Add 2mic example service

wyoming_satellite/example_event_client.py

@@ -4,13 +4,11 @@ import asyncio
 import logging
 import time
 from functools import partial
-from pathlib import Path
 
 from wyoming.event import Event
 from wyoming.server import AsyncEventHandler, AsyncServer
 
 _LOGGER = logging.getLogger()
-_DIR = Path(__file__).parent
 
 
 async def main() -> None:
@@ -52,8 +50,6 @@ class ExampleEventHandler(AsyncEventHandler):
         self.cli_args = cli_args
         self.client_id = str(time.monotonic_ns())
 
-        self.is_running = True
-
         _LOGGER.debug("Client connected: %s", self.client_id)
 
     async def handle_event(self, event: Event) -> bool:

wyoming_satellite/satellite.py

@@ -15,7 +15,7 @@ from wyoming.error import Error
 from wyoming.event import Event, async_write_event
 from wyoming.mic import MicProcessAsyncClient
 from wyoming.pipeline import PipelineStage, RunPipeline
-from wyoming.satellite import RunSatellite
+from wyoming.satellite import RunSatellite, StreamingStarted, StreamingStopped
 from wyoming.snd import SndProcessAsyncClient
 from wyoming.tts import Synthesize
 from wyoming.vad import VoiceStarted, VoiceStopped
@@ -538,9 +538,11 @@ class SatelliteBase:
 
     async def trigger_streaming_start(self) -> None:
         await run_event_command(self.settings.event.streaming_start)
+        await self.forward_event(StreamingStarted().event())
 
     async def trigger_streaming_stop(self) -> None:
         await run_event_command(self.settings.event.streaming_stop)
+        await self.forward_event(StreamingStopped().event())
 
     async def trigger_detect(self) -> None:
         await run_event_command(self.settings.event.detect)