fix voice mail

Author: aboutphilippe

agent_telephony/twilio_livekit/agent_twilio/src/functions/llm_logic.py

@@ -5,6 +5,9 @@
 from pydantic import BaseModel
 from restack_ai.function import NonRetryableError, function
 
+class Message(BaseModel):
+    role: str
+    content: str
 
 class LlmLogicResponse(BaseModel):
     """Structured AI decision output used to interrupt conversations."""
@@ -15,7 +18,7 @@ class LlmLogicResponse(BaseModel):
 
 
 class LlmLogicInput(BaseModel):
-    messages: list[dict]
+    messages: list[Message]
     documentation: str
 
 
@@ -26,6 +29,12 @@ async def llm_logic(
     try:
         client = OpenAI(api_key=os.environ.get("OPENAI_API_KEY"))
 
+        user_messages = [msg for msg in function_input.messages if msg.role == "user"]
+        if len(user_messages) == 1:
+            voice_mail_detection = "End the call if a voice mail is detected."
+        else:
+            voice_mail_detection = ""
+
         response = client.beta.chat.completions.parse(
             model="gpt-4o",
             messages=[
@@ -35,7 +44,7 @@ async def llm_logic(
                         "Analyze the developer's questions and determine if an interruption is needed. "
                         "Use the Restack documentation for accurate answers. "
                         "Track what the developer has learned and update their belief state."
-                        "End the call if a voice mail is detected."
+                        f"{voice_mail_detection}"
                         f"Restack Documentation: {function_input.documentation}"
                     ),
                 },

agent_telephony/twilio_livekit/livekit_pipeline/src/metrics.py

@@ -53,7 +53,7 @@ async def send_metrics(
             )
             await client.send_agent_event(
                 event_name="pipeline_metrics",
-                agent_id=agent_id.replace("local-", ""),
+                agent_id=agent_id,
                 run_id=run_id,
                 event_input={
                     "metrics": pipeline_metrics,