self/botalka
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: self:c6a2710087ea31a22592c4ddbb8568e578b82fd0
Branches Tags
self:master
self:prod
self:metric
self:dev
..
compare: self:42fc5552abd096a9772a41bdea2b7c2a5787fa4f
Branches Tags
self:master
self:prod
self:metric
self:dev

No commits in common. "c6a2710087ea31a22592c4ddbb8568e578b82fd0" and "42fc5552abd096a9772a41bdea2b7c2a5787fa4f" have entirely different histories.
c6a2710087 ... 42fc5552ab

1 changed files with 20 additions and 21 deletions
Show Stats Expand all files Collapse all files

41
daemons/poll.py
View File

@ -12,28 +12,27 @@ class Daemon(base.Daemon):
self.telegram_pollers: dict[str, dict[str, multiprocessing.Process|None]] = {} self.telegram_pollers: dict[str, dict[str, multiprocessing.Process|None]] = {}
def execute(self): def execute(self):
while True: bots = platform.platform_client.get_config('bots')
bots = platform.platform_client.get_config('bots') for project_name, project in bots.items():
for project_name, project in bots.items(): if project_name not in self.telegram_pollers:
if project_name not in self.telegram_pollers: self.telegram_pollers[project_name] = {}
self.telegram_pollers[project_name] = {} for bot_name, bot_info in project.items():
for bot_name, bot_info in project.items(): if bot_name not in self.telegram_pollers[project_name]:
if bot_name not in self.telegram_pollers[project_name]: self.telegram_pollers[project_name][bot_name] = None
process = self.telegram_pollers[project_name][bot_name]
if bot_info.get('poll_enabled'):
if process is not None and process.is_alive:
continue
new_process = multiprocessing.Process(target=self.start_polling, args=[bot_info['secrets']['telegram_token'], bot_info['queue']])
new_process.start()
self.telegram_pollers[project_name][bot_name] = new_process
else:
if process is None:
continue
if process.is_alive:
process.terminate()
self.telegram_pollers[project_name][bot_name] = None self.telegram_pollers[project_name][bot_name] = None
process = self.telegram_pollers[project_name][bot_name] time.sleep(10)
if bot_info.get('poll_enabled'):
if process is not None and process.is_alive:
continue
new_process = multiprocessing.Process(target=self.start_polling, args=[bot_info['secrets']['telegram_token'], bot_info['queue']])
new_process.start()
self.telegram_pollers[project_name][bot_name] = new_process
else:
if process is None:
continue
if process.is_alive:
process.terminate()
self.telegram_pollers[project_name][bot_name] = None
time.sleep(10)
def start_polling(telegram_token, queue): def start_polling(telegram_token, queue):
bot = telebot.TeleBot(telegram_token) bot = telebot.TeleBot(telegram_token)