fix(ws,fastify-websocket): Send only on ready socket

enisdenjo · Oct 19, 2021 · 8d13c9e · 8d13c9e
1 parent 8479f76
commit 8d13c9e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/src/use/fastify-websocket.ts b/src/use/fastify-websocket.ts
@@ -83,6 +83,7 @@ export function makeHandler<
         protocol: socket.protocol,
         send: (data) =>
           new Promise((resolve, reject) => {
+            if (socket.readyState !== socket.OPEN) return resolve();
             socket.send(data, (err) => (err ? reject(err) : resolve()));
           }),
         close: (code, reason) => socket.close(code, reason),

diff --git a/src/use/ws.ts b/src/use/ws.ts
@@ -101,6 +101,7 @@ export function useServer<
         protocol: socket.protocol,
         send: (data) =>
           new Promise((resolve, reject) => {
+            if (socket.readyState !== socket.OPEN) return resolve();
             socket.send(data, (err) => (err ? reject(err) : resolve()));
           }),
         close: (code, reason) => socket.close(code, reason),