Merge pull request #20 from ArcReactorKC/codex/add-buymeacoffee-link-to-webui-ir1167

Start scheduler on first request under gunicorn

Author: ArcReactorKC

Dockerfile

@@ -16,4 +16,4 @@ ENV DATA_DIR=/data \
     DEVICE_DB=/data/devices.json \
     BACKUP_OUTPUT_DIR=/backups
 
-CMD ["python", "/app/app/app.py"]
+CMD ["gunicorn", "-w", "2", "-k", "gthread", "--threads", "4", "-b", "0.0.0.0:5000", "--access-logfile", "-", "--error-logfile", "-", "--chdir", "/app/app", "app:app"]

app/app.py

@@ -1,14 +1,27 @@
+import fcntl
 import json
 import os
 import shutil
 import stat
 import tempfile
 import threading
+import warnings
+from datetime import datetime, timezone
 from ftplib import FTP, all_errors as ftp_errors
 from datetime import datetime, timezone
 from pathlib import Path
 from typing import Optional
 
+from cryptography.utils import CryptographyDeprecationWarning
+
+warnings.filterwarnings(
+    "ignore",
+    message=(
+        r".*TripleDES has been moved to cryptography\.hazmat\.decrepit\.ciphers\.algorithms\.TripleDES.*"
+    ),
+    category=CryptographyDeprecationWarning,
+)
+
 import paramiko
 from apscheduler.schedulers.background import BackgroundScheduler
 from apscheduler.triggers.interval import IntervalTrigger
@@ -39,6 +52,8 @@
 scheduler = BackgroundScheduler()
 backup_status_lock = threading.Lock()
 backup_status = {}
+_scheduler_lock_handle = None
+_scheduler_started = False
 
 
 def load_devices():
@@ -365,6 +380,29 @@ def refresh_schedule():
     save_devices(devices_list)
 
 
+def start_scheduler():
+    global _scheduler_lock_handle, _scheduler_started
+    if _scheduler_started:
+        return
+    lock_path = DATA_DIR / "scheduler.lock"
+    lock_path.parent.mkdir(parents=True, exist_ok=True)
+    lock_file = lock_path.open("w")
+    try:
+        fcntl.flock(lock_file.fileno(), fcntl.LOCK_EX | fcntl.LOCK_NB)
+    except OSError:
+        lock_file.close()
+        return
+    _scheduler_lock_handle = lock_file
+    refresh_schedule()
+    scheduler.start()
+    _scheduler_started = True
+
+
+@app.before_request
+def _start_scheduler_once():
+    start_scheduler()
+
+
 @app.route("/")
 def index():
     return render_template("index.html", intervals=sorted(INTERVAL_SECONDS.keys()))
@@ -508,6 +546,5 @@ def browse():
 
 
 if __name__ == "__main__":
-    refresh_schedule()
-    scheduler.start()
+    start_scheduler()
     app.run(host="0.0.0.0", port=int(os.getenv("PORT", "5000")))

requirements.txt

@@ -1,3 +1,4 @@
-Flask==3.0.2
+Flask==3.0.3
 APScheduler==3.10.4
-paramiko==3.4.0
+paramiko==3.5.0
+gunicorn==22.0.0