send_dtmf_code

@function_tool()
async def send_dtmf_code(
    self,
    code: Annotated[int, Field(description="The DTMF code to send to the phone number for the current step.")],
    context: RunContext_T
) -> None:
    # Cooldown check to prevent rapid presses
    current_time = time.time()
    if current_time - context.userdata.last_dtmf_press < 3:
        <http://logger.info|logger.info>("DTMF code rejected due to cooldown")
        return None

    # Send the DTMF code
    context.userdata.last_dtmf_press = current_time
    room = context.session.room
    await room.local_participant.publish_dtmf(
        code=code,
        digit=str(code)
    )
    await room.local_participant.publish_data(
        f"{code}",
        topic="dtmf_code"
    )

def setup_dtmf_handlers(room: rtc.Room, phone_assistant: PhoneAssistant):
    async def _async_handle_dtmf(dtmf_event: rtc.SipDTMF):
        await phone_assistant.session.interrupt()
        <http://logger.info|logger.info>("Interrupted agent due to DTMF")

        code = dtmf_event.code
        digit = dtmf_event.digit
        identity = dtmf_event.participant.identity

        # Example of processing different DTMF inputs
        department_numbers = {
            "1": ("BILLING_PHONE_NUMBER", "Billing"),
            "2": ("TECH_SUPPORT_PHONE_NUMBER", "Tech Support"),
            "3": ("CUSTOMER_SERVICE_PHONE_NUMBER", "Customer Service")
        }

        if digit in department_numbers:
            # Process valid input
            env_var, dept_name = department_numbers[digit]
            transfer_number = f"tel:{os.getenv(env_var)}"
            userdata = phone_assistant.session.userdata
            userdata.selected_department = dept_name
            await phone_assistant._handle_transfer(identity, transfer_number, dept_name)
        else:
            # Handle invalid input
            await phone_assistant.session.generate_reply(user_input="I'm sorry, please choose one of the options I mentioned earlier.")

    @room.on("sip_dtmf_received")
    def handle_dtmf(dtmf_event: rtc.SipDTMF):
        asyncio.create_task(_async_handle_dtmf(dtmf_event))