Upload main.py

main.py

@@ -13,7 +13,7 @@ COLLECTION_RULES = "availability_rules"
 COLLECTION_INBOX = "inbox"
 KNOWLEDGE_CACHE = []
 
-# --- FIREBASE START ---
+# --- FIREBASE VERBINDUNG ---
 db = None
 try:
     key = os.environ.get("FIREBASE_KEY")
@@ -31,13 +31,15 @@ except Exception as e:
 # --- CACHE LADEN ---
 def reload_knowledge():
     global KNOWLEDGE_CACHE
-    if not db: return
+    if not db: return 0
     try:
         docs = db.collection(COLLECTION_KNOWLEDGE).stream()
         KNOWLEDGE_CACHE = [d.to_dict() for d in docs]
         print(f"📚 {len(KNOWLEDGE_CACHE)} Einträge geladen.")
+        return len(KNOWLEDGE_CACHE)
     except Exception as e:
         print(f"❌ Cache Fehler: {e}")
+        return 0
 
 @app.on_event("startup")
 async def startup():
@@ -50,7 +52,24 @@ def get_stem(word):
     return w
 
 # ==========================================
-# 1. TOOL: VERFÜGBARKEIT PRÜFEN
+# 1. HAUPTSEITE & MONITORING (Repariert!)
+# ==========================================
+@app.get("/")
+def home():
+    # Hier ist die Info zurück!
+    return {
+        "status": "Online", 
+        "docs_loaded": len(KNOWLEDGE_CACHE),
+        "endpoints": ["/check_availability", "/search", "/refresh_knowledge"]
+    }
+
+@app.get("/refresh_knowledge")
+def refresh():
+    count = reload_knowledge()
+    return {"status": "Cache aktualisiert", "docs_loaded": count}
+
+# ==========================================
+# 2. TOOL: VERFÜGBARKEIT PRÜFEN
 # ==========================================
 @app.post("/check_availability")
 async def check_availability(request: Request):
@@ -58,7 +77,6 @@ async def check_availability(request: Request):
     
     today = datetime.now().strftime("%Y-%m-%d")
     status = "available"
-    # Standard-Nachricht
     message = "Normaler Betrieb."
     
     try:
@@ -69,7 +87,6 @@ async def check_availability(request: Request):
                 if rd.get('start_date') <= today <= rd.get('end_date'):
                     print(f"🛑 REGEL GEFUNDEN: {rd.get('name')}")
                     status = "unavailable"
-                    # Hier bauen wir den Satz für den Agenten
                     message = rd.get('instruction_text')
                     break
     except Exception as e:
@@ -78,7 +95,6 @@ async def check_availability(request: Request):
 
     print(f"👉 RESULTAT: {status} | {message}")
     
-    # Rückgabe als JSON-String für das LLM
     return {
         "result": json.dumps({
             "status": status,
@@ -87,7 +103,7 @@ async def check_availability(request: Request):
     }
 
 # ==========================================
-# 2. TOOL: WISSENSSUCHE (Preise etc.)
+# 3. TOOL: WISSENSSUCHE
 # ==========================================
 @app.post("/search")
 async def search(request: Request):
@@ -140,14 +156,8 @@ async def search(request: Request):
         return {"result": "Systemfehler."}
 
 # ==========================================
-# 3. DUMMY ENDPUNKT (MÜLLSCHLUCKER)
-# Fängt die 404 Fehler ab!
+# 4. MÜLLSCHLUCKER (Gegen 404 Fehler)
 # ==========================================
 @app.post("/vapi-incoming")
 async def dummy_incoming(request: Request):
-    # Wir sagen Vapi einfach "Alles OK", damit er Ruhe gibt
-    return {"status": "ok"}
-
-@app.get("/")
-def home():
-    return {"status": "Online"}
+    return {"status": "ok"}