import { AppBskyFeedLike } from "@atproto/api";
import { Firehose } from "@skyware/firehose";
import { getAgent } from "./agent.js";
import { label } from "./label.js";
import { DID } from "./constants.js";
import "dotenv/config";

const subscribe = async () => {
  const agent = await getAgent();
  let cursorSave = 0;

  // TODO: save cursor to a file
  const firehose = new Firehose({ cursor: process.env.CURSOR ?? "" });

  firehose.on("error", ({ cursor }) => {
    console.log(`Firehose errored on cursor: ${cursor}`);
  });

  firehose.on("open", () => {
    setInterval(() => {
      console.log(`cursor: ${cursorSave}`);
    }, 60000);
  });

  firehose.on("commit", async (commit) => {
    cursorSave = commit.seq;
    commit.ops.forEach(async (op) => {
      if (op.action !== "delete" && AppBskyFeedLike.isRecord(op.record)) {
        if ((op.record.subject.uri ?? "").includes(DID)) {
          if ((op.record.subject.uri ?? "").includes("app.bsky.feed.post")) {
            await label(agent, commit.repo, op.record.subject.uri).catch(
              (err) => console.error(err),
            );
          }
        }
      }
    });
  });

  firehose.start();
};

subscribe();