diff --git a/network/communication-hub.ts b/network/communication-hub.ts index a24a845..3ab4434 100644 --- a/network/communication-hub.ts +++ b/network/communication-hub.ts @@ -560,7 +560,6 @@ export class CommunicationHubHandler { // find socket that matches endpoint instance exactly const socket = this.findMatchingEndpointSocket(endpoint, excludeSocket); - // console.log("getPreferredSocketForEndpoint", socket, endpoint, excludeSocket); if (socket) return socket; @@ -633,7 +632,6 @@ export class CommunicationHubHandler { const promises = [] - // console.log("datexOut", receivers, outGroups); for (const [socket, endpoints] of outGroups) { if (!socket) continue; promises.push(this.sendAddressedBlockToReceivers(data.dxb, endpoints, socket)); diff --git a/network/communication-interfaces/window-interface.ts b/network/communication-interfaces/window-interface.ts index 0421892..96f96c3 100644 --- a/network/communication-interfaces/window-interface.ts +++ b/network/communication-interfaces/window-interface.ts @@ -10,14 +10,9 @@ export class WindowInterfaceSocket extends CommunicationInterfaceSocket { } handleReceive = (event: MessageEvent) => { - console.log("Receive", event) if (event.origin == this.windowOrigin) { if (event.data instanceof ArrayBuffer) this.receive(event.data) else if (typeof event.data == "string") this.receive(base64ToArrayBuffer(event.data)) - else - this.logger.error("Got an invalid request in window socket", event) - } else { - this.logger.error("Got an invalid origin", event.origin, this.windowOrigin, this.toString(), this.endpoint?.toString()) } } @@ -26,7 +21,6 @@ export class WindowInterfaceSocket extends CommunicationInterfaceSocket { } close() { - console.warn("Why are we removing this socket??????", this) globalThis.removeEventListener('message', this.handleReceive); } @@ -36,8 +30,7 @@ export class WindowInterfaceSocket extends CommunicationInterfaceSocket { else this.window.postMessage(dxb, this.windowOrigin) return true; } - catch (e) { - console.error(e, "window socket"); + catch { return false; } } diff --git a/runtime/runtime.ts b/runtime/runtime.ts index cfbca98..e02b5a2 100644 --- a/runtime/runtime.ts +++ b/runtime/runtime.ts @@ -1773,7 +1773,6 @@ export class Runtime { // block end if (current_block && index >= current_block_size) { - console.log("received new block from stream") this.handleDatexIn(current_block.buffer, full_scope_callback, variables, header_callback, socket) .catch(e=>console.error("Error handling block stream: ", e)) // reset for next block