Upload main.py

main.py

@@ -7,12 +7,15 @@ from datetime import datetime
 
 app = FastAPI()
 
-# --- SETUP ---
+# --- 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"
 KNOWLEDGE_CACHE = []
 
-# --- DB VERBINDUNG ---
+# --- FIREBASE VERBINDUNG ---
 db = None
 try:
     key = os.environ.get("FIREBASE_KEY")
@@ -42,7 +45,7 @@ def reload_knowledge():
 async def startup():
     reload_knowledge()
 
-# --- HELPER ---
+# --- HELPER: WORTSTÄMME ---
 def get_stem(word):
     w = word.lower().strip()
     for end in ["ern", "en", "er", "es", "st", "te", "e", "s", "t"]:
@@ -50,7 +53,9 @@ def get_stem(word):
     return w
 
 # ==========================================
-# 1. START DES ANRUFS (Verfügbarkeit)
+# 1. DER TÜRSTEHER (Phone Number URL)
+# Endpunkt: /vapi-incoming
+# Aufgabe: Prüft Regeln & weist den Agenten zu
 # ==========================================
 @app.post("/vapi-incoming")
 async def vapi_incoming(request: Request):
@@ -59,42 +64,48 @@ async def vapi_incoming(request: Request):
         msg = data.get("message", {})
         msg_type = msg.get("type")
         
-        # LOGGEN WAS PASSIERT
-        print(f"⚡ INCOMING EVENT: {msg_type}")
+        # Loggen für Debugging
+        print(f"⚡ PHONE EVENT: {msg_type}")
 
-        # Nur hier reagieren wir mit Regeln!
         if msg_type == "assistant-request":
-            print("📞 ANRUF STARTET - Prüfe Regeln...")
+            print("📞 ANRUF GEHT EIN! Entscheide Routing & Kontext...")
+            
             today = datetime.now().strftime("%Y-%m-%d")
-            context = ""
+            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()
-                    # Prüfen ob Datum passt
+                    # Datum Check
                     if rd.get('start_date') <= today <= rd.get('end_date'):
-                        print(f"🛑 REGEL AKTIV: {rd.get('name')}")
-                        context = f"ACHTUNG - BESONDERE SITUATION: {rd.get('instruction_text')}"
+                        print(f"🛑 SONDERREGEL AKTIV: {rd.get('name')}")
+                        context_text = f"WICHTIGE VERFÜGBARKEITS-INFO: {rd.get('instruction_text')}"
                         break
             
-            if not context: print("✅ Keine Regeln für heute.")
+            if not context_text: 
+                print("✅ Keine Regeln (Normalbetrieb).")
 
+            # 2. Antwort an Vapi: "Nimm Alex + Hier ist der Kontext"
             return {
-                "assistant": {
+                "assistantId": ALEX_ID,
+                "assistantOverrides": {
                     "variableValues": {
-                        "seasonal_context": context
+                        "seasonal_context": context_text
                     }
                 }
             }
             
     except Exception as e:
-        print(f"❌ ERROR START: {e}")
+        print(f"❌ ERROR ROUTING: {e}")
     
     return {"status": "ok"}
 
 # ==========================================
-# 2. WÄHREND DES ANRUFS (Suche)
+# 2. DAS GEHIRN (Tool URL)
+# Endpunkt: /search
+# Aufgabe: Sucht Preise und Infos während des Gesprächs
 # ==========================================
 @app.post("/search")
 async def search(request: Request):
@@ -102,7 +113,7 @@ async def search(request: Request):
         data = await request.json()
         query = ""
         
-        # Parsing
+        # Robustes Parsing (egal wie Vapi die Frage verpackt)
         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"]
@@ -112,17 +123,14 @@ async def search(request: Request):
         print(f"🔎 FRAGE: '{query}'")
         if not query: return {"result": "Akustik-Fehler."}
 
-        # --- INTELLIGENTE FILTERUNG ---
-        # Wörter, die wir IGNORIEREN, damit er nicht bei "Capaneo" jedes Dokument findet
+        # STOP-WÖRTER (Damit er nicht bei 'Udo' halluziniert)
         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]
         
-        print(f"   ⚙️ Relevante Suchwörter: {relevant_words}")
-        
         if not relevant_words:
-            print("⚠️ Keine relevanten Keywords gefunden (nur Stopwörter).")
+            print("⚠️ Nur Stopwörter erkannt - Breche ab.")
             return {"result": "Dazu habe ich keine spezifischen Informationen."}
 
         best_doc = None
@@ -133,12 +141,12 @@ async def search(request: Request):
             txt = (doc.get("question", "") + " " + doc.get("answer", "")).lower()
             kws = [k.lower() for k in doc.get("keywords", [])]
             
-            # A) Keywords (Stark)
+            # 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
             
-            # B) Text (Mittel)
+            # Wenig Punkte für Fließtext
             for w in relevant_words:
                 if w in txt: score += 5
 
@@ -146,14 +154,21 @@ async def search(request: Request):
                 best_score = score
                 best_doc = doc
 
-        # Schwelle auf 15 setzen
+        # 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")}
         else:
-            print(f"⚠️ KEIN GUTER TREFFER (Max: {best_score})")
+            print(f"⚠️ KEIN TREFFER (Max: {best_score})")
             return {"result": "Dazu habe ich leider keine Informationen."}
 
     except Exception as e:
         print(f"❌ SEARCH ERROR: {e}")
-        return {"result": "Fehler."}
+        return {"result": "Fehler."}
+
+# ==========================================
+# 3. KOSMETIK (Damit '404' im Log verschwindet)
+# ==========================================
+@app.get("/")
+async def root():
+    return {"status": "Udo API Online", "endpoints": ["/vapi-incoming", "/search"]}