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

Compare commits

base: deflax:49f454c5a70453c5d7f9ab9a7cd04e7895d06052
Branches Tags
deflax:main
...
compare: deflax:22cda2f77c7da75d173094a6cd19164767e9d007
Branches Tags
deflax:main

2 commits
49f454c5a7 ... 22cda2f77c

Author SHA1 Message Date
deflax
22cda2f77c Skip non readable meta 2025-03-05 00:22:45 +00:00
deflax
4800739a25 Simple playhead log 2025-03-05 00:14:31 +00:00
1 changed files with 5 additions and 7 deletions
Show stats Expand all files Collapse all files

12
src/api/app/flask_api.py
View file

@ -50,7 +50,7 @@ def get_core_process_details(client, process_id):
# Process a running channel
def process_running_channel(database, scheduler, stream_id, stream_name, stream_description, stream_hls_url):
if stream_id in database:
# Skip learned channels
# Skip already learned channels
return
else:
try:
@ -59,12 +59,11 @@ def process_running_channel(database, scheduler, stream_id, stream_name, stream_
stream_start = api_settings.get('start_at')
stream_prio = api_settings.get('prio', 0)
except Exception as e:
logger_job.error(e)
# Skip channels without readable meta
return
logger_job.warning(f'{stream_id} ({stream_name}) has been registered.')
if stream_start == "now":
logger_job.warning("Stream should start now. Preparing")
logger_job.warning(f'{stream_id} ({stream_name}) has been registered with {api_settings} ')
if stream_start == "now":
# Check if the stream_hls_url returns 200
req_counter = 0
while True:
@ -80,7 +79,6 @@ def process_running_channel(database, scheduler, stream_id, stream_name, stream_
return
scheduler.add_job(func=exec_stream, id=stream_id, args=(stream_id, stream_name, stream_prio, stream_hls_url))
else:
logger_job.warning(f"Stream start hour is set to {stream_start}")
scheduler.add_job(
func=exec_stream, trigger='cron', hour=stream_start, jitter=60,
id=stream_id, args=(stream_id, stream_name, stream_prio, stream_hls_url)
@ -144,7 +142,7 @@ def update_playhead(stream_id, stream_name, stream_prio, stream_hls_url):
"name": stream_name,
"prio": stream_prio,
"head": stream_hls_url }
logger_job.warning(f'Playhead position is: {str(playhead)}')
logger_job.warning(f'Playhead: {str(playhead)}')
# Execute stream
def exec_stream(stream_id, stream_name, stream_prio, stream_hls_url):