diff options
Diffstat (limited to 'shim/ws-shim/src/test.ts')
-rw-r--r-- | shim/ws-shim/src/test.ts | 44 |
1 files changed, 44 insertions, 0 deletions
diff --git a/shim/ws-shim/src/test.ts b/shim/ws-shim/src/test.ts new file mode 100644 index 0000000..fb87555 --- /dev/null +++ b/shim/ws-shim/src/test.ts @@ -0,0 +1,44 @@ +import { Relay } from "./client"; +const ids = [ + "1a4f2d987384a33753e777138586b1f9b3b62eb0f6e54ca1cdb42859de5625bc", +]; +async function wsClient(url: string) { + console.log("connecting to relae", url); + const relay = new Relay(url); + await relay.connect(); + const id = crypto.randomUUID(); + relay.subscribe(id, [{ ids, limit: 50 }], { + oneose: () => { + console.log("oneose"); + }, + onevent(event) { + console.log("relay event", { url, event }); + }, + }); + // const socket = new WebSocket(url); + // socket.addEventListener("open", (event) => { + // // + // console.log("socket client open", event); + // }); + // socket.addEventListener("close", (event) => { + // // + // console.log("socket client close", event); + // }); + // socket.addEventListener("error", (event) => { + // // + // console.log("socket client error", event); + // }); + // socket.addEventListener("message", (event) => { + // // + // console.log("socket client msg", event); + // }); + // return socket; +} + +const relays = ["wss://nos.lol", "wss://relay.damus.io"]; + +async function run() { + console.log("wth"); + await wsClient(relays[0]!); +} +run(); |