Chat

from zrt import Pipeline
from zrt.plugins import GoogleLLM, CartesiaTTS

# Text in, voice out
pipeline = Pipeline(llm=GoogleLLM(), tts=CartesiaTTS())

# ... when a text message arrives:
await pipeline.process_text("What are your opening hours?")

pipeline = Pipeline(llm=GoogleLLM())

def on_reply(data):
    print(f"Agent: {data['text']}")

pipeline.on("llm", on_reply)
await pipeline.process_text("Hello!")

from zrt import PubSubPublishConfig

# Typically called from a function_tool, e.g. self.session inside the agent:
await self.session.publish_message(
    PubSubPublishConfig(topic="CHAT", message="Hello from the agent")
)

def on_message(message):
    print("Received:", message)

# Inside the agent, e.g. in on_enter: self.session is available on the agent.
await self.session.subscribe_pubsub("CHAT", on_message)