kurbezz/discord-bot
1
0
Fork 0
mirror of https://github.com/kurbezz/discord-bot.git synced 2026-03-03 15:40:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix

Browse Source
This commit is contained in:
Bulat Kurbanov
2024-11-28 17:34:22 +01:00
parent df7285a37b
commit 87b44b7835
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/modules/stream_notifications/twitch/webhook.py
View File

@@ -1,4 +1,4 @@
from asyncio import sleep, gather from asyncio import sleep, gather, get_running_loop
from datetime import datetime, timezone from datetime import datetime, timezone
import logging import logging
from typing import NoReturn, Literal from typing import NoReturn, Literal
@@ -24,6 +24,7 @@ class TwitchService:
ONLINE_NOTIFICATION_DELAY = 15 * 60 ONLINE_NOTIFICATION_DELAY = 15 * 60
def __init__(self, twitch: Twitch): def __init__(self, twitch: Twitch):
self.loop = get_
self.twitch = twitch self.twitch = twitch
async def on_channel_update(self, event: ChannelUpdateEvent): async def on_channel_update(self, event: ChannelUpdateEvent):
@@ -91,10 +92,13 @@ class TwitchService:
logger.info(f"Subscribe to events for {streamer.twitch.name} done") logger.info(f"Subscribe to events for {streamer.twitch.name} done")
async def _check_token(self): async def _check_token(self):
while True: assert self.twitch._user_auth_token is not None
await sleep(60)
assert self.twitch._user_auth_token is not None while True:
for _ in range(60):
loop = get_running_loop()
if loop.is_closed():
return
logger.info("Check token...") logger.info("Check token...")
val_result = await validate_token( val_result = await validate_token(