|
|
@ -77,6 +77,9 @@ function makeSocketFactory( |
|
|
// Bind websocket handlers.
|
|
|
// Bind websocket handlers.
|
|
|
socket.onopen = onOpen; |
|
|
socket.onopen = onOpen; |
|
|
socket.onclose = onClose; |
|
|
socket.onclose = onClose; |
|
|
|
|
|
socket.onerror = (err) => { |
|
|
|
|
|
console.log("WebSocket error:", err); |
|
|
|
|
|
}; |
|
|
socket.onmessage = onMessage; |
|
|
socket.onmessage = onMessage; |
|
|
|
|
|
|
|
|
return socket; |
|
|
return socket; |
|
|
@ -106,10 +109,15 @@ function makeMiddleware( |
|
|
if (socket !== undefined) { |
|
|
if (socket !== undefined) { |
|
|
socket.close(); |
|
|
socket.close(); |
|
|
socket = undefined; |
|
|
socket = undefined; |
|
|
console.log("WebSocket closed."); |
|
|
|
|
|
|
|
|
console.log("WebSocket closing."); |
|
|
} else { |
|
|
} else { |
|
|
console.log("Ignoring socketClose action, socket is already closed."); |
|
|
|
|
|
|
|
|
console.log( |
|
|
|
|
|
"Ignoring socketClose action, socket is already closing or closed." |
|
|
|
|
|
); |
|
|
} |
|
|
} |
|
|
|
|
|
} else if (socketClosed.match(action)) { |
|
|
|
|
|
console.log("WebSocket closed."); |
|
|
|
|
|
socket = undefined; |
|
|
} else if (socket !== undefined) { |
|
|
} else if (socket !== undefined) { |
|
|
for (const middleware of messageMiddlewares) { |
|
|
for (const middleware of messageMiddlewares) { |
|
|
middleware.handleAction(socketMessageSender(socket), action); |
|
|
middleware.handleAction(socketMessageSender(socket), action); |
|
|
|