code-api-web/src/modules/git/Git.service.ts

import {constants} from 'http2';
import * as codeCore from '@modal/code-core';
import {HttpError} from '../../packages/fastify-compliant-http-errors';

export interface GitService {
  createRepo(options: codeCore.git.CreateRepoData, user?: codeCore.common.User): Promise<codeCore.git.Repo>;
  deleteRepo(repoId: codeCore.git.Repo['id'], user?: codeCore.common.User): Promise<void>
}

export class UnauthorizedToCreateRepoError extends HttpError(constants.HTTP_STATUS_UNAUTHORIZED, 'Unauthorized to Create Repo') {}
export class UnauthorizedToDeleteRepoError extends HttpError(constants.HTTP_STATUS_UNAUTHORIZED, 'Unauthorized to Delete Repo') {}
export class UnableToCreateRepoError extends HttpError(constants.HTTP_STATUS_INTERNAL_SERVER_ERROR, 'Unable to Create Repo') {}
export class UnableToDeleteRepoError extends HttpError(constants.HTTP_STATUS_INTERNAL_SERVER_ERROR, 'Unable to Delete Repo') {}

export class GitServiceImpl implements GitService {
  private readonly coreGitService: codeCore.git.GitService;

  constructor() {
    this.coreGitService = new codeCore.git.GitServiceImpl();
  }

  async createRepo(options: codeCore.git.CreateRepoData, user?: codeCore.common.User): Promise<codeCore.git.Repo> {
    if (user) {
      let newRepo: codeCore.git.Repo;
      try {
        newRepo = await this.coreGitService.create(options, user);
      } catch (causeRaw) {
        const cause = causeRaw as Error;
        throw new UnableToCreateRepoError('Something went wrong while creating the repo.', { cause, });
      }
      return newRepo;
    }
    throw new UnauthorizedToCreateRepoError('Could not create repo with insufficient authorization.');
  }

  async deleteRepo(repoId: codeCore.git.Repo['id'], user?: codeCore.common.User): Promise<void> {
    if (user) {
      try {
        await this.coreGitService.delete(repoId, user);
      } catch (causeRaw) {
        const cause = causeRaw as Error;
        throw new UnableToDeleteRepoError('Something went wrong while deleting the repo.', { cause, });
      }
    }
    throw new UnauthorizedToDeleteRepoError('Could not delete repo with insufficient authorization.');
  }
}