From 300e15b674bc988f2fe9ccec216360cc48de0a4a Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Sat, 16 Mar 2024 17:41:45 +0100 Subject: [PATCH] Cosmetic --- packages/ws-relay/src/index.ts | 12 +++--------- 1 file changed, 3 insertions(+), 9 deletions(-) diff --git a/packages/ws-relay/src/index.ts b/packages/ws-relay/src/index.ts index 4845601..e16df3e 100644 --- a/packages/ws-relay/src/index.ts +++ b/packages/ws-relay/src/index.ts @@ -77,16 +77,12 @@ export function boot(ds = Dataspace.global, debug: boolean = false, WebSocketCon ws.close(); } ws.onclose = () => facet.turn(() => { stop facet; }); - ws.onerror = () => facet.turn(() => - Turn.active.crash(new Error("WebSocket error"))); + ws.onerror = () => facet.turn(() => Turn.active.crash(new Error("WebSocket error"))); const relay = new Relay.Relay({ debug, trustPeer: true, packetWriter: bs => ws.send(bs), - setup(r: Relay.Relay) { - ws.onmessage = e => facet.turn(() => - r.accept(new Uint8Array(e.data))); - }, + setup: r => ws.onmessage = e => r.accept(new Uint8Array(e.data)), initialOid: 0, }); console.log('succeed', addr.url); @@ -283,9 +279,7 @@ export function boot(ds = Dataspace.global, debug: boolean = false, WebSocketCon : N.Packet.fragmented(fragments)); } }), - setup(r: Relay.Relay) { - relay = r; - }, + setup: r => relay = r, initialOid: 0, }).peer!; assert G.ResolvedPathStep({