1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
import { Relay } from "./client";
const ids = [
// "1a4f2d987384a33753e777138586b1f9b3b62eb0f6e54ca1cdb42859de5625bc",
"9ef9530b9601d798fcd4e29f151b16bbe4f659408a80618cdf9f2f12a8bc39c6",
"db2815575eddeed24f122de70023c861ec63d0473c40b899d8883194edf122b3",
"1ada56a84ffc94a3cd8ad68432c3cc0ed3e66ac8633226e92cc1a1686efa15a8",
"1a4e12c3c8d2c560c068ee71f51afb84eefda4ec2593ab160312265d626aaa72",
];
const authors: string[] = [];
async function wsClient(url: string) {
console.log("connecting to relae", url);
const relay = new Relay(url, (msg) => {
// console.log("msg", msg);
});
relay.onerror = (error) => {
console.log(url);
console.error("ws error", error);
};
relay.ondisconnect = () => {
console.error(url, "relay disconnected");
};
relay.onfailure = () => {
console.error(url, "relay failed");
};
relay.onnotice = (notice) => {
console.error("on notice", notice);
};
relay.onconnect = () => {
console.log("relay connected", url);
};
await relay.connect();
const id = crypto.randomUUID();
const fids = ids.filter((i) => i.length === 64);
// const filter = { ids: fids, limit: 500 };
const filter = { kinds: [1, 2, 3, 4, 5, 6, 7, 8, 9, 10], limit: 500 };
// const filter = {
// kinds: [0],
// authors,
// };
let eventCount = 0;
const pubkeys: string[] = [];
relay.subscribe(id, [filter], {
oneose: () => {
console.log("oneose");
console.log({ eventCount });
console.log(pubkeys);
},
onevent(event) {
// console.log("relay event", { url, event });
eventCount++;
pubkeys.push(event.pubkey);
},
onclose: (msg) => {
console.log("sub closed wtf", msg);
},
});
// 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"];
const relays = ["wss://n.urbit.cloud"];
async function run() {
console.log("wth");
for (const r of relays) {
await wsClient(r);
}
}
run();
|
