Create app.py

app.py

@@ -0,0 +1,66 @@
+import os, json, time, hashlib
+from fastapi import FastAPI, Request, HTTPException
+import requests
+
+WAKEUP_URL = os.getenv("WAKEUP_URL", "http://163.245.192.149:8080/wakeup/")
+TIMEOUT = int(os.getenv("RELAY_TIMEOUT", "30"))
+
+app = FastAPI()
+
+def norm(v):
+    if v is None:
+        return ""
+    if isinstance(v, str):
+        s = v.strip()
+        return "" if s.lower() in ("null", "none") else s
+    return v
+
+def compute_fingerprint(payload: dict) -> str:
+    """
+    MVP fingerprint: stable hash from fields that should represent the same upload.
+    Upgrade later to sha256(file-bytes) when you have a download URL.
+    """
+    parts = {
+        "rid": norm(payload.get("rid")),
+        "file_type": norm(payload.get("file_type")),
+        "case_vendor_rid": norm(payload.get("case_vendor_rid")),
+        "date_modified": norm(payload.get("date_modified")),
+    }
+    raw = json.dumps(parts, sort_keys=True, separators=(",", ":")).encode("utf-8")
+    return hashlib.sha256(raw).hexdigest()
+
+# ultra-light “db” for HF: in-memory set (fine for relay testing)
+SEEN = set()
+
+@app.post("/webhook")
+async def webhook(req: Request):
+    payload = await req.json()
+
+    # 1) processing state default
+    state = norm(payload.get("sa_processing_state"))
+    if not state:
+        payload["sa_processing_state"] = "new"  # null -> new  [oai_citation:3‡API Integration Setup Guide_otter.ai.txt](sediment://file_0000000079e8722fb44223541f5b71cb)
+
+    # 2) fingerprint + dedupe
+    fp = norm(payload.get("sa_fingerprint"))
+    if not fp:
+        fp = compute_fingerprint(payload)
+        payload["sa_fingerprint"] = fp
+
+    if fp in SEEN:
+        payload["sa_processing_state"] = "duplicate"
+        return {"ok": True, "duplicate": True, "fingerprint": fp}
+
+    SEEN.add(fp)
+
+    # 3) forward/relay
+    try:
+        r = requests.post(WAKEUP_URL, json=payload, timeout=TIMEOUT)
+        return {
+            "ok": True,
+            "forward_status": r.status_code,
+            "forward_body": r.text[:2000],
+            "fingerprint": fp,
+        }
+    except requests.RequestException as e:
+        raise HTTPException(status_code=502, detail=f"relay_failed: {e}")