deflax/television
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

dont add announcement job if one exists

Browse source
This commit is contained in:
deflax 2024-01-17 05:13:57 +02:00
parent 751edc5903
commit 41e2e5f77c
1 changed files with 9 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/discordbot/discordbot.py
View file

@ -77,10 +77,14 @@ async def update_database():
stream_name = value['name'] stream_name = value['name']
stream_start_at = value['start_at'] stream_start_at = value['start_at']
if stream_start_at == 'now': if stream_start_at == 'now':
logger_discord.info(f'{stream_name} live stream detected!') try:
scheduler.add_job(func=announce_live_channel, trigger='interval', seconds=60, id='announce_live_channel', args=(stream_name,)) job = scheduler.get_job('announce_live_channel')
return if not job:
logger_discord.info(f'{stream_name} live stream detected!')
scheduler.add_job(func=announce_live_channel, trigger='interval', seconds=60, id='announce_live_channel', args=(stream_name,))
return
except JobLookupError:
pass
try: try:
job = scheduler.get_job('announce_live_channel') job = scheduler.get_job('announce_live_channel')
if job: if job:
@ -88,10 +92,8 @@ async def update_database():
live_channel = bot.get_channel(announce_channel_id) live_channel = bot.get_channel(announce_channel_id)
logger_discord.info(f'{stream_name} finished') logger_discord.info(f'{stream_name} finished')
await live_channel.send(f'{stream_name} finished') await live_channel.send(f'{stream_name} finished')
else:
return
except JobLookupError: except JobLookupError:
return pass
async def announce_live_channel(stream_name): async def announce_live_channel(stream_name):
if announce_channel_id == 'disabled': if announce_channel_id == 'disabled':