GitFOSS

// 1st-party
import type { ServiceMethodFactory } from "@ethicdevs/react-monolith";
// generated via script[generate:prisma]
import type { Repository } from "@prisma/client";
// service
import type { CreateRepositoryDTO, RepositoryServiceDeps } from "./types";

const makeCreateRepository: ServiceMethodFactory<
  RepositoryServiceDeps,
  [CreateRepositoryDTO],
  Promise<Repository>
> = ({ request }) => {
  return async ({ parentOrgSlug, repoSlug, repoData, repoInitFlags }) => {
    const {
      gitRepositoryDir,
      withBaseReadmeFile: _,
      withLicenseFile: __,
    } = repoInitFlags;

    const parentOrg = await request.prisma.organization.findUnique({
      where: {
        slug: parentOrgSlug,
      },
    });

    if (parentOrg == null) {
      throw new Error(
        `Could not find the parent organization to create new repository in.`
      );
    }

    console.log(
      `[..] creating repository "${parentOrg.slug}/${repoSlug}" in database`
    );

    const newRepo = await request.prisma.repository.create({
      data: {
        ...repoData,
        organizationId: parentOrg.id,
        slug: repoSlug,
      },
    });

    console.log(
      `[ok] created repository in database with id "${newRepo.id}" and slug "${parentOrg.slug}/${newRepo.slug}"!`
    );

    console.log(
      `[..] creating repository folder with "git init --bare --shared=group"`
    );

    const gitInitBareRepoProcess = request.spawnGitCommand(
      ["init --bare --shared=group"],
      gitRepositoryDir
    );

    const gitInitBareRepoResult = await new Promise<string>((resolve) => {
      let buffer = [] as string[];
      gitInitBareRepoProcess.stdout.on("data", (chunk) => buffer.push(chunk));
      gitInitBareRepoProcess.stdout.on("close", () => {
        resolve(buffer.join(""));
      });
    });

    console.log(
      `[ok] finished execution of "git init --bare --shared=group" with result:\n\t`,
      gitInitBareRepoResult
    );

    return newRepo;
  };
};

export default makeCreateRepository;