summaryrefslogtreecommitdiff
path: root/shim/ws-shim/src/test.ts
diff options
context:
space:
mode:
authorpolwex <polwex@sortug.com>2025-09-11 01:50:29 +0700
committerpolwex <polwex@sortug.com>2025-09-11 01:50:29 +0700
commit91b15ad49092c314dd6d3483aec47f0be7a37506 (patch)
tree9a0b040ed6e1c2793e4f9fc269a5d6118b16e453 /shim/ws-shim/src/test.ts
parentb1d68ac307ed87d63e83820cbdf843fff0fd9f7f (diff)
ihategit
Diffstat (limited to 'shim/ws-shim/src/test.ts')
-rw-r--r--shim/ws-shim/src/test.ts44
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();