lib.js

require("dotenv").config();
const fs = require("fs");
const axiosBase = require("axios");

// Prepare axios for GitLab API
const gitlab = axiosBase.create({
  baseURL: process.env.GITLAB_API_URL,
  headers: {
    "Content-Type": "application/json",
    "PRIVATE-TOKEN": process.env.GITLAB_TOKEN,
  },
  responseType: "json",
});

// Prepare axios for GitHub API
const github = axiosBase.create({
  baseURL: process.env.GITHUB_API_URL,
  headers: {
    "Content-Type": "application/json",
    Authorization: `token ${process.env.GITHUB_TOKEN}`,
  },
  responseType: "json",
});

/**
 * Loads the previously-saved information of the GitHub repos.
 * @param {String} filename File name
 */
function loadReposInfo(filename) {
  try {
    return JSON.parse(fs.readFileSync(filename, "utf8"));
  } catch (error) {
    return []; // fallback
  }
}

/**
 * Saves the current information of the GitHub repos.
 * @param {String} filename File name
 * @param {Object} repos Repos information
 */
function saveReposInfo(filename, repos) {
  fs.writeFileSync(filename, JSON.stringify(repos, null, "  "));
}

async function getGithubReposPage(url) {
  const result = await github.get(url);
  let next = null;
  if (result.headers && result.headers.link) {
    // extract next url from "link" header
    const matches = /\<([^<>]+)\>; rel\="next"/.exec(result.headers.link);
    if (matches) {
      next = matches[1];
    }
  }
  const data =
    (result.data &&
      result.data.length > 0 &&
      result.data.map(({ id, name, updated_at, pushed_at }) => ({
        id,
        name,
        updated_at,
        pushed_at,
      }))) ||
    null;
  return {
    next,
    data,
  };
}

/**
 * Gets a list of repos in GitHub.
 * @param {String} ownerType Resource type of owner (orgs|users)
 * @param {String} owner Owner name
 */
async function getGithubRepos(ownerType, owner) {
  let url = `${ownerType}/${owner}/repos?sort=full_name`;
  const array = [];
  while (url) {
    const { next, data } = await getGithubReposPage(url);
    if (data) array.push(data);
    url = next;
  }
  return array.flat();
}

/**
 * Gets a project in GitLab.
 * @param {String} projectName Name of target project
 */
async function getGitlabProject(projectName) {
  const result = await gitlab.get("projects", {
    params: { search: projectName },
  });
  return result.data.find((x) => x.name === projectName);
}

/**
 * Deletes the project from GitLab.
 * @param {Number} projectId Id of target project
 */
async function deleteGitlabProject(projectId) {
  await gitlab.delete(`projects/${projectId}`);
}

/**
 * Starts to import GitHub repo to GitLab.
 * @param {Number} repoId ID of the GitHub repo
 * @param {String} targetNamespace Namespace in GitLab
 */
async function importFromGithub(repoId, targetNamespace) {
  const data = {
    personal_access_token: process.env.GITHUB_TOKEN,
    repo_id: repoId,
    target_namespace: targetNamespace,
  };
  await gitlab.post("import/github", data);
}

module.exports = {
  loadReposInfo,
  saveReposInfo,
  getGithubRepos,
  getGitlabProject,
  deleteGitlabProject,
  importFromGithub,
};