import { RepoSubscription } from "./data-plane/subscription.ts";
import { IdResolver, MemoryCache } from "@atp/identity";
import { ServerConfig } from "./config.ts";
import { Database } from "./data-plane/db/index.ts";

const cfg = ServerConfig.readEnv();

const idResolver = new IdResolver({
  plcUrl: cfg.plcUrl,
  didCache: new MemoryCache(),
});
const db = new Database(cfg);
db.connect();

const savedCursor = cfg.debugMode ? null : await db.getCursorState();
const startCursor = savedCursor !== null ? savedCursor : undefined;

const sub = new RepoSubscription({
  cfg,
  db,
  idResolver,
  startCursor,
});

sub.start();
console.info("Subscription started");