import type { CacheContext } from "@/worker/cache";
import type { PackCatalogRow } from "./types";

import { createLogger, getRepoStub } from "@/worker/common";
import { countSubrequest, getLimiter } from "@/worker/git/operations/limits";
import { ensureMemo, logOnce } from "./support";

export async function loadActivePackCatalog(
  env: Env,
  repoId: string,
  cacheCtx?: CacheContext
): Promise<PackCatalogRow[]> {
  ensureMemo(cacheCtx, repoId);
  const log = createLogger(env.LOG_LEVEL, { service: "PackedObjectStore", repoId });

  if (cacheCtx?.memo?.packCatalog) {
    logOnce(cacheCtx, "packed-catalog-logged", () => {
      log.debug("pack-catalog:loaded", {
        source: "memo",
        packs: cacheCtx.memo?.packCatalog?.length,
      });
    });
    return cacheCtx.memo.packCatalog;
  }
  if (cacheCtx?.memo?.packCatalogPromise) return await cacheCtx.memo.packCatalogPromise;

  const stub = getRepoStub(env, repoId);
  const limiter = getLimiter(cacheCtx);
  const inflight = limiter.run("do:get-active-pack-catalog", async () => {
    if (!countSubrequest(cacheCtx)) {
      logOnce(cacheCtx, "packed-catalog-soft-budget-warned", () => {
        log.warn("soft-budget-exhausted", {
          op: "do:get-active-pack-catalog",
        });
      });
    }
    return await stub.getActivePackCatalog();
  });
  if (cacheCtx?.memo) cacheCtx.memo.packCatalogPromise = inflight;
  try {
    const rows = await inflight;
    if (cacheCtx?.memo) cacheCtx.memo.packCatalog = rows;
    logOnce(cacheCtx, "packed-catalog-logged", () => {
      log.debug("pack-catalog:loaded", { source: "do", packs: rows.length });
    });
    return rows;
  } catch (error) {
    log.warn("pack-catalog:load-error", { error: String(error) });
    throw error;
  } finally {
    if (cacheCtx?.memo) cacheCtx.memo.packCatalogPromise = undefined;
  }
}