console: drop head_wobbler.feed_pcm path and its playback-delay helper

LocalStream's audio path no longer needs to feed a local wobbler with a
playback-delay-aware start offset; the daemon's wobbler analyses the
same audio that we hand off via push_audio_sample. Remove the
"if head_wobbler is not None" block and the now-unused
_estimate_pending_playback_seconds helper that only existed to compute
that start_delay_s.

Drops the matching test
test_play_loop_feeds_head_wobbler_with_local_playback_delay in
tests/test_console.py.

Author: RemiFabre

src/reachy_mini_conversation_app/console.py

@@ -65,26 +65,6 @@
 )
 
 
-def _estimate_pending_playback_seconds(robot: ReachyMini) -> float:
-    """Best-effort estimate of audio still queued in the local player."""
-    media = getattr(robot, "media", None)
-    audio = getattr(media, "audio", None)
-    if audio is None:
-        return 0.0
-
-    next_pts_ns = getattr(audio, "_playback_next_pts_ns", None)
-    get_running_time_ns = getattr(audio, "_get_playback_running_time_ns", None)
-    if next_pts_ns is None or not callable(get_running_time_ns):
-        return 0.0
-
-    try:
-        pending_ns = int(next_pts_ns) - int(get_running_time_ns())
-    except Exception:
-        return 0.0
-
-    return max(0.0, pending_ns / 1e9)
-
-
 class LocalStream:
     """LocalStream using Reachy Mini's recorder/player."""
 
@@ -622,11 +602,6 @@ async def play_loop(self) -> None:
                         num_samples,
                     )
 
-                head_wobbler = self.handler.deps.head_wobbler
-                if head_wobbler is not None:
-                    playback_delay_s = _estimate_pending_playback_seconds(self._robot)
-                    head_wobbler.feed_pcm(audio_data.reshape(1, -1), input_sample_rate, start_delay_s=playback_delay_s)
-
                 self._robot.media.push_audio_sample(audio_frame)
 
             else:

tests/test_console.py

@@ -70,56 +70,6 @@ def test_clear_audio_queue_falls_back_when_backend_is_unknown() -> None:
     assert handler.output_queue.empty()
 
 
-@pytest.mark.asyncio
-async def test_play_loop_feeds_head_wobbler_with_local_playback_delay() -> None:
-    """Local playback should drive speech wobble using the queued player delay."""
-    head_wobbler = MagicMock()
-    chunk = np.array([1, -2, 3, -4], dtype=np.int16)
-
-    class Handler:
-        def __init__(self) -> None:
-            self.deps = SimpleNamespace(head_wobbler=head_wobbler)
-            self.output_queue = asyncio.Queue()
-            self._emitted = False
-
-        async def emit(self):
-            if not self._emitted:
-                self._emitted = True
-                return (24000, chunk.copy())
-            return None
-
-    audio = SimpleNamespace(
-        _playback_next_pts_ns=1_500_000_000,
-        _get_playback_running_time_ns=lambda: 500_000_000,
-    )
-    media = SimpleNamespace(
-        audio=audio,
-        backend=MediaBackend.LOCAL,
-        get_output_audio_samplerate=lambda: 24000,
-        push_audio_sample=MagicMock(),
-    )
-    robot = SimpleNamespace(media=media)
-    handler = Handler()
-    stream = LocalStream(handler, robot)
-
-    async def stop_soon() -> None:
-        await asyncio.sleep(0.01)
-        stream._stop_event.set()
-
-    stopper = asyncio.create_task(stop_soon())
-    try:
-        await asyncio.wait_for(stream.play_loop(), timeout=1.0)
-    finally:
-        await stopper
-
-    head_wobbler.feed_pcm.assert_called_once()
-    args, kwargs = head_wobbler.feed_pcm.call_args
-    assert np.array_equal(args[0], chunk.reshape(1, -1))
-    assert args[1] == 24000
-    assert kwargs["start_delay_s"] == pytest.approx(1.0)
-    media.push_audio_sample.assert_called_once()
-
-
 def test_backend_config_persists_gemini_selection_and_status(
     tmp_path,
     monkeypatch,