"""Manifestes d'apps : ~/dispatch/apps/.json (source de vérité de « comment » tourne une app). Schéma : { "app": "lou-ka", "label": "Lou-Ka", "domain": "www.lou-ka.com", "port": 8095, "health_path": "/", "dir": "~/apps/lou-ka", # répertoire de l'app (même chemin absolu sur tous les nœuds) "extra_paths": ["~/.ssh/trouveka_tunnel"], # autres fichiers/dossiers à copier avec l'app "sync_excludes": ["data/backups/"], # exclusions rsync (relatives à dir) "requires": {"runtimes": ["python@3.14", "pm2", "ngrok"], "ram_gb": 2, "ports": [8095]}, "ram_mb_observed": 400, "size_mb": 4359, "placement": {"pin": null, "prefer": null, "avoid": [], "reason": ""}, "processes": [{"name": "lou-ka-web", "manager": "pm2", "script": "...", "args": [...], "interpreter": null, "cwd": "...", "env": {...}, "cron_restart": null, "autorestart": true, "max_memory_restart": null}], "ngrok": {"name": "lou-ka-ngrok", "url": "www.lou-ka.com", "port": 8095} | null, "launchd": [{"label": "...", "program_arguments": [...], "working_directory": "...", "env": {...}, "keep_alive": true}], "env_overrides": {".env": {"DATABASE_URL": "postgresql://...@{{IP:M2M32}}:5432/x"}}, # réécritures de fichiers .env "hooks": {"post_sync": ["bash ..."], "post_start": []}, "ka_repo": true # inscrire dir dans ~/.ka-pousseur-repos du nœud hôte } Gabarits acceptés dans env/args/env_overrides : {{HOME}}, {{NODE}}, {{LAN_IP}}, {{IP:}}. """ import glob import json import os import re from . import config DEFAULTS = { "label": None, "domain": None, "port": None, "health_path": "/", "extra_paths": [], "sync_excludes": [], "requires": {"runtimes": ["pm2"], "ram_gb": 1, "ports": []}, "ram_mb_observed": 512, "size_mb": 0, "placement": {"pin": None, "prefer": None, "avoid": [], "reason": ""}, "processes": [], "ngrok": None, "launchd": [], "env_overrides": {}, "hooks": {"post_sync": [], "post_start": []}, "ka_repo": False, } def path(app): return os.path.join(config.APPS_DIR, app + ".json") def load(app): p = path(app) if not os.path.exists(p): raise SystemExit("manifeste introuvable : %s" % p) m = json.load(open(p)) for k, v in DEFAULTS.items(): m.setdefault(k, json.loads(json.dumps(v))) m["requires"].setdefault("runtimes", ["pm2"]) m["requires"].setdefault("ram_gb", 1) m["requires"].setdefault("ports", [m["port"]] if m.get("port") else []) return m def save(m): json.dump(m, open(path(m["app"]), "w"), indent=2, ensure_ascii=False) os.chmod(path(m["app"]), 0o600) def all_apps(): return sorted(os.path.basename(p)[:-5] for p in glob.glob(os.path.join(config.APPS_DIR, "*.json"))) def load_all(): return {a: load(a) for a in all_apps()} def render(value, ctx): """Remplace {{HOME}}, {{NODE}}, {{LAN_IP}}, {{IP:alias}} dans une chaîne / liste / dict.""" if isinstance(value, str): def sub(mo): key = mo.group(1) if key.startswith("IP:"): return ctx.get("ips", {}).get(key[3:], mo.group(0)) return str(ctx.get(key, mo.group(0))) return re.sub(r"\{\{([A-Za-z0-9_:@.-]+)\}\}", sub, value) if isinstance(value, list): return [render(v, ctx) for v in value] if isinstance(value, dict): return {k: render(v, ctx) for k, v in value.items()} return value def pm2_names(m): names = [p["name"] for p in m["processes"] if p.get("manager", "pm2") == "pm2"] if m.get("ngrok"): names.append(m["ngrok"]["name"]) return names def launchd_labels(m): return [l["label"] for l in m.get("launchd", [])] def detect_requirements(m): """Déduit les runtimes requis à partir des processus (complète requires.runtimes).""" req = set(m["requires"].get("runtimes") or []) req.add("pm2") if m.get("ngrok"): req.add("ngrok") blob = json.dumps(m["processes"]) + json.dumps(m.get("launchd", [])) if "/opt/homebrew/bin/node" in blob or "next" in blob or "npm" in blob or ".mjs" in blob or ".js" in blob: req.add("node") if "pnpm" in blob: req.add("pnpm") vp = m.get("venv_python") or "" for ver in ("3.14", "3.13", "3.12"): if "python@%s" % ver in vp or "/%s/" % ver in vp or "python%s" % ver in vp: req.add("python@%s" % ver) if "uv/python/cpython-3.12" in vp: req.discard("python@3.12") req.add("uv-python@3.12") m["requires"]["runtimes"] = sorted(req) return m