from livekit.api import (
  LiveKitAPI,
  CreateSIPDispatchRuleRequest,
  SIPDispatchRule,
  SIPDispatchRuleIndividual,
)

api = LiveKitAPI()

rule = await api.sip.create_sip_dispatch_rule(
  CreateSIPDispatchRuleRequest(
      rule=SIPDispatchRule(
          dispatch_rule_individual=SIPDispatchRuleIndividual(
              room_prefix="dental-"
          ),
          trunk_ids=["ST_xxxxxxxxxxxx"],
      ),
      attributes={"sip.sendDtmf": "true"},
  )
)

import { SipClient } from "livekit-server-sdk";

const sipClient = new SipClient(
process.env.LIVEKIT_URL!,
process.env.LIVEKIT_API_KEY!,
process.env.LIVEKIT_API_SECRET!
);

const rule = await sipClient.createSipDispatchRule({
rule: {
  dispatchRuleIndividual: {
    roomPrefix: "dental-",
  },
},
trunkIds: ["ST_xxxxxxxxxxxx"],
attributes: { "sip.sendDtmf": "true" },
});

from livekit.agents import Agent, AgentSession, AgentServer
from livekit.agents.prebuilt.tasks import GetDtmfTask
from livekit.plugins import openai, deepgram, cartesia

server = AgentServer()


phone_menu = GetDtmfTask(
  instructions="""Ask the caller to press 1 for appointments or 2 for office hours.
  Wait for their keypad input. If they press 1, respond that you are transferring
  them to appointment scheduling. If they press 2, tell them the office hours are
  Monday through Friday, 8 AM to 5 PM.""",
  send_dtmf_events=True,
)


@server.rtc_session
async def entrypoint(session: AgentSession):
  await session.start(
      agent=Agent(
          instructions="""You are a friendly receptionist at Bright Smile Dental clinic.
          Keep responses brief and conversational.""",
          tasks=[phone_menu],
      ),
      room=session.room,
      stt=deepgram.STT(model="nova-3"),
      llm=openai.LLM(model="gpt-4o-mini"),
      tts=cartesia.TTS(voice="<voice-id>"),
  )


if __name__ == "__main__":
  server.run()

import { Agent, AgentSession, AgentServer } from "@livekit/agents";
import { GetDtmfTask } from "@livekit/agents/prebuilt";
import { DeepgramSTT } from "@livekit/agents-plugin-deepgram";
import { OpenAILLM } from "@livekit/agents-plugin-openai";
import { CartesiaTTS } from "@livekit/agents-plugin-cartesia";

const phoneMenu = new GetDtmfTask({
instructions: `Ask the caller to press 1 for appointments or 2 for office hours.
  Wait for their keypad input. If they press 1, respond that you are transferring
  them to appointment scheduling. If they press 2, tell them the office hours are
  Monday through Friday, 8 AM to 5 PM.`,
sendDtmfEvents: true,
});

const server = new AgentServer();

server.rtcSession(async (session: AgentSession) => {
await session.start({
  agent: new Agent({
    instructions: `You are a friendly receptionist at Bright Smile Dental clinic.
      Keep responses brief and conversational.`,
    tasks: [phoneMenu],
  }),
  room: session.room,
  stt: new DeepgramSTT({ model: "nova-3" }),
  llm: new OpenAILLM({ model: "gpt-4o-mini" }),
  tts: new CartesiaTTS({ voice: "<voice-id>" }),
});
});

server.run();

from livekit.agents import Agent, AgentTask, AgentSession, AgentServer, function_tool
from livekit.agents.prebuilt.tasks import GetDtmfTask
from livekit.plugins import openai, deepgram, cartesia

server = AgentServer()


class CollectConsent(AgentTask):
  def __init__(self):
      super().__init__(
          instructions="""You are collecting recording consent from a caller.
          Ask if they consent to being recorded. If they agree, call the
          consent_given tool. If they refuse, call the consent_refused tool."""
      )

  @function_tool
  async def consent_given(self, context):
      """Called when the caller gives consent to recording."""
      self.complete()

  @function_tool
  async def consent_refused(self, context):
      """Called when the caller refuses consent to recording."""
      await self.session.say("I understand. Goodbye.")
      await self.session.room.disconnect()

  async def on_enter(self):
      await self.session.say(
          "Thank you for calling Bright Smile Dental. "
          "This call may be recorded. Do you consent?"
      )


phone_menu = GetDtmfTask(
  instructions="""Ask the caller to press 1 for appointments or 2 for office hours.
  Wait for their keypad input and respond accordingly.""",
  send_dtmf_events=True,
)


@server.rtc_session
async def entrypoint(session: AgentSession):
  await session.start(
      agent=Agent(
          instructions="""You are a friendly receptionist at Bright Smile Dental.
          Help callers with appointment inquiries and general questions.""",
          tasks=[CollectConsent(), phone_menu],
      ),
      room=session.room,
      stt=deepgram.STT(model="nova-3"),
      llm=openai.LLM(model="gpt-4o-mini"),
      tts=cartesia.TTS(voice="<voice-id>"),
  )


if __name__ == "__main__":
  server.run()

collect_patient_id = GetDtmfTask(
  instructions="""Ask the caller to enter their 4-digit patient ID using their keypad,
  followed by the pound key. Read back the number they entered to confirm.""",
  send_dtmf_events=True,
)