syndicate-lang
/
syndicate-js
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

Cosmetic

This commit is contained in:
Tony Garnock-Jones 2024-03-16 17:41:45 +01:00
parent 40f5ef4085
commit 300e15b674
1 changed files with 3 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
packages/ws-relay/src/index.ts
View File

@ -77,16 +77,12 @@ export function boot(ds = Dataspace.global, debug: boolean = false, WebSocketCon
ws.close(); ws.close();
} }
ws.onclose = () => facet.turn(() => { stop facet; }); ws.onclose = () => facet.turn(() => { stop facet; });
ws.onerror = () => facet.turn(() => ws.onerror = () => facet.turn(() => Turn.active.crash(new Error("WebSocket error")));
Turn.active.crash(new Error("WebSocket error")));
const relay = new Relay.Relay({ const relay = new Relay.Relay({
debug, debug,
trustPeer: true, trustPeer: true,
packetWriter: bs => ws.send(bs), packetWriter: bs => ws.send(bs),
setup(r: Relay.Relay) { setup: r => ws.onmessage = e => r.accept(new Uint8Array(e.data)),
ws.onmessage = e => facet.turn(() =>
r.accept(new Uint8Array(e.data)));
},
initialOid: 0, initialOid: 0,
}); });
console.log('succeed', addr.url); console.log('succeed', addr.url);
@ -283,9 +279,7 @@ export function boot(ds = Dataspace.global, debug: boolean = false, WebSocketCon
: N.Packet.fragmented(fragments)); : N.Packet.fragmented(fragments));
} }
}), }),
setup(r: Relay.Relay) { setup: r => relay = r,
relay = r;
},
initialOid: 0, initialOid: 0,
}).peer!; }).peer!;
assert G.ResolvedPathStep<Ref>({ assert G.ResolvedPathStep<Ref>({