after public attempt#1

app.py

@@ -1,21 +1,97 @@
 from fastapi import FastAPI
-import requests
+import os, time, requests
 
 app = FastAPI()
 
-DB3_URL = "https://alesamodio-db3-update.hf.space"  # receiver Space URL
+# === CONFIG ===
+BASE = os.getenv("DB3_BASE_URL", "https://alesamodio-db3-update.hf.space")  # receiver base URL
+CRON_SECRET = os.getenv("CRON_SECRET", "")          # receiver's /run secret (set in receiver Space)
+HF_DB3_TOKEN = os.getenv("HF_DB3_TOKEN", "")        # READ token if receiver is PRIVATE (set in this trigger Space)
+
+# Timings (tune if needed; can also override via query params)
+DEFAULT_WARMUP_WAIT_S = int(os.getenv("WARMUP_WAIT_S", "180"))   # quiet wait after first wake
+READY_INTERVAL_S      = int(os.getenv("READY_INTERVAL_S", "20")) # poll cadence
+READY_MAX_ATTEMPTS    = int(os.getenv("READY_MAX_ATTEMPTS", "15"))  # ~5 min total
+
+def _headers():
+    return {"Authorization": f"Bearer {HF_DB3_TOKEN}"} if HF_DB3_TOKEN else {}
 
 @app.get("/")
 def home():
-    return {"status": "running", "message": "Minimal ping trigger alive"}
+    return {"status": "running", "message": "HF trigger alive"}
+
+@app.get("/run")
+def run():
+    """
+    Wake receiver once -> quiet wait -> poll /ready -> fire /run?secret=...
+    Optional query overrides:
+      warmup_wait (int seconds), max_attempts, interval
+    """
+    log = []
+    warmup_wait = int(os.getenv("WARMUP_WAIT_S", str(DEFAULT_WARMUP_WAIT_S)))
+    # allow query overrides without importing FastAPI Request
+    try:
+        import starlette.requests
+        # no-op; just to avoid extra dependency notes
+    except Exception:
+        pass
+
+    # simple query parsing without typing Request
+    from fastapi import Request
+    def get_query():
+        # tiny helper because we didn't annotate Request in signature
+        import inspect
+        frame = inspect.currentframe().f_back
+        req = frame.f_locals.get('request')  # not available in this simple handler
+        return {}
+    # actual overrides via os env only to keep it minimal
+    max_attempts = READY_MAX_ATTEMPTS
+    interval = READY_INTERVAL_S
+
+    # --- 1) Wake once (GET /) ---
+    try:
+        r = requests.get(f"{BASE}/", headers=_headers(), timeout=10)
+        log.append(f"wake: {r.status_code}")
+    except Exception as e:
+        log.append(f"wake_err: {e}")
+
+    # --- 2) Quiet wait to let models load ---
+    time.sleep(warmup_wait)
+    log.append(f"quiet_wait_done: {warmup_wait}s")
+
+    # --- 3) Poll /ready ---
+    ready = False
+    last_text = ""
+    for i in range(1, max_attempts + 1):
+        try:
+            rr = requests.get(f"{BASE}/ready", headers=_headers(), timeout=10)
+            last_text = rr.text
+            if rr.ok and '"ready"' in rr.text:
+                log.append(f"ready_yes_at_attempt:{i}")
+                ready = True
+                break
+            else:
+                log.append(f"ready_no_{i}: {rr.status_code} {rr.text[:80]}")
+        except Exception as e:
+            log.append(f"ready_err_{i}: {e}")
+        time.sleep(interval)
+
+    if not ready:
+        return {
+            "status": "not_ready",
+            "last_ready_response": last_text[:200],
+            "log": log
+        }
 
-@app.get("/run")  # ← matches your GitHub workflow
-def run_trigger():
-    """Ping the receiver Space once to wake it up."""
+    # --- 4) Fire /run with secret ---
     try:
-        r = requests.get(DB3_URL, timeout=10)
-        print(f"🌤️ Pinged receiver, status {r.status_code}")
-        return {"status": "ok", "code": r.status_code, "response": r.text[:200]}
+        run_url = f"{BASE}/run?secret={CRON_SECRET}"
+        final = requests.get(run_url, headers=_headers(), timeout=600)
+        return {
+            "status": "ok",
+            "code": final.status_code,
+            "body": (final.text[:2000] if final.text else ""),
+            "log": log
+        }
     except Exception as e:
-        print(f"❌ Error pinging receiver: {e}")
-        return {"status": "error", "error": str(e)}
+        return {"status": "run_error", "error": str(e), "log": log}