neuro_llc/neuro-reply-bot-reworked
2
0
Fork 0
mirror of https://github.com/MrSedan/neuro-reply-bot-reworked.git synced 2026-01-14 13:39:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

Get active settings

Browse Source
This commit is contained in:
Sergey Elpashev
2024-02-14 22:41:40 +03:00
parent 0babe084ad
commit 5a402fcd5b
2 changed files with 19 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
handlers/message_handlers/update_settings.py
View File

@@ -17,20 +17,15 @@ class UpdateSettingsCommand(MessageHandlerABC):
filter = Command('update_settings')
async def settings_and_schedule_checker(self):
await self._command()
await self._auto_update_settings()
while 1:
await schedule.run_pending()
await asyncio.sleep(1)
def __init__(self, bot: Bot, post_command: Coroutine, *args) -> None:
super().__init__(bot)
self.post = post_command
asyncio.create_task(self.settings_and_schedule_checker())
async def _command(self, mes: types.Message | None = None):
async def _auto_update_settings(self):
self.settings = await neuroapi.bot_settings.get()
schedule.clear()
schedule.every().minute.do(self._command, None)
schedule.every().minute.do(self._auto_update_settings)
# TODO: Сделать в бэке и в боте, чтоб дни тоже можно было в настройках хранить
for i in self.settings.message_times:
@@ -40,6 +35,13 @@ class UpdateSettingsCommand(MessageHandlerABC):
schedule.every().thursday.at(i).do(self.post, None)
schedule.every().friday.at(i).do(self.post, None)
schedule.every().sunday.at(i).do(self.post, None)
if mes:
await mes.answer('Настройки обновлены!')
def __init__(self, bot: Bot, post_command: Coroutine, *args) -> None:
super().__init__(bot)
self.post = post_command
asyncio.create_task(self.settings_and_schedule_checker())
async def _command(self, mes: types.Message):
self.settings = await neuroapi.bot_settings.get_update()
await mes.answer('Настройки обновлены')

6
neuroapi/_methods/bot_settings.py
View File

@@ -10,4 +10,10 @@ class BotSettings(ApiMethod):
async with ClientSession() as session:
response = await session.get(self.api_url+'/settings')
settings = BotSettingsType.from_dict(await response.json())
return settings
async def get_update(self) -> BotSettingsType:
async with ClientSession() as session:
response = await session.get(self.api_url+'/settings/active')
settings = BotSettingsType.from_dict(await response.json())
return settings