Refactor WebRTC example and update werift version to 0.21.12

shinyoshiaki · Jan 26, 2025 · 4894934 · 4894934
1 parent fae307e
commit 4894934
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 12 deletions.
diff --git a/examples/ring/recv-via-webrtc.ts b/examples/ring/recv-via-webrtc.ts
@@ -9,25 +9,25 @@ import { CustomPeerConnection } from "./peer";
 
 const example = async () => {
   const ringApi = new RingApi({
-      // Replace with your refresh token
-      refreshToken: process.env.RING_REFRESH_TOKEN!,
-      debug: true,
-    }),
-    cameras = await ringApi.getCameras(),
-    camera = cameras[0];
+    // Replace with your refresh token
+    refreshToken: process.env.RING_REFRESH_TOKEN!,
+    debug: true,
+  });
+  const cameras = await ringApi.getCameras();
+  const camera = cameras[0];
 
   if (!camera) {
     console.log("No cameras found");
     return;
   }
 
   const track = new MediaStreamTrack({ kind: "video" });
-  const receiver = new CustomPeerConnection() as any;
-  receiver.onVideoRtp.subscribe((rtp) => {
+  const ring = new CustomPeerConnection();
+  ring.onVideoRtp.subscribe((rtp) => {
     track.writeRtp(rtp);
   });
   await camera.startLiveCall({
-    createPeerConnection: () => receiver,
+    createPeerConnection: () => ring,
   });
   const server = new Server({ port: 8888 });
 

diff --git a/package-lock.json b/package-lock.json
diff --git a/packages/webrtc/package.json b/packages/webrtc/package.json
@@ -1,6 +1,6 @@
 {
   "name": "werift",
-  "version": "0.21.11",
+  "version": "0.21.12",
   "description": "WebRTC Implementation for TypeScript (Node.js)",
   "keywords": [
     "WebRTC",

diff --git a/packages/webrtc/src/nonstandard/recorder/writer/webm.ts b/packages/webrtc/src/nonstandard/recorder/writer/webm.ts
@@ -159,7 +159,7 @@ export class WebmFactory extends MediaWriter {
     await Promise.all(this.rtpSources.map((r) => r.stop()));
 
     if (!this.ended) {
-      await this.onEol.asPromise(5000);
+      await this.onEol.asPromise(5000).catch((e) => e);
     }
     this.unSubscribers.dispose();
   }