{variante === 'linux' ? 'Auf der Linux-Maschine (mit Docker) ausführen — WORKER_NAME frei wählen, unter dem Namen taucht sie oben auf und übernimmt Kompressions-Jobs. GPU wird erkannt und angezeigt.' - : 'In einer PowerShell auf dem Windows-PC ausführen (braucht nur Python 3.10+ — kein Docker, kein git). Der Installer holt Worker-Code und HandBrake automatisch von dieser Rippy-Instanz bzw. dem offiziellen HandBrake-Release und erzeugt eine start-worker.bat. Autostart bei Anmeldung: Parameter -Autostart anhängen.'} + : 'In einer PowerShell auf dem Windows-PC ausführen (braucht nur Python 3.10+ — kein Docker, kein git). Der Installer holt Worker-Code und HandBrake automatisch und erzeugt: start-tray.bat (Tray-Symbol neben der Uhr mit Start/Stopp/Status), start-worker.bat (Konsole, für Fehlersuche) und uninstall.ps1 (entfernt alles rückstandsfrei inkl. Worker-Eintrag hier). Autostart bei Anmeldung: Parameter -Autostart anhängen.'}
+ Der Windows-Worker läuft mit Tray-Symbol neben der Uhr
+ (Status, Start/Stopp, „Rippy öffnen", Log) — gestartet über start-tray.bat.
+ Deinstallieren: uninstall.ps1 im Worker-Ordner stoppt alles, entfernt den
+ Autostart, meldet den Worker in Rippy ab und löscht den Ordner rückstandsfrei.
+
Wichtig: Worker verbinden sich direkt im Heimnetz — in den Befehlen immer die LAN-Adresse der Rippy-Maschine verwenden, diff --git a/docker/worker/tray.py b/docker/worker/tray.py new file mode 100644 index 0000000..07d1628 --- /dev/null +++ b/docker/worker/tray.py @@ -0,0 +1,121 @@ +"""Tray-Symbol für den NATIVEN Windows-Worker (nicht im Docker-Image genutzt). + +Zeigt den Worker-Status unten rechts neben der Uhr und bietet: +Start/Stopp, Rippy im Browser öffnen, Log anzeigen, Beenden. Gestartet +wird es über start-tray.bat (setzt die Verbindungs-Umgebung und ruft +pythonw.exe auf — kein Konsolenfenster). Der Worker-Prozess (celery, +Queue transcode) läuft als Kind-Prozess und stoppt mit dem Tray. + +Abhängigkeiten pystray + Pillow installiert NUR der Windows-Installer +(install.ps1) — das Docker-Image bleibt davon unberührt. +""" + +import os +import subprocess +import sys +import webbrowser + +try: + import pystray + from PIL import Image, ImageDraw +except ImportError: + print("Tray braucht pystray + Pillow — install.ps1 erneut ausführen.") + sys.exit(1) + +BASIS = os.path.dirname(os.path.abspath(__file__)) +RIPPY_HOST = os.getenv("RIPPY_TRAY_HOST", "") +WORKER_NAME = os.getenv("WORKER_NAME", "windows-worker") +LOG_PFAD = os.path.join(BASIS, "worker.log") + +prozess = None + + +def disc_bild(laeuft: bool) -> Image.Image: + """Disc-Symbol im Rippy-Look: Indigo wenn der Worker läuft, grau sonst.""" + bild = Image.new("RGBA", (64, 64), (0, 0, 0, 0)) + zeichner = ImageDraw.Draw(bild) + farbe = (99, 102, 241, 255) if laeuft else (125, 132, 145, 255) + zeichner.ellipse([4, 4, 60, 60], fill=farbe) + zeichner.ellipse([24, 24, 40, 40], fill=(255, 255, 255, 255)) + return bild + + +def worker_laeuft() -> bool: + return prozess is not None and prozess.poll() is None + + +def worker_starten(icon=None, item=None): + global prozess + if worker_laeuft(): + return + celery = os.path.join(BASIS, "venv", "Scripts", "celery.exe") + log = open(LOG_PFAD, "a", encoding="utf-8", errors="replace") + prozess = subprocess.Popen( + [celery, "-A", "celery_app", "worker", "--loglevel=info", + "-Q", "transcode", "--pool=solo", "-n", f"{WORKER_NAME}@%h"], + cwd=BASIS, stdout=log, stderr=subprocess.STDOUT, + creationflags=getattr(subprocess, "CREATE_NO_WINDOW", 0), + ) + if icon: + icon.icon = disc_bild(True) + icon.update_menu() + + +def worker_stoppen(icon=None, item=None): + global prozess + if worker_laeuft(): + prozess.terminate() + try: + prozess.wait(15) + except subprocess.TimeoutExpired: + prozess.kill() + prozess = None + if icon: + icon.icon = disc_bild(False) + icon.update_menu() + + +def umschalten(icon, item): + if worker_laeuft(): + worker_stoppen(icon) + else: + worker_starten(icon) + + +def rippy_oeffnen(icon, item): + if RIPPY_HOST: + webbrowser.open(f"http://{RIPPY_HOST}") + + +def log_anzeigen(icon, item): + if os.path.exists(LOG_PFAD): + os.startfile(LOG_PFAD) # noqa: S606 — bewusst: Standard-Editor des Nutzers + + +def beenden(icon, item): + worker_stoppen() + icon.stop() + + +menue = pystray.Menu( + pystray.MenuItem( + lambda item: f'Rippy-Worker "{WORKER_NAME}": {"läuft" if worker_laeuft() else "gestoppt"}', + None, enabled=False, + ), + pystray.Menu.SEPARATOR, + pystray.MenuItem( + lambda item: "Worker stoppen" if worker_laeuft() else "Worker starten", + umschalten, + ), + pystray.MenuItem("Rippy öffnen", rippy_oeffnen), + pystray.MenuItem("Log anzeigen", log_anzeigen), + pystray.Menu.SEPARATOR, + pystray.MenuItem("Beenden (stoppt den Worker)", beenden), +) + + +if __name__ == "__main__": + tray = pystray.Icon("rippy-worker", disc_bild(False), "Rippy Worker", menue) + worker_starten() + tray.icon = disc_bild(worker_laeuft()) + tray.run()