danvics/ytptube
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

Added backward compatibility fix.

Browse source
This commit is contained in:
ArabCoders 2025-01-24 23:25:03 +03:00
parent a4827202d8
commit e5f2a09cc7
1 changed files with 21 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
app/main.py
View file

@ -10,6 +10,7 @@ from datetime import datetime
from pathlib import Path from pathlib import Path
import time import time
from typing import TypedDict from typing import TypedDict
import uuid
import caribou import caribou
import magic import magic
@ -180,9 +181,10 @@ class Main:
self.cron.clear() self.cron.clear()
if not tasks or len(tasks) < 1: if not tasks or len(tasks) < 1:
LOG.warning(f"No tasks found in '{tasksFile}'.") LOG.info(f"No tasks found in '{tasksFile}'.")
return return
modified = False
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
for task in tasks: for task in tasks:
if not task.get("url"): if not task.get("url"):
@ -190,12 +192,19 @@ class Main:
continue continue
try: try:
cron_timer: str = task.get("timer", f"{random.randint(1,59)} */1 * * *") if not task.get("timer", None):
task["timer"] = f"{random.randint(1,59)} */1 * * *"
modified = True
if not task.get("id", None):
task["id"] = str(uuid.uuid4())
modified = True
self.cron.append( self.cron.append(
job_item( job_item(
name=task.get("name", "??"), name=task.get("name", "??"),
job=crontab( job=crontab(
spec=cron_timer, spec=task.get("timer"),
func=self.cron_runner, func=self.cron_runner,
args=(task,), args=(task,),
start=True, start=True,
@ -204,11 +213,19 @@ class Main:
) )
) )
LOG.info(f"Queued 'Task: {task.get('name','??')}' to be executed every '{cron_timer}'.") LOG.info(f"Queued 'Task: {task.get('name','??')}' to be executed every '{task.get('timer')}'.")
except Exception as e: except Exception as e:
LOG.error(f"Failed to add 'Task: {task.get('name', '??')}'. Error message '{str(e)}'.") LOG.error(f"Failed to add 'Task: {task.get('name', '??')}'. Error message '{str(e)}'.")
LOG.exception(e) LOG.exception(e)
if modified:
try:
with open(tasksFile, "w") as f:
f.write(json.dumps(tasks, indent=4))
except Exception as e:
LOG.error(f"Failed to save tasks file '{tasksFile}'. Error message '{str(e)}'.")
LOG.exception(e)
self.config.tasks = tasks self.config.tasks = tasks
def start(self): def start(self):