Upload main.py

main.py

@@ -13,7 +13,7 @@ COLLECTION_RULES = "availability_rules"
 COLLECTION_INBOX = "inbox"
 KNOWLEDGE_CACHE = []
 
-# --- FIREBASE VERBINDUNG ---
+# --- FIREBASE START ---
 db = None
 try:
     key = os.environ.get("FIREBASE_KEY")
@@ -50,8 +50,7 @@ def get_stem(word):
     return w
 
 # ==========================================
-# NEU: TOOL FÜR VERFÜGBARKEIT
-# Endpunkt: /check_availability
+# 1. TOOL: VERFÜGBARKEIT PRÜFEN
 # ==========================================
 @app.post("/check_availability")
 async def check_availability(request: Request):
@@ -59,27 +58,27 @@ async def check_availability(request: Request):
     
     today = datetime.now().strftime("%Y-%m-%d")
     status = "available"
-    message = "Normaler Betrieb. Nimm Anrufe entgegen und vereinbare Termine."
+    # Standard-Nachricht
+    message = "Normaler Betrieb."
     
     try:
         if db:
             rules = db.collection(COLLECTION_RULES).where("active", "==", True).stream()
             for r in rules:
                 rd = r.to_dict()
-                # Datum Check
                 if rd.get('start_date') <= today <= rd.get('end_date'):
                     print(f"🛑 REGEL GEFUNDEN: {rd.get('name')}")
                     status = "unavailable"
-                    # Wir bauen die Instruktion direkt in die Message
-                    message = f"ACHTUNG SONDERREGEL: {rd.get('instruction_text')}"
+                    # Hier bauen wir den Satz für den Agenten
+                    message = rd.get('instruction_text')
                     break
     except Exception as e:
         print(f"❌ ERROR CHECK: {e}")
-        return {"status": "error", "message": "Fehler beim Datenbank-Check. Gehe von Normalbetrieb aus."}
+        return {"result": json.dumps({"status": "available", "instruction": "Fehler ignoriert, normal arbeiten."})}
 
     print(f"👉 RESULTAT: {status} | {message}")
     
-    # Rückgabe genau wie vom LLM benötigt
+    # Rückgabe als JSON-String für das LLM
     return {
         "result": json.dumps({
             "status": status,
@@ -88,8 +87,7 @@ async def check_availability(request: Request):
     }
 
 # ==========================================
-# TOOL: SUCHE / WISSEN
-# Endpunkt: /search
+# 2. TOOL: WISSENSSUCHE (Preise etc.)
 # ==========================================
 @app.post("/search")
 async def search(request: Request):
@@ -97,7 +95,6 @@ async def search(request: Request):
         data = await request.json()
         query = ""
         
-        # Parsing Logic
         if "search_query" in data: query = data["search_query"]
         elif "message" in data and "toolCalls" in data["message"]:
             args = data["message"]["toolCalls"][0]["function"]["arguments"]
@@ -107,13 +104,12 @@ async def search(request: Request):
         print(f"🔎 FRAGE: '{query}'")
         if not query: return {"result": "Akustik-Fehler."}
 
-        # Stop-Wörter
         STOP_WORDS = ["capaneo", "udo", "schober", "firma", "gmbh", "hallo", "demo"]
         q_words = [get_stem(w) for w in query.lower().split() if len(w)>2]
         relevant_words = [w for w in q_words if w not in STOP_WORDS]
         
         if not relevant_words:
-            return {"result": "Dazu habe ich keine spezifischen Informationen."}
+            return {"result": "Dazu habe ich keine Informationen."}
 
         best_doc = None
         best_score = 0
@@ -137,13 +133,21 @@ async def search(request: Request):
             print(f"🏆 TREFFER ({best_score}): {best_doc.get('question')}")
             return {"result": best_doc.get("answer")}
         else:
-            print(f"⚠️ KEIN TREFFER (Max: {best_score})")
-            return {"result": "Dazu habe ich leider keine Informationen."}
+            return {"result": "Dazu habe ich keine Informationen."}
 
     except Exception as e:
         print(f"❌ SEARCH ERROR: {e}")
-        return {"result": "Fehler."}
+        return {"result": "Systemfehler."}
+
+# ==========================================
+# 3. DUMMY ENDPUNKT (MÜLLSCHLUCKER)
+# Fängt die 404 Fehler ab!
+# ==========================================
+@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", "endpoints": ["/check_availability", "/search"]}
+    return {"status": "Online"}