Automatically sending the recording once the recording is ready.

Author: filipi87

examples/freeze_test/client/src/app.ts

@@ -60,6 +60,8 @@ class RecordingSerializer extends ProtobufFrameSerializer {
 }
 
 class WebsocketClientApp {
+  private RECORDING_TIME_MS = 5000
+
   private rtviClient: RTVIClient | null = null;
   private connectBtn: HTMLButtonElement | null = null;
   private disconnectBtn: HTMLButtonElement | null = null;
@@ -240,10 +242,11 @@ class WebsocketClientApp {
 
       this.log("Starting to recording the next 05s of audio");
       this.recordingSerializer.startRecording()
-      await this.sleep(5000)
+      await this.sleep(this.RECORDING_TIME_MS)
       this.recordingSerializer.stopRecording()
       this.log("Recording stopped");
       this.rtviClient.enableMic(false)
+      this.startSendingRecordedAudio()
     } catch (error) {
       this.log(`Error connecting: ${(error as Error).message}`);
       this.updateStatus('Error');

examples/freeze_test/freeze_test_bot.py

@@ -49,6 +49,7 @@
 
 load_dotenv(override=True)
 
+
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     """Handles FastAPI startup and shutdown."""
@@ -70,8 +71,8 @@ async def lifespan(app: FastAPI):
 # Mount the frontend at /
 app.mount("/client", SmallWebRTCPrebuiltUI)
 
-class SimulateFreezeInput(FrameProcessor):
 
+class SimulateFreezeInput(FrameProcessor):
     def __init__(
         self,
         **kwargs,
@@ -123,11 +124,13 @@ async def _send_frames(self):
                 # Emulation as if the user has spoken and the stt transcribed
                 await self.push_frame(UserStartedSpeakingFrame())
                 await self.push_frame(StartInterruptionFrame())
-                await self.push_frame(TranscriptionFrame(
-                    "Count from 01 to 20!",
-                    "",
-                    time_now_iso8601(),
-                ))
+                await self.push_frame(
+                    TranscriptionFrame(
+                        "Count from 01 to 20!",
+                        "",
+                        time_now_iso8601(),
+                    )
+                )
                 await self.push_frame(UserStoppedSpeakingFrame())
                 # sleeping 1s before interrupting
                 wait_time = random.uniform(1, 10)
@@ -136,7 +139,6 @@ async def _send_frames(self):
             logger.error(f"{self} exception receiving data: {e.__class__.__name__} ({e})")
 
 
-
 async def run_example(websocket_client):
     logger.info(f"Starting bot")
 
@@ -177,7 +179,7 @@ async def run_example(websocket_client):
 
     pipeline = Pipeline(
         [
-            #freeze,
+            # freeze,
             transport.input(),
             rtvi,
             stt,
@@ -197,7 +199,7 @@ async def run_example(websocket_client):
             enable_usage_metrics=True,
             report_only_initial_ttfb=True,
         ),
-        idle_timeout_secs=120
+        idle_timeout_secs=120,
     )
 
     @transport.event_handler("on_client_connected")
@@ -236,6 +238,7 @@ async def websocket_endpoint(websocket: WebSocket):
     except Exception as e:
         print(f"Exception in run_bot: {e}")
 
+
 @app.post("/connect")
 async def bot_connect(request: Request) -> Dict[Any, Any]:
     server_mode = os.getenv("WEBSOCKET_SERVER", "fast_api")