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

change the way we read the epg

Browse source
This commit is contained in:
deflax 2024-01-06 06:48:06 +02:00
parent 0f713cdc53
commit 218331efc1
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/scheduler/app.py
View file

@ -15,9 +15,13 @@ logger.setLevel(os.environ.get('SCHEDULER_LOG_LEVEL', 'INFO').upper())
database = {} database = {}
prio = 0 prio = 0
head = {} head = {}
with open('/config/epg.json', 'r') as json_file:
# Load the epg.json config file epg_json = open('/config/epg.json', 'r')
epg_json = json.load(json_file) epg = json.load(epg_json)
for i in epg:
logger.info(i)
epg_json.close()
# Environment # Environment
api_hostname = os.environ.get('CORE_API_HOSTNAME') api_hostname = os.environ.get('CORE_API_HOSTNAME')
@ -77,6 +81,7 @@ except Exception as err:
def core_api_sync(): def core_api_sync():
global database global database
global epg
global prio global prio
new_ids = [] new_ids = []
try: try:
@ -115,7 +120,7 @@ def core_api_sync():
continue continue
else: else:
logger.info('{} ({}) has been registered to the database'.format(stream_id, stream_name)) logger.info('{} ({}) has been registered to the database'.format(stream_id, stream_name))
epg_result = find_event_entry(epg_json, stream_name) epg_result = find_event_entry(epg, stream_name)
stream_prio = epg_result['prio'] stream_prio = epg_result['prio']
try: try:
stream_start_time = epg_result['start_at'] stream_start_time = epg_result['start_at']