import { createServerFn } from "@tanstack/react-start";
import { viewerMiddleware } from "./middleware";
import { limitHeavy } from "~/server/limits";
import { requireRepoAccess } from "~/server/repos";
import { syncRefsFromSource } from "~/server/git/ref-sync";
import { badRequest } from "~/server/errors";
import { repoRef } from "~/lib/validation";

export const syncImportedRefs = createServerFn({ method: "POST" })
  .middleware([viewerMiddleware])
  .validator(repoRef)
  .handler(async ({ data, context }) => {
    const { repo } = await requireRepoAccess(data.owner, data.repo, context.viewer, "admin");
    if (!repo.import_source_url) throw badRequest("This repository was not imported");
    if (repo.status !== "ready") throw badRequest("The repository is still being provisioned");
    await limitHeavy(context.viewer);
    return syncRefsFromSource(repo, repo.import_source_url);
  });