Update app.py

app.py

@@ -175,6 +175,95 @@ async def log_commitment(data: CommitmentIn):
 # HEALTH
 # ─────────────────────────────────────────────
 
+
+# ─────────────────────────────────────────────
+# INTERN MANAGEMENT — GET / UPDATE / DELETE
+# ─────────────────────────────────────────────
+
+class InternUpdate(BaseModel):
+    name: str | None = None
+    stage: str | None = None
+    department: str | None = None
+    channel_id: str | None = None
+    ft_slack_id: str | None = None
+    hr_slack_id: str | None = None
+    week0_start_date: str | None = None
+    status: str | None = None
+    cohort_id: str | None = None
+
+
+@app.get("/interns", summary="List all interns — filter by department")
+async def get_interns(department: str = None):
+    """
+    Returns all active interns.
+    Optional query param: ?department=ai
+    Example: /interns?department=ai
+    """
+    try:
+        candidates = sheets.get_active_candidates()
+        if department:
+            candidates = [
+                c for c in candidates
+                if c.get("department", "").lower() == department.lower()
+            ]
+        return JSONResponse({"ok": True, "count": len(candidates), "interns": candidates})
+    except Exception as e:
+        return JSONResponse({"error": str(e)}, status_code=500)
+
+
+@app.get("/interns/{candidate_id}", summary="Get a single intern by candidate ID")
+async def get_intern(candidate_id: str):
+    try:
+        candidate = sheets.get_candidate_by_id(candidate_id)
+        if not candidate:
+            return JSONResponse({"error": "Intern not found"}, status_code=404)
+        return JSONResponse({"ok": True, "intern": candidate})
+    except Exception as e:
+        return JSONResponse({"error": str(e)}, status_code=500)
+
+
+@app.patch("/interns/{candidate_id}", summary="Update intern fields")
+async def update_intern(candidate_id: str, data: InternUpdate):
+    """
+    Update one or more fields of an intern.
+    Only pass the fields you want to change.
+    """
+    try:
+        candidate = sheets.get_candidate_by_id(candidate_id)
+        if not candidate:
+            return JSONResponse({"error": "Intern not found"}, status_code=404)
+
+        updates = data.dict(exclude_none=True)
+        if not updates:
+            return JSONResponse({"error": "No fields to update"}, status_code=400)
+
+        for field, value in updates.items():
+            sheets.update_candidate_field(candidate_id, field, value)
+
+        return JSONResponse({"ok": True, "updated": updates})
+    except Exception as e:
+        return JSONResponse({"error": str(e)}, status_code=500)
+
+
+@app.delete("/interns/{candidate_id}", summary="Remove an intern from the pipeline")
+async def delete_intern(candidate_id: str):
+    """
+    Marks the intern as eliminated and inactive.
+    Does not delete the row — preserves audit trail.
+    """
+    try:
+        candidate = sheets.get_candidate_by_id(candidate_id)
+        if not candidate:
+            return JSONResponse({"error": "Intern not found"}, status_code=404)
+
+        sheets.update_candidate_field(candidate_id, "status", "eliminated")
+        return JSONResponse({
+            "ok": True,
+            "message": f"{candidate.get('name')} removed from pipeline. Row preserved for audit."
+        })
+    except Exception as e:
+        return JSONResponse({"error": str(e)}, status_code=500)
+
 @app.get("/health", summary="Health check")
 async def health():
     return JSONResponse({"status": "ok"})