feat(breeze_buddy): add IVR mode — DTMF-driven menu flow

  New flow.mode="ivr" runs a pure DTMF state machine (no STT/LLM/pipeline):
  walks a per-template menu tree, plays TTS prompts, routes on keypresses.
  Supports nested sub-menus, back-navigation, greeting-driven opening node,
  per-node timeout/retry, invalid-key replay (no retry consumed), digit
  logging (dtmf_inputs), synthetic transcription, and BUSY-on-incomplete
  so unanswered calls retry.

Author: manas-narra

app/ai/voice/agents/breeze_buddy/agent/__init__.py

@@ -38,12 +38,6 @@
     create_lead_from_template_id,
     handle_inbound_call,
 )
-from app.ai.voice.agents.breeze_buddy.agent.ivr import (
-    BLOCK_MESSAGE_PLAY_SECONDS,
-    _send_audio,
-    get_template_id_from_call,
-    prepare_block_audio,
-)
 from app.ai.voice.agents.breeze_buddy.agent.pipeline import (
     build_pipeline,
     create_pipeline_task,
@@ -62,6 +56,13 @@
 from app.ai.voice.agents.breeze_buddy.handlers.internal.end_conversation import (
     end_conversation,
 )
+from app.ai.voice.agents.breeze_buddy.ivr.selection import (
+    BLOCK_MESSAGE_PLAY_SECONDS,
+    _send_audio,
+    get_template_id_from_call,
+    prepare_block_audio,
+)
+from app.ai.voice.agents.breeze_buddy.ivr.walker import IvrWalker
 from app.ai.voice.agents.breeze_buddy.managers.utils import (
     prepare_and_store_initial_greeting,
 )
@@ -82,6 +83,7 @@
 from app.ai.voice.agents.breeze_buddy.template.types import (
     LEGACY_VOICE_TO_PROVIDER,
     ConfigurationModel,
+    FlowMode,
     InterruptionConfig,
     TemplateModel,
     TTSConfig,
@@ -1054,6 +1056,22 @@ async def run(self, runner_args: Optional[RunnerArguments] = None) -> None:
                             f"Invalid TTS provider '{payload_provider}' in payload, keeping existing config"
                         )
 
+            # ── IVR mode: pure DTMF state machine (no STT/LLM/pipeline) ─────────
+            # Telephony-only. Runs the menu tree directly over the websocket and
+            # returns before any pipeline is built — self.task/self.context stay
+            # None, which the reused end_conversation finaliser already handles.
+            if (
+                not self.is_daily_mode
+                and self.template
+                and self.template.flow.get("mode") == FlowMode.IVR.value
+            ):
+                logger.info(
+                    f"[IVR] flow.mode=ivr -> running DTMF walker for "
+                    f"call {self.call_sid}"
+                )
+                await IvrWalker(self).run()
+                return
+
             # Build services and pipeline. Stream mode skips LLM creation and
             # runs build_pipeline with mode="stream" (no LLM processor, no
             # assistant aggregator, transcript collector inserted, no user idle).

app/ai/voice/agents/breeze_buddy/handlers/internal/end_conversation.py

@@ -302,12 +302,22 @@ async def end_conversation(context: TemplateContext, args, transition_to=None):
         if approval_manager:
             approval_manager.deny_all("conversation_ended")
 
-        # Send EndFrame to gracefully terminate the pipeline
-        logger.info(
-            f"Sending EndFrame to terminate pipeline for call {context.call_sid}"
-        )
-        await context.task.queue_frame(EndFrame())
-        logger.info(f"EndFrame queued for call {context.call_sid}")
+        # Send EndFrame to gracefully terminate the pipeline.
+        # IVR mode (flow.mode == "ivr") runs without a Pipecat pipeline, so
+        # context.task is None — there is nothing to terminate. The IVR walker
+        # ends the call by closing the websocket itself. Guard the EndFrame so
+        # this finalization path is reusable from the pipeline-less walker.
+        if context.task:
+            logger.info(
+                f"Sending EndFrame to terminate pipeline for call {context.call_sid}"
+            )
+            await context.task.queue_frame(EndFrame())
+            logger.info(f"EndFrame queued for call {context.call_sid}")
+        else:
+            logger.info(
+                f"No pipeline task for call {context.call_sid} (IVR mode); "
+                "skipping EndFrame"
+            )
 
         # Clear log context AFTER all logs to prevent leakage between calls
         clear_log_context()

app/ai/voice/agents/breeze_buddy/ivr/__init__.py

@@ -0,0 +1,10 @@
+"""IVR (DTMF) subpackage for Breeze Buddy telephony.
+
+- ``selection``: answer-time, pre-pipeline IVR for inbound template selection
+  (caller picks which agent/template via keypad before the pipeline is built).
+- ``walker``: mid-call IVR mode (``flow.mode == "ivr"``) — a pure DTMF state
+  machine that runs the conversation itself, no STT/LLM/pipeline.
+
+Import from the explicit submodules (``ivr.selection`` /
+``ivr.walker``); this package intentionally does not re-export.
+"""