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({