lapatatedouce/MamieHenriette
1
0
Fork 0
mirror of https://github.com/skylanix/MamieHenriette.git synced 2026-02-06 06:40:35 +01:00
Code Issues Packages Projects Releases Wiki Activity

correction logger live logging

Browse Source
This commit is contained in:
Kepka Ludovic
2025-09-14 00:44:40 +02:00
parent d2baa164d4
commit 46c927a768
1 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
twitchbot/live_alert.py
View File

@@ -8,6 +8,9 @@ from database.models import LiveAlert
from discordbot import bot
from webapp import webapp
logger = logging.getLogger('live-alert')
logger.setLevel(logging.INFO)
async def checkOnlineStreamer(twitch: Twitch) :
with webapp.app_context() :
@@ -16,31 +19,31 @@ async def checkOnlineStreamer(twitch: Twitch) :
for alert in alerts :
stream = next((s for s in streams if s.user_login == alert.login), None)
if stream :
logging.info(f'Streamer en ligne : {alert.login}')
logger.info(f'Streamer en ligne : {alert.login}')
if not alert.online and alert.enable :
logging.info(f'N\'etait pas en ligne auparavant : {alert.login}')
logger.info(f'N\'etait pas en ligne auparavant : {alert.login}')
await _notifyAlert(alert, stream)
alert.online = True
else :
logging.info(f'Streamer hors ligne : {alert.login}')
logger.info(f'Streamer hors ligne : {alert.login}')
alert.online = False
db.session.commit()
async def _notifyAlert(alert : LiveAlert, stream : Stream):
message : str = alert.message.format(stream)
logging.info(f'Message de notification : {message}')
logger.info(f'Message de notification : {message}')
bot.loop.create_task(_sendMessage(alert.notify_channel, message))
async def _sendMessage(channel : int, message : str) :
logging.info(f'Envoi de notification : {message}')
logger.info(f'Envoi de notification : {message}')
await bot.get_channel(channel).send(message)
logging.info(f'Notification envoyé')
logger.info(f'Notification envoyé')
async def _retreiveStreams(twitch: Twitch, alerts : list[LiveAlert]) -> list[Stream] :
streams : list[Stream] = []
logging.info(f'Recherche de streams pour : {alerts}')
logger.info(f'Recherche de streams pour : {alerts}')
async for stream in twitch.get_streams(user_login = [alert.login for alert in alerts]):
streams.append(stream)
logging.info(f'Ces streams sont en ligne : {streams}')
logger.info(f'Ces streams sont en ligne : {streams}')
return streams