From 9da03aa053ccb85986359fb3fe4ce008984632e3 Mon Sep 17 00:00:00 2001 From: Alex Gleason Date: Fri, 25 Aug 2023 17:17:26 -0500 Subject: [PATCH] streaming: socket.addEventListener('open', ...) --> socket.onopen, etc --- src/controllers/api/streaming.ts | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/src/controllers/api/streaming.ts b/src/controllers/api/streaming.ts index bc91eef..8b655f9 100644 --- a/src/controllers/api/streaming.ts +++ b/src/controllers/api/streaming.ts @@ -42,8 +42,7 @@ const streamingController: AppController = (c) => { } } - socket.addEventListener('open', async () => { - console.log('websocket: connection opened'); + socket.onopen = async () => { if (!stream) return; ws.subscribe(conn, { stream }); @@ -58,14 +57,11 @@ const streamingController: AppController = (c) => { } } } - }); + }; - socket.addEventListener('message', (e) => console.log('websocket message: ', e.data)); - - socket.addEventListener('close', () => { - console.log('websocket: connection closed'); + socket.onclose = () => { ws.unsubscribeAll(socket); - }); + }; return response; };