Update speiseplan_core/missing.py

speiseplan_core/missing.py

@@ -1,9 +1,20 @@
 from __future__ import annotations
+
 from dataclasses import dataclass, asdict
-from typing import Any
+from pathlib import Path
+from typing import Any, Optional
+
 import pandas as pd
 import numpy as np
 
+# ✅ Pipeline imports (no UI Space call) — this file lives in speiseplan_core
+from .pipeline import (
+    fetch_speiseplan_pdf_cached,
+    fetch_speiseplan_pdf_by_week_cached,
+    get_text_any,
+    process_text,
+)
+
 
 @dataclass
 class MissingItem:
@@ -89,4 +100,46 @@ def build_missing_report(
         "uncertain_match_count": int(uncertain_mask.sum()),
         "not_confirmed_count": int(not_confirmed_mask.sum()),
         "items": [asdict(x) for x in items],
+    }
+
+
+def missing_pipeline_api(
+    tenant_id: Optional[str] = None,
+    mode: str = "latest",  # latest | this_week
+    week_start_date: Optional[str] = None,
+    match_threshold: Optional[int] = None,
+    limit: int = 50,
+) -> dict[str, Any]:
+    """
+    ✅ Missing-API Wrapper:
+    - lädt Speiseplan (latest/this_week oder explizit week_start_date)
+    - extrahiert Text
+    - parsed zu DF via process_text
+    - erzeugt Missing-Report via build_missing_report
+    """
+    if week_start_date:
+        pdf_bytes, meta = fetch_speiseplan_pdf_by_week_cached(week_start_date, tenant_id)
+    else:
+        pdf_bytes, meta = fetch_speiseplan_pdf_cached(mode=mode, tenant_id=tenant_id)
+
+    tmp = Path("/tmp/speiseplan_missing_input.pdf")
+    tmp.write_bytes(pdf_bytes)
+
+    text = get_text_any(tmp)
+    default_date = str(meta.get("week_start_date") or "")
+    df = process_text(text, default_date=default_date)
+
+    report = build_missing_report(
+        df_results=df,
+        match_threshold=int(match_threshold or 92),
+        limit=int(limit or 50),
+    )
+
+    return {
+        "ok": True,
+        "tenant_id": tenant_id or "",
+        "mode": (mode or "latest"),
+        "week_start_date": meta.get("week_start_date"),
+        "meta": meta,
+        **report,
     }