delete-old-branches.js

const { octokit } = require('./lib/shared');
const { log, warn, error } = require('./lib/utils');

const getExistingBranches = async () => {
  try {
    const { data } = await octokit.repos.listBranches({
      owner: process.env.JCB_SOURCE_FORK_OWNER,
      repo: process.env.JCB_TARGET_REPO,
      protected: false,
      per_page: 100,
    });

    return data;
  } catch (e) {
    warn('Could not load branches from github', e);
    throw e;
  }
};

const findPullRequest = async (branch) => {
  try {
    const { data } = await octokit.pulls.list({
      owner: process.env.JCB_TARGET_OWNER,
      repo: process.env.JCB_TARGET_REPO,
      head: `${process.env.JCB_SOURCE_FORK_OWNER}:${branch.name}`,
      per_page: 100,
      state: 'all',
    });

    return data;
  } catch (e) {
    warn('Could not load PRs from github', e);
    throw e;
  }
};

const deleteBranch = async (branch) => {
  await octokit.git.deleteRef({
    owner: process.env.JCB_SOURCE_FORK_OWNER,
    repo: process.env.JCB_TARGET_REPO,
    ref: `heads/${branch.name}`,
  });
};

const main = async () => {
  const branches = await getExistingBranches();

  if (branches.length === 0) {
    log('Found no outdated branches');
  }

  for (const branch of branches) {
    const prs = await findPullRequest(branch);

    log(`Checking ${branch.name}`);

    if (prs.length === 0) {
      log(`\tNo PR open for ${branch.name}`);
      continue;
    }

    log(`\tFound ${prs.length} PRs for ${branch.name}`);

    const openPrs = prs.filter((pr) => pr.state === 'open');

    if (openPrs.length === 0) {
      log('\tAll PRs are closed, deleting branch');
      try {
        await deleteBranch(branch);
        log('\tSuccessfully deleted branch');
      } catch (e) {
        error(`\tCould not delete ${branch.name}`, e);
      }
    } else {
      log('\tThe following PRs are still open: ');
      log('\t\t' + openPrs.map((x) => x.html_url).join('\n\t\t'));
    }
  }
};

main().catch((e) => {
  error(e);
  process.exit(1);
});