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

bootstrap the playhead

Browse source
This commit is contained in:
deflax 2024-01-07 05:55:09 +02:00
parent a6caa2b0bf
commit 2fc10cf2e6
1 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/scheduler/app.py
View file

@ -61,8 +61,12 @@ def process_running_channel(database, scheduler, stream_id, stream_name, stream_
scheduler.add_job( scheduler.add_job(
func=stream_exec, trigger='cron', hour=stream_start, jitter=60, func=stream_exec, trigger='cron', hour=stream_start, jitter=60,
id=stream_id, args=(stream_id, stream_name, stream_prio, stream_hls_url) id=stream_id, args=(stream_id, stream_name, stream_prio, stream_hls_url)
) )
database.update({stream_id: {'name': stream_name, 'start_at': stream_start, 'meta': stream_description, 'src': stream_hls_url}}) database.update({stream_id: {'name': stream_name, 'start_at': stream_start, 'meta': stream_description, 'src': stream_hls_url}})
# Bootstrap the playhead if its still empty.
if head == {}:
fallback = fallback_search(database)
scheduler.add_job(func=stream_exec, id="fallback", args=(fallback['stream_id'], fallback['stream_name'], 0, fallback['stream_hls_url']))
# Helper function to remove channel from the database # Helper function to remove channel from the database
def remove_channel_from_database(database, scheduler, stream_id, stream_name, state): def remove_channel_from_database(database, scheduler, stream_id, stream_name, state):