Upload main.py

main.py

@@ -8,11 +8,9 @@ from datetime import datetime
 app = FastAPI()
 
 # --- KONFIGURATION ---
-# Trage hier die ID von Alex aus deinem Vapi Dashboard ein!
-ALEX_ID = "e3e86ece-e6d3-459c-87bc-e9fb9a0f0aa0"
-
 COLLECTION_KNOWLEDGE = "knowledge_base"
 COLLECTION_RULES = "availability_rules"
+COLLECTION_INBOX = "inbox"
 KNOWLEDGE_CACHE = []
 
 # --- FIREBASE VERBINDUNG ---
@@ -45,7 +43,6 @@ def reload_knowledge():
 async def startup():
     reload_knowledge()
 
-# --- HELPER: WORTSTÄMME ---
 def get_stem(word):
     w = word.lower().strip()
     for end in ["ern", "en", "er", "es", "st", "te", "e", "s", "t"]:
@@ -53,59 +50,46 @@ def get_stem(word):
     return w
 
 # ==========================================
-# 1. DER TÜRSTEHER (Phone Number URL)
-# Endpunkt: /vapi-incoming
-# Aufgabe: Prüft Regeln & weist den Agenten zu
+# NEU: TOOL FÜR VERFÜGBARKEIT
+# Endpunkt: /check_availability
 # ==========================================
-@app.post("/vapi-incoming")
-async def vapi_incoming(request: Request):
+@app.post("/check_availability")
+async def check_availability(request: Request):
+    print("🚦 TOOL CALL: checkAvailability")
+    
+    today = datetime.now().strftime("%Y-%m-%d")
+    status = "available"
+    message = "Normaler Betrieb. Nimm Anrufe entgegen und vereinbare Termine."
+    
     try:
-        data = await request.json()
-        msg = data.get("message", {})
-        msg_type = msg.get("type")
-        
-        # Loggen für Debugging
-        print(f"⚡ PHONE EVENT: {msg_type}")
-
-        if msg_type == "assistant-request":
-            print("📞 ANRUF GEHT EIN! Entscheide Routing & Kontext...")
-            
-            today = datetime.now().strftime("%Y-%m-%d")
-            context_text = ""
-            
-            # 1. Datenbank prüfen (Ist heute Schulung?)
-            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"🛑 SONDERREGEL AKTIV: {rd.get('name')}")
-                        context_text = f"WICHTIGE VERFÜGBARKEITS-INFO: {rd.get('instruction_text')}"
-                        break
-            
-            if not context_text: 
-                print("✅ Keine Regeln (Normalbetrieb).")
-
-            # 2. Antwort an Vapi: "Nimm Alex + Hier ist der Kontext"
-            return {
-                "assistantId": ALEX_ID,
-                "assistantOverrides": {
-                    "variableValues": {
-                        "seasonal_context": context_text
-                    }
-                }
-            }
-            
+        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')}"
+                    break
     except Exception as e:
-        print(f"❌ ERROR ROUTING: {e}")
+        print(f"❌ ERROR CHECK: {e}")
+        return {"status": "error", "message": "Fehler beim Datenbank-Check. Gehe von Normalbetrieb aus."}
+
+    print(f"👉 RESULTAT: {status} | {message}")
     
-    return {"status": "ok"}
+    # Rückgabe genau wie vom LLM benötigt
+    return {
+        "result": json.dumps({
+            "status": status,
+            "instruction": message
+        })
+    }
 
 # ==========================================
-# 2. DAS GEHIRN (Tool URL)
+# TOOL: SUCHE / WISSEN
 # Endpunkt: /search
-# Aufgabe: Sucht Preise und Infos während des Gesprächs
 # ==========================================
 @app.post("/search")
 async def search(request: Request):
@@ -113,7 +97,7 @@ async def search(request: Request):
         data = await request.json()
         query = ""
         
-        # Robustes Parsing (egal wie Vapi die Frage verpackt)
+        # 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"]
@@ -123,14 +107,12 @@ async def search(request: Request):
         print(f"🔎 FRAGE: '{query}'")
         if not query: return {"result": "Akustik-Fehler."}
 
-        # STOP-WÖRTER (Damit er nicht bei 'Udo' halluziniert)
+        # 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:
-            print("⚠️ Nur Stopwörter erkannt - Breche ab.")
             return {"result": "Dazu habe ich keine spezifischen Informationen."}
 
         best_doc = None
@@ -141,12 +123,9 @@ async def search(request: Request):
             txt = (doc.get("question", "") + " " + doc.get("answer", "")).lower()
             kws = [k.lower() for k in doc.get("keywords", [])]
             
-            # Hohe Punkte für Keywords (Preis, Kosten, Starter)
             for k in kws:
                 k_stem = get_stem(k)
                 if k_stem in relevant_words: score += 30
-            
-            # Wenig Punkte für Fließtext
             for w in relevant_words:
                 if w in txt: score += 5
 
@@ -154,7 +133,6 @@ async def search(request: Request):
                 best_score = score
                 best_doc = doc
 
-        # Schwelle: Mindestens 15 Punkte für einen Treffer
         if best_doc and best_score >= 15:
             print(f"🏆 TREFFER ({best_score}): {best_doc.get('question')}")
             return {"result": best_doc.get("answer")}
@@ -166,9 +144,6 @@ async def search(request: Request):
         print(f"❌ SEARCH ERROR: {e}")
         return {"result": "Fehler."}
 
-# ==========================================
-# 3. KOSMETIK (Damit '404' im Log verschwindet)
-# ==========================================
 @app.get("/")
-async def root():
-    return {"status": "Udo API Online", "endpoints": ["/vapi-incoming", "/search"]}
+def home():
+    return {"status": "Online", "endpoints": ["/check_availability", "/search"]}