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

print_jobs on db query

Browse source
This commit is contained in:
deflax 2025-02-08 03:25:26 +00:00
parent 2ec0eaf556
commit 4676e251e2
1 changed files with 3 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/discordbot/discordbot.py
View file

@ -49,7 +49,6 @@ async def on_ready():
# Schedule a database update
scheduler.add_job(func=query_database, trigger='interval', seconds=30, id='query_database')
scheduler.get_job('query_database').modify(next_run_time=datetime.now())
logger_discord.info(scheduler.print_jobs())
@bot.command(name='hello', help='Say hello to the bot')
@has_role(worshipper_role_name)
@ -101,7 +100,6 @@ async def rec(ctx):
# Check if the recorder job already exists
if scheduler.get_job('recorder') is None:
scheduler.add_job(func=exec_recorder, id='recorder', args=playhead)
logger_discord.info(scheduler.print_jobs())
await ctx.channel.send(f'Recording from {stream_name} (prio={stream_prio})')
else:
await ctx.channel.send(f'Recorder is busy!')
@ -118,7 +116,6 @@ async def stop(ctx):
if scheduler.get_job('recorder') is not None:
await ctx.channel.send(f'Shutting down recorder')
scheduler.remove_job('recorder')
logger_discord.info(scheduler.print_jobs())
else:
await ctx.channel.send(f'Recorder is stopped.')
@ -158,6 +155,9 @@ async def query_database():
if database == {}:
logger_discord.error('Database is empty!')
return
# List jobs
logger_discord.info(scheduler.print_jobs())
# Search for live streams and announce them
for key, value in database.items():
@ -171,7 +171,6 @@ async def query_database():
logger_discord.info(f'{stream_name} live stream detected!')
scheduler.add_job(func=announce_live_channel, trigger='interval', minutes=int(live_channel_update), id='announce_live_channel', args=(stream_name, stream_meta))
scheduler.get_job('announce_live_channel').modify(next_run_time=datetime.now())
logger_discord.info(scheduler.print_jobs())
return
else:
# Exit since we already have a live announcement job
@ -180,7 +179,6 @@ async def query_database():
# Cleanup the announce job
if scheduler.get_job('announce_live_channel') is not None:
scheduler.remove_job('announce_live_channel')
logger_discord.info(scheduler.print_jobs())
if live_channel_id != 0:
live_channel = bot.get_channel(int(live_channel_id))
await live_channel.send(f'{stream_name} is offline.')