@@ 13,6 13,7 @@ function blast(msg, key) {
try {
peer.send(boxed)
} catch (err) {
+ console.log(err)
}
})
}
@@ 45,6 46,9 @@ async function handleWs(ws) {
ws.send(boxed)
})
})
+ publish({'text': ws.pubkey.substring(0, 10) + ' connected.'}, key).then(bog => {
+ blast(bog, key)
+ })
}
} else if (msg instanceof Uint8Array) {
unbox(msg, key).then(unboxed => {
@@ 55,10 59,9 @@ async function handleWs(ws) {
blast(unboxed, key)
})
} else if (isWebSocketCloseEvent(msg)) {
- peers.delete(id);
- dispatch(`Closed: [${id}]`);
- break;
- }
+ peers.delete(id);
+ break;
+ }
}
} catch (err) {
if (!ws.isClosed) {