GitFOSS

// 1st-party
import type { ServiceMethodFactory } from "@ethicdevs/react-monolith";
import { GitServer } from "@ethicdevs/fastify-git-server";
// app
import { Const } from "../../const";
import { Env } from "../../env";
import { GitServerServiceDeps } from "./types";
import { getEnv } from "../../utils/server";

const toAscii = (str: string) => {
  // replace emoji with nothing
  return (
    str
      // .replace(/[\u{1F600}-\u{1F64F}]/gu, "")
      .replace(
        /[\p{Emoji_Presentation}\p{Extended_Pictographic}\p{Emoji}\uFE0F]/gu,
        "",
      )
  );
};

const makeOnPushEvent: ServiceMethodFactory<
  GitServerServiceDeps,
  [GitServer.Event],
  void
> = ({ request, repoService }) => {
  const env = getEnv();
  return ({ data, message }) => {
    // process message from the push event 0
    message.accept();

    if (data.packType === GitServer.PackType.RECEIVE) {
      // client has done something like "git push" it is uploading
      // server is receiving
      console.log("receive-pack");
      message.write("\n");

      // console.log("git.onPushEvent:", type, data, message);

      // git push:
      // on data.requestType === 'git-receive-pack'
      //  + data.packType === 'receive-pack'
      // - data.payload.commitId  # id of incoming commit
      // - data.payload.refType   # "head" or "tag"
      // - data.payload.refName   # the branch or tag name
      // - data.repoDiskPath      # the path to the repository on disk
      // - data.request.id        # the request id

      // git push --tags:
      // on data.requestType === 'git-receive-pack'
      //  + data.packType === 'receive-pack'
      // - data.payload = null
      // - data.repoDiskPath      # the path to the repository on disk
      // - data.request.id        # the request id

      const [orgSlug, repoSlug] = data.repoSlug.split("/");
      request.prisma.repository
        .findFirst({
          where: {
            slug: repoSlug,
            organization: {
              slug: orgSlug,
            },
          },
        })
        .then(async (repo) => {
          if (repo == null) return Promise.resolve(null);

          try {
            // trigger pipeline run
            const body = {
              repo: `${orgSlug}/${repoSlug}`,
              refType: data.payload!.refType,
              refName: data.payload!.refName,
              commitId: data.payload!.commitId,
              username: data.username,
              gitRepositoryDir: data.repoDiskPath,
              packType: data.packType,
              timestamp: Date.now(),
            };

            const res = await fetch(
              `https://gitfoss.dev/${orgSlug}/${repoSlug}/pipelines/trigger`,
              {
                method: "POST",
                headers: {
                  "Content-Type": "application/json",
                },
                body: JSON.stringify(body),
              },
            );

            console.log(
              `/${orgSlug}/${repoSlug}/pipelines/trigger`,
              body,
              await res.text(),
            );

            if (!res.ok) {
              console.log("could not trigger pipeline run:", res.statusText);
              return;
            }

            const ciManifest = await repoService!.getRepositoryFileContent(
              repo,
              ".gitfoss.ci",
              data.payload!.refName,
            );
            console.log(
              "ci manifest:",
              `${orgSlug}/${repoSlug}` + "/.gitfoss.ci:\n",
              ciManifest,
              data.payload,
            );
          } catch (err) {
            console.log(
              "could not get ci manifest:",
              `${orgSlug}/${repoSlug}`,
              "/.gitfoss.ci",
            );
          }

          const updatedRepo = await request.prisma.repository.update({
            where: {
              id: repo.id,
            },
            data: {
              lastPushedAt: new Date(Date.now()),
            },
          });
          return updatedRepo;
        });

      const repoUrlPrefix = `${Env.DEPLOYMENT_SCHEME}://${Env.DEPLOYMENT_DOMAIN}${Env.DEPLOYMENT_SCHEME !== "https" ? `:${Env.PORT}` : ""}`;
      const repoUrlSuffix = `${orgSlug}/${repoSlug}`;
      const repoUrlBase =
        env === "production"
          ? `${repoUrlPrefix}/${repoUrlSuffix}`
          : `${repoUrlPrefix}:${Env.PORT}/${repoUrlSuffix}`;

      if (data.payload != null) {
        message.write(toAscii(`Hey ${data.username}, welcome back 🖖.\n\n`));
        message.write(toAscii(`📖 See the details of your push at:\n`));
        if (data.payload.refType === "head") {
          message.write(
            toAscii(`🔗 ${repoUrlBase}/show/${data.payload.commitId}\n`),
          );
          if (data.payload.refName !== Const.PRIMARY_BRANCH_REF) {
            message.write(`\n`);
            // todo: if pr already exist, link to it instead of new pr page
            message.write(
              toAscii(
                `🚀 Quickly create a pull-request from this branch at:\n`,
              ),
            );
            message.write(
              toAscii(
                `🔗 ${repoUrlBase}/pulls/new?from_branch=${encodeURIComponent(
                  data.payload.refName,
                )}\n`,
              ),
            );
          }
        } else if (data.payload.refType === "tag") {
          message.write(
            toAscii(
              `🏷 ${repoUrlBase}/tags/${encodeURIComponent(
                data.payload.refName,
              )}\n`,
            ),
          );
        }
      }

      message.write("\n");

      // trigger the continuous integration pipeline
      fetch(`${repoUrlBase}/pipelines/trigger`, {
        method: 'POST',
        body: {},
        // web: {}
      })
        .catch((err) => {
          console.log(`Can not trigger the pipeline: ${err.message}`);
        });
    } else if (data.packType === GitServer.PackType.UPLOAD) {
      // client has done something like "git clone" or "git fetch" or "git pull",
      // it is receiving, server is uploading
      console.log("upload-pack");
      // ⬇️ disabled because it seem to cause issues on git pull. ⬇️
      // message.write(toAscii(`🖖 Welcome at GitFOSS ${data.username}!\n`));

      console.log("upload-pack:", data, message);
    }

    // Finally, accept the payload from client
    // message.accept();
  };
};

export default makeOnPushEvent;