fix agent pipeline

Author: aboutphilippe

agent_telephony/twilio/livekit-trunk-setup/.env.example

@@ -1,4 +1,5 @@
 TWILIO_ACCOUNT_SID=
 TWILIO_AUTH_TOKEN=
 TWILIO_PHONE_NUMBER="+000000000000"
-LIVEKIT_SIP_URI="sip:XXXXX.sip.livekit.cloud;transport=tcp"
+LIVEKIT_SIP_URI="sip:XXXXX.sip.livekit.cloud;transport=tcp"
+TRUNK_NAME="LiveKit Trunk"

agent_telephony/twilio/livekit-trunk-setup/inbound_trunk.json

@@ -0,0 +1,8 @@
+{
+    "trunk": {
+        "name": "Inbound LiveKit Trunk",
+        "numbers": [
+            "+12096194281"
+        ]
+    }
+}

agent_telephony/twilio/livekit-trunk-setup/twilio_trunk.py

@@ -16,25 +16,25 @@ def get_env_var(var_name):
     return value
 
 
-def create_livekit_trunk(client, sip_uri):
+def create_livekit_trunk(client, sip_uri, trunk_name):
     domain_name = f"livekit-trunk-{os.urandom(4).hex()}.pstn.twilio.com"
     trunk = client.trunking.v1.trunks.create(
-        friendly_name="LiveKit Trunk",
+        friendly_name=trunk_name,
         domain_name=domain_name,
     )
     trunk.origination_urls.create(
         sip_url=sip_uri,
         weight=1,
         priority=1,
         enabled=True,
-        friendly_name="LiveKit SIP URI",
+        friendly_name=f"{trunk_name} SIP URI",
     )
-    logging.info("Created new LiveKit Trunk.")
+    logging.info(f"Created new {trunk_name} trunk.")
     return trunk
 
 
-def create_inbound_trunk(phone_number):
-    trunk_data = {"trunk": {"name": "Inbound LiveKit Trunk", "numbers": [phone_number]}}
+def create_inbound_trunk(phone_number, trunk_name):
+    trunk_data = {"trunk": {"name": f"Inbound {trunk_name}", "numbers": [phone_number]}}
     with open("inbound_trunk.json", "w") as f:
         json.dump(trunk_data, f, indent=4)
 
@@ -58,9 +58,9 @@ def create_inbound_trunk(phone_number):
     return None
 
 
-def create_dispatch_rule(trunk_sid):
+def create_dispatch_rule(trunk_sid, trunk_name):
     dispatch_rule_data = {
-        "name": "Inbound Dispatch Rule",
+        "name": f"Inbound {trunk_name} Dispatch Rule",
         "trunk_ids": [trunk_sid],
         "rule": {"dispatchRuleIndividual": {"roomPrefix": "call-"}},
     }
@@ -89,23 +89,25 @@ def main():
     auth_token = get_env_var("TWILIO_AUTH_TOKEN")
     phone_number = get_env_var("TWILIO_PHONE_NUMBER")
     sip_uri = get_env_var("LIVEKIT_SIP_URI")
+    trunk_name = get_env_var("TRUNK_NAME")
 
     client = Client(account_sid, auth_token)
 
     existing_trunks = client.trunking.v1.trunks.list()
     livekit_trunk = next(
-        (trunk for trunk in existing_trunks if trunk.friendly_name == "LiveKit Trunk"),
+        (trunk for trunk in existing_trunks if trunk.friendly_name == trunk_name),
         None,
     )
 
     if not livekit_trunk:
-        livekit_trunk = create_livekit_trunk(client, sip_uri)
+        livekit_trunk = create_livekit_trunk(client, sip_uri, trunk_name)
     else:
-        logging.info("LiveKit Trunk already exists. Using the existing trunk.")
+        logging.info(f"{trunk_name} already exists. Using the existing trunk.")
 
-    inbound_trunk_sid = create_inbound_trunk(phone_number)
+
+    inbound_trunk_sid = create_inbound_trunk(phone_number, trunk_name)
     if inbound_trunk_sid:
-        create_dispatch_rule(inbound_trunk_sid)
+        create_dispatch_rule(inbound_trunk_sid, trunk_name)
 
 
 if __name__ == "__main__":

agent_telephony/twilio/livekit_pipeline/src/pipeline.py

@@ -124,7 +124,7 @@ def on_metrics_collected(agent_metrics: metrics.AgentMetrics) -> None:
     cli.run_app(
         WorkerOptions(
             entrypoint_fnc=entrypoint,
-            agent_name="AgentStream",
+            agent_name="AgentTwilio",
             prewarm_fnc=prewarm,
         )
     )

agent_telephony/twilio/readme.md

@@ -7,7 +7,10 @@ Build an AI agent that do an outbound call with Twilio and can interact with in
 
 - Docker (for running Restack)
 - Python 3.10 or higher
-- Vapi account (for outbound calls)
+- Twilio account (for outbound calls)
+- Livekit account (for WebRTC pipeline)
+- Deepgram account (for transcription)
+- ElevenLabs account (for TTS)
 
 ### Trunk setup for outbound calls with Twilio
 

agent_voice/livekit/livekit_pipeline/src/pipeline.py

@@ -124,7 +124,7 @@ def on_metrics_collected(agent_metrics: metrics.AgentMetrics) -> None:
     cli.run_app(
         WorkerOptions(
             entrypoint_fnc=entrypoint,
-            agent_name="AgentStream",
+            agent_name="AgentVoice",
             prewarm_fnc=prewarm,
         )
     )