Create app.py

app.py

@@ -0,0 +1,52 @@
+import os
+import tempfile
+import shutil
+from typing import Optional
+
+from fastapi import FastAPI, Request, UploadFile, File, Form
+from fastapi.responses import JSONResponse, HTMLResponse
+from fastapi.staticfiles import StaticFiles
+from fastapi.templating import Jinja2Templates
+from fastapi.encoders import jsonable_encoder
+
+# Assumes pipeline_with_agents.py (with process_file and to_json_serializable) is in same folder
+from pipeline_with_agents import process_file, to_json_serializable
+
+app = FastAPI()
+
+# Templates folder named "templates"
+templates = Jinja2Templates(directory="templates")
+
+# Ensure tmp dir exists and is writable (Hugging Face requires writable /tmp)
+TMP_DIR = os.environ.get("TMPDIR", "/tmp")
+os.makedirs(TMP_DIR, exist_ok=True)
+
+@app.get("/", response_class=HTMLResponse)
+async def index(request: Request):
+    return templates.TemplateResponse("index.html", {"request": request})
+
+@app.post("/analyze")
+async def analyze(file: UploadFile = File(...), sheet: Optional[str] = Form(None)):
+    # Save to a tmp file under TMP_DIR
+    suffix = os.path.splitext(file.filename)[1] or ".xlsx"
+    with tempfile.NamedTemporaryFile(dir=TMP_DIR, delete=False, suffix=suffix) as tmp:
+        tmp_path = tmp.name
+        content = await file.read()
+        tmp.write(content)
+
+    try:
+        # Call the user's pipeline. This returns a serializable python dict.
+        result = process_file(tmp_path, sheet=sheet, model=os.environ.get("GEMINI_MODEL", "gemini-2.5-flash-lite"))
+        # Convert non-json-native numpy/pandas types
+        json_safe = jsonable_encoder(result, custom_encoder={})
+        return JSONResponse(content=json_safe)
+    finally:
+        try:
+            os.remove(tmp_path)
+        except Exception:
+            pass
+
+# Small health endpoint
+@app.get("/healthz")
+async def health():
+    return {"status": "ok"}