regenerate function

app.py

@@ -36,6 +36,10 @@ correction_store = CorrectionStore()
 correction_svc = CorrectionService(kb=pipeline.kb, store=correction_store)
 correction_svc.replay_corrections_on_startup()
 
+class RegenerateRequest(BaseModel):
+    session_id: str
+    features: dict
+
 class TranslateRequest(BaseModel):
     report: str
 
@@ -137,6 +141,33 @@ async def get_correction(correction_id: str):
         raise HTTPException(status_code=404, detail="Correction not found")
     return record
 
+class RegenerateRequest(BaseModel):
+    features: dict          # /predict'ten dönen features (zorunlu)
+    session_id: str = ""    # audit için opsiyonel
+
+@app.post("/regenerate-report")
+async def regenerate_report(body: RegenerateRequest):
+    from src.query_builder import build_all_queries
+    from src.report_generator import build_report_prompt
+
+    features = body.features
+    queries = build_all_queries(features) if features.get("stone_detected") else []
+
+    largest_mm = features.get("largest_stone_mm")
+    size_filter = pipeline._stone_size_range(largest_mm) if largest_mm else None
+
+    retrieved = pipeline.retrieve_context(queries, size_filter=size_filter) if queries else []
+
+    system_prompt, user_prompt = build_report_prompt(features, retrieved)
+    report = llm.generate(system_prompt=system_prompt, user_prompt=user_prompt, temperature=0.3)
+
+    return {
+        "session_id": body.session_id,
+        "report": report,
+        "retrieved_context": retrieved,
+    }
+
+
 @app.get("/admin/export-correction-store")
 async def export_correction_store():
     """HF Spaces'taki güncel correction_store.db'yi indir."""