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();