Spaces:

martinbrahm
/

Call_Agent_API

Paused

App Files Files Community

martinbrahm commited on Dec 15, 2025

Commit

1b5d2ca

verified ·

1 Parent(s): 35ea9b7

Upload main.py

Browse files

Files changed (1) hide show

main.py +55 -162

main.py CHANGED Viewed

@@ -1,168 +1,61 @@
-import uvicorn
 from fastapi import FastAPI, Request
-from sqlalchemy import create_engine, Column, Integer, String, DateTime, Text
-from sqlalchemy.orm import DeclarativeBase, sessionmaker
-from datetime import datetime
-# --- 1. DATENBANK SETUP ---
-DATABASE_URL = "sqlite:///./vapi_leads.db"
-engine = create_engine(DATABASE_URL, connect_args={"check_same_thread": False})
-SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
-class Base(DeclarativeBase):
-    pass
-class CallLog(Base):
-    __tablename__ = "vapi_anrufe"
-    id = Column(Integer, primary_key=True, index=True)
-    call_id = Column(String, unique=True)
-    customer_number = Column(String)
-    status = Column(String)
-    transcript = Column(Text, nullable=True)
-    timestamp = Column(DateTime, default=datetime.utcnow)
-Base.metadata.create_all(bind=engine)
-# --- 2. SERVER (Der entscheidende Teil) ---
 app = FastAPI()
-# WICHTIG: Hier definieren wir die Tür "/vapi", an die Vapi klopft!
-@app.post("/vapi")
-async def handle_vapi_event(request: Request):
     try:
         data = await request.json()
-        message = data.get("message", {})
-        msg_type = message.get("type")
-        print(f"📩 Event empfangen: {msg_type}")
-        db = SessionLocal()
-        # Fall 1: Anruf startet (neuer Name: assistant.started)
-        if msg_type == "assistant.started":
-            call_details = message.get("call", {})
-            customer_number = call_details.get("customer", {}).get("number", "Unbekannt")
-            call_id = call_details.get("id")
-            print(f"📞 Neuer Anruf erkannt! ID: {call_id}")
-            # Prüfen ob Anruf schon da ist, sonst anlegen
-            existing = db.query(CallLog).filter(CallLog.call_id == call_id).first()
-            if not existing:
-                new_call = CallLog(call_id=call_id, customer_number=customer_number, status="Live")
-                db.add(new_call)
-                db.commit()
-        # Fall 2: Anruf zu Ende (Transkript speichern)
-        elif msg_type == "end-of-call-report":
-            call_id = message.get("call", {}).get("id")
-            transcript = message.get("transcript", "")
-            summary = message.get("summary", "Keine Zusammenfassung")
-            print(f"✅ Anruf beendet. Transkript empfangen.")
-            existing_call = db.query(CallLog).filter(CallLog.call_id == call_id).first()
-            if existing_call:
-                existing_call.status = "Beendet"
-                existing_call.transcript = transcript
-                db.commit()
-        db.close()
-    except Exception as e:
-        print(f"⚠️ Fehler beim Verarbeiten: {e}")
-    return {"status": "ok"}
-from fastapi.responses import HTMLResponse
-# --- WEBSEITE FÜR TESTER ---
-@app.get("/", response_class=HTMLResponse)
-async def get_web_interface():
-    # HIER DEINE DATEN EINTRAGEN:
-    VAPI_PUBLIC_KEY = "f4f1efff-091c-495f-acab-4669b1cc7cbe" # Beginnt nicht mit 'ey...', ist kürzer
-    ASSISTANT_ID = "4008c58f-556c-44a3-b78d-2b920ea80c66"
-    html_content = f"""
-    <!DOCTYPE html>
-    <html lang="de">
-    <head>
-        <meta charset="UTF-8">
-        <meta name="viewport" content="width=device-width, initial-scale=1.0">
-        <title>Test: Alex Sales Bot</title>
-        <script src="https://cdn.jsdelivr.net/gh/VapiAI/html-script-tag@latest/dist/assets/index.js"></script>
-        <style>
-            body {{
-                font-family: 'Segoe UI', sans-serif;
-                background-color: #f4f4f9;
-                display: flex;
-                flex-direction: column;
-                align_items: center;
-                justify-content: center;
-                height: 100vh;
-                margin: 0;
-                color: #333;
-            }}
-            h1 {{ margin-bottom: 20px; }}
-            p {{ color: #666; margin-bottom: 40px; }}
-            .info {{
-                background: white; padding: 20px; border-radius: 10px;
-                box-shadow: 0 4px 6px rgba(0,0,0,0.1);
-                text-align: center;
-            }}
-        </style>
-    </head>
-    <body>
-        <div class="info">
-            <h1>📞 Teste meinen Sales-Bot</h1>
-            <p>Klicke unten rechts auf den Button, um das Gespräch zu starten.</p>
-            <small>⚠️ Mein Laptop muss an sein, damit es funktioniert.</small>
-        </div>
-        <script>
-          var vapiInstance = null;
-          const assistant = "{ASSISTANT_ID}";
-          const apiKey = "{VAPI_PUBLIC_KEY}";
-          // Konfiguration des Buttons
-          const buttonConfig = {{
-              position: "bottom-right",
-              offset: "40px",
-              width: "50px",
-              height: "50px",
-              idle: {{
-                color: "rgb(93, 254, 202)",
-                type: "pill",
-                title: "Hier klicken zum Sprechen",
-                subtitle: "Kostenloser Testanruf",
-                icon: "https://unpkg.com/lucide-static@0.321.0/icons/phone.svg",
-              }},
-              loading: {{
-                color: "rgb(93, 124, 202)",
-                type: "pill",
-                title: "Verbinde...",
-                subtitle: "Bitte warten",
-                icon: "https://unpkg.com/lucide-static@0.321.0/icons/loader-2.svg",
-              }},
-              active: {{
-                color: "rgb(255, 0, 0)",
-                type: "pill",
-                title: "Anruf läuft...",
-                subtitle: "Klicken zum Auflegen",
-                icon: "https://unpkg.com/lucide-static@0.321.0/icons/phone-off.svg",
-              }}
-          }};
-          (function() {{
-            vapiInstance = window.vapiSDK.run({{
-              apiKey: apiKey,
-              assistant: assistant,
-              config: buttonConfig
-            }});
-          }})();
-        </script>
-    </body>
-    </html>
-    """
-    return html_content
-if __name__ == "__main__":
-    uvicorn.run(app, host="0.0.0.0", port=8000)

 from fastapi import FastAPI, Request
+import json
 app = FastAPI()
+# 1. Startseite (damit du im Browser siehst, dass es läuft)
+@app.get("/")
+def home():
+    return {"status": "Die API läuft und wartet auf Vapi!"}
+# 2. Der Such-Endpunkt für Vapi
+@app.post("/search")
+async def search_knowledge(request: Request):
+    # Wir holen uns die Daten, egal wie Vapi sie verpackt
     try:
         data = await request.json()
+        print(f"📥 DEBUG: {json.dumps(data)}") # Zeigt dir im Log, was ankommt
+    except:
+        return {"result": "Fehler: Kein JSON empfangen."}
+    query_text = ""
+    # Vapi sendet Daten oft tief verschachtelt. Wir suchen die 'query' überall:
+    # Check 1: Einfaches Format (dein Curl Test)
+    if "query" in data and isinstance(data["query"], str):
+        query_text = data["query"]
+    # Check 2: Vapi Format A (message -> toolCalls)
+    elif "message" in data and "toolCalls" in data["message"]:
+        try:
+            args = data["message"]["toolCalls"][0]["function"]["arguments"]
+            # Manchmal ist args ein String, manchmal schon ein Objekt
+            if isinstance(args, str):
+                query_text = json.loads(args).get("query", "")
+            else:
+                query_text = args.get("query", "")
+        except:
+            pass
+    # Check 3: Vapi Format B (direkt toolCall)
+    elif "toolCall" in data:
+         try:
+            args = data["toolCall"]["function"]["arguments"]
+            if isinstance(args, str):
+                query_text = json.loads(args).get("query", "")
+            else:
+                query_text = args.get("query", "")
+         except:
+             pass
+    # --- ANTWORT ---
+    if not query_text:
+        # Fallback, falls wir nichts finden
+        return {"result": "Ich habe die Frage technisch nicht verstanden. Bitte prüfen Sie die Parameter."}
+    # Einfache Logik für den Test:
+    if "geo" in query_text.lower():
+        return {"result": "Geofencing ist eine virtuelle Begrenzung für ein echtes geografisches Gebiet."}
+    return {"result": f"Ich habe deine Frage '{query_text}' erhalten, habe aber keine Antwort in der Datenbank."}