aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--handlers/admin/add_user.py8
-rw-r--r--handlers/admin/new_announcement.py8
-rw-r--r--handlers/admin/new_invoice.py12
-rw-r--r--libs/msg.py4
4 files changed, 16 insertions, 16 deletions
diff --git a/handlers/admin/add_user.py b/handlers/admin/add_user.py
index b9b8604..c58af2b 100644
--- a/handlers/admin/add_user.py
+++ b/handlers/admin/add_user.py
@@ -34,7 +34,7 @@ CANCEL_BUTTON = "Отменить добавление"
34 34
35 35
36@router.message(Command("add_user")) 36@router.message(Command("add_user"))
37async def add_user_command(msg: Message, state: FSMContext) -> None: 37async def command(msg: Message, state: FSMContext) -> None:
38 await msg.answer( 38 await msg.answer(
39 "Выберете пользователя которого хотите добавить.", 39 "Выберете пользователя которого хотите добавить.",
40 reply_markup=ReplyKeyboardMarkup( 40 reply_markup=ReplyKeyboardMarkup(
@@ -58,7 +58,7 @@ async def add_user_command(msg: Message, state: FSMContext) -> None:
58 58
59 59
60@router.message(AddUserStates(), F.text == CANCEL_BUTTON) 60@router.message(AddUserStates(), F.text == CANCEL_BUTTON)
61async def add_user_cancel(msg: Message, state: FSMContext) -> None: 61async def cancel(msg: Message, state: FSMContext) -> None:
62 await msg.answer( 62 await msg.answer(
63 "Добавление пользователей отменено", 63 "Добавление пользователей отменено",
64 reply_markup=ReplyKeyboardRemove(), 64 reply_markup=ReplyKeyboardRemove(),
@@ -67,7 +67,7 @@ async def add_user_cancel(msg: Message, state: FSMContext) -> None:
67 67
68 68
69@router.message(AddUserStates.user_id) 69@router.message(AddUserStates.user_id)
70async def add_user_user_id(msg: Message, state: FSMContext) -> None: 70async def set_user_id(msg: Message, state: FSMContext) -> None:
71 if msg.users_shared is None: 71 if msg.users_shared is None:
72 await msg.answer("Вы должны воспользоваться кнопкой ниже.") 72 await msg.answer("Вы должны воспользоваться кнопкой ниже.")
73 return 73 return
@@ -80,7 +80,7 @@ async def add_user_user_id(msg: Message, state: FSMContext) -> None:
80 80
81 81
82@router.message(AddUserStates.vpn_link) 82@router.message(AddUserStates.vpn_link)
83async def add_user_vpn_link( 83async def set_vpn_link(
84 msg: Message, 84 msg: Message,
85 state: FSMContext, 85 state: FSMContext,
86 session: AsyncSession, 86 session: AsyncSession,
diff --git a/handlers/admin/new_announcement.py b/handlers/admin/new_announcement.py
index 6aa099e..e8aacb0 100644
--- a/handlers/admin/new_announcement.py
+++ b/handlers/admin/new_announcement.py
@@ -36,7 +36,7 @@ CANCEL_BUTTON = "Отменить создание"
36 36
37 37
38@router.message(Command("new_announcement")) 38@router.message(Command("new_announcement"))
39async def new_announcement_command(msg: Message, state: FSMContext) -> None: 39async def command(msg: Message, state: FSMContext) -> None:
40 await msg.answer( 40 await msg.answer(
41 "Укажите сообщение для анонса.", 41 "Укажите сообщение для анонса.",
42 reply_markup=ReplyKeyboardMarkup( 42 reply_markup=ReplyKeyboardMarkup(
@@ -53,7 +53,7 @@ async def new_announcement_command(msg: Message, state: FSMContext) -> None:
53 53
54 54
55@router.message(NewAnnouncementStates.message, F.text == SEND_BUTTON) 55@router.message(NewAnnouncementStates.message, F.text == SEND_BUTTON)
56async def announcement_send( 56async def publish(
57 msg: Message, 57 msg: Message,
58 bot: Bot, 58 bot: Bot,
59 state: FSMContext, 59 state: FSMContext,
@@ -88,13 +88,13 @@ async def announcement_send(
88 88
89 89
90@router.message(NewAnnouncementStates.message, F.text == CANCEL_BUTTON) 90@router.message(NewAnnouncementStates.message, F.text == CANCEL_BUTTON)
91async def announcement_cancel(msg: Message, state: FSMContext) -> None: 91async def cancel(msg: Message, state: FSMContext) -> None:
92 await msg.answer("Создание анонса отменено", reply_markup=ReplyKeyboardRemove()) 92 await msg.answer("Создание анонса отменено", reply_markup=ReplyKeyboardRemove())
93 await state.clear() 93 await state.clear()
94 94
95 95
96@router.message(NewAnnouncementStates.message) 96@router.message(NewAnnouncementStates.message)
97async def announcement_message(msg: Message, bot: Bot, state: FSMContext) -> None: 97async def set_message(msg: Message, bot: Bot, state: FSMContext) -> None:
98 if msg.text is None: 98 if msg.text is None:
99 await msg.answer( 99 await msg.answer(
100 "Неверный тип сообщения.\n" 100 "Неверный тип сообщения.\n"
diff --git a/handlers/admin/new_invoice.py b/handlers/admin/new_invoice.py
index 0427d90..43e47cb 100644
--- a/handlers/admin/new_invoice.py
+++ b/handlers/admin/new_invoice.py
@@ -36,7 +36,7 @@ CANCEL_BUTTON = "Отменить создание"
36 36
37 37
38@router.message(Command("new_invoice")) 38@router.message(Command("new_invoice"))
39async def new_invoice_command(msg: Message, state: FSMContext) -> None: 39async def command(msg: Message, state: FSMContext) -> None:
40 await msg.answer( 40 await msg.answer(
41 "Укажите сообщение для создания счёта", 41 "Укажите сообщение для создания счёта",
42 reply_markup=ReplyKeyboardMarkup( 42 reply_markup=ReplyKeyboardMarkup(
@@ -53,7 +53,7 @@ async def new_invoice_command(msg: Message, state: FSMContext) -> None:
53 53
54 54
55@router.message(NewInvoiceStates.message, F.text == CREATE_BUTTON) 55@router.message(NewInvoiceStates.message, F.text == CREATE_BUTTON)
56async def invoice_send( 56async def create(
57 msg: Message, 57 msg: Message,
58 bot: Bot, 58 bot: Bot,
59 state: FSMContext, 59 state: FSMContext,
@@ -82,19 +82,19 @@ async def invoice_send(
82 await status_msg.delete() 82 await status_msg.delete()
83 await msg.answer( 83 await msg.answer(
84 "Счёт отправлен всем пользователям", 84 "Счёт отправлен всем пользователям",
85 # reply_markup=ReplyKeyboardRemove(), 85 reply_markup=ReplyKeyboardRemove(),
86 ) 86 )
87 # await state.clear() 87 await state.clear()
88 88
89 89
90@router.message(NewInvoiceStates.message, F.text == CANCEL_BUTTON) 90@router.message(NewInvoiceStates.message, F.text == CANCEL_BUTTON)
91async def invoice_cancel(msg: Message, state: FSMContext) -> None: 91async def cancel(msg: Message, state: FSMContext) -> None:
92 await msg.answer("Создание счёта отменено", reply_markup=ReplyKeyboardRemove()) 92 await msg.answer("Создание счёта отменено", reply_markup=ReplyKeyboardRemove())
93 await state.clear() 93 await state.clear()
94 94
95 95
96@router.message(NewInvoiceStates.message) 96@router.message(NewInvoiceStates.message)
97async def invoice_message(msg: Message, bot: Bot, state: FSMContext) -> None: 97async def set_message(msg: Message, bot: Bot, state: FSMContext) -> None:
98 if msg.text is None: 98 if msg.text is None:
99 await msg.answer( 99 await msg.answer(
100 "Неверный тип сообщения.\n" 100 "Неверный тип сообщения.\n"
diff --git a/libs/msg.py b/libs/msg.py
index 05bddfc..2e9e16b 100644
--- a/libs/msg.py
+++ b/libs/msg.py
@@ -23,7 +23,7 @@ async def publish_announcement(
23 except TelegramRetryAfter as e: 23 except TelegramRetryAfter as e:
24 await asyncio.sleep(e.retry_after + 1) 24 await asyncio.sleep(e.retry_after + 1)
25 except TelegramAPIError: 25 except TelegramAPIError:
26 await asyncio.sleep(5) 26 await asyncio.sleep(0.2)
27 27
28 yield n 28 yield n
29 29
@@ -55,6 +55,6 @@ async def send_invoice(
55 except TelegramRetryAfter as e: 55 except TelegramRetryAfter as e:
56 await asyncio.sleep(e.retry_after + 1) 56 await asyncio.sleep(e.retry_after + 1)
57 except TelegramAPIError: 57 except TelegramAPIError:
58 await asyncio.sleep(5) 58 await asyncio.sleep(0.2)
59 59
60 yield n 60 yield n