action.js

const github = require("@actions/github");
const getOctokit = require("./lib/actions/octokit");

const octokit = getOctokit();

async function getActionParameters() {
  if (
    github.context &&
    github.context.payload &&
    github.context.payload.issue &&
    github.context.payload.issue.number
  ) {
    // this is a issue comment
    console.log(`Getting PR from issue`);
    const {
      issue: { number: issueNumber },
      comment,
      repository: {
        owner: { login: owner },
        name: repo,
      },
    } = github.context.payload;
    console.log(`Found issue ${issueNumber} for ${owner}/${repo}`);
    return { comment, owner, repo, issueNumber };
  } else if (github.context.payload.pull_request) {
    // this is a PR event
    console.log("Getting PR from context");
    const pullRequest = github.context.payload.pull_request;
    return {
      pullRequest,
    };
  } else if (github.context.payload.merge_group) {
    // this is a merge group event
    const { merge_group: mergeGroup } = github.context.payload;
    return {
      mergeGroup,
    };
  }
  return {};
}

const getPullAuthor = (exports.getPullAuthor = (pullRequest) => {
  const {
    user: { login },
  } = pullRequest;
  return login;
});

const getPullDraft = (exports.getPullDraft = (pullRequest) => {
  const { draft } = pullRequest;
  return draft;
});

const getPullNumber = (exports.getPullNumber = (pullRequest) => {
  const { number: pullNumber } = pullRequest;
  return pullNumber;
});

const getPullBase = (exports.getPullBase = (pullRequest) => {
  const {
    base: {
      ref: baseRef,
      repo: {
        owner: { login: owner },
        name: repo,
      },
    },
  } = pullRequest;
  return { baseRef, owner, repo };
});

const getPullRequestedReviewers = (exports.getPullRequestedReviewers = (
  pullRequest
) => {
  const { requested_reviewers: requestedReviewers } = pullRequest;
  return requestedReviewers;
});

const getHasRequestedReview = (exports.getHasRequestedReview = (comments) =>
  comments.some(
    ({ body, user: { login } }) =>
      login === "ms-bot" &&
      body.match(/A review for this PR has been requested in Slack/)
  ));

exports.action = async function action() {
  if (
    github.context &&
    github.context.payload &&
    github.context.payload.issue &&
    github.context.payload.issue.number
  ) {
    return await actionIssue();
  } else if (github.context.payload.pull_request) {
    return await actionPullRequest();
  } else {
    console.log("Not an issue neither a pull request, ignoring");
  }
};

async function getPull({ org, repoName, pullNumber }) {
  return (
    await octokit.rest.pulls.get({
      owner: org,
      repo: repoName,
      pull_number: pullNumber,
    })
  ).data;
}

async function actionIssue() {
  console.info(`Calling action on issue`);
  const { owner, repo, issueNumber, comment } = await getActionParameters();

  if (!getHasRequestedReview([comment])) {
    console.log("This comment is not a message requesting review, ignoring");
    return;
  }

  const pull = await getPull({
    org: owner,
    repoName: repo,
    pullNumber: issueNumber,
  });
  const {
    head: { ref: headRef },
  } = pull;

  const workflowRuns = await octokit.paginate(
    "GET /repos/{owner}/{repo}/actions/runs",
    { owner, repo, branch: headRef }
  );
  const reviewWorkflows = workflowRuns.filter(
    ({ name, event, pull_requests: pullRequests }) =>
      name === "Review Requested" &&
      event === "pull_request" &&
      pullRequests.some(({ number }) => number === issueNumber)
  );
  if (!reviewWorkflows.length) {
    console.log(
      "Review Requested workflow has not yet been run on this repository for this pull request, bailing out"
    );
    return;
  }
  reviewWorkflows.sort(
    ({ run_started_at: runStartedAtA }, { run_started_at: runStartedAtB }) =>
      runStartedAtA >= runStartedAtB
        ? -1
        : runStartedAtA < runStartedAtB
        ? 1
        : 0
  );
  const latestRun = reviewWorkflows[0];
  const { id: runId } = latestRun;
  console.log(`Triggering re-run on ${runId}`);

  await octokit.request(
    "POST /repos/{owner}/{repo}/actions/runs/{run_id}/rerun",
    {
      owner,
      repo,
      run_id: runId,
    }
  );
}

async function actionPullRequest() {
  console.info(`Calling action on pull_request`);
  const { pullRequest } = await getActionParameters();

  const author = getPullAuthor(pullRequest);
  const pullNumber = getPullNumber(pullRequest);
  const draft = getPullDraft(pullRequest);
  const { baseRef, owner, repo } = getPullBase(pullRequest);
  const requestedReviewers = getPullRequestedReviewers(pullRequest);

  const comments = await octokit.paginate(
    "GET /repos/{owner}/{repo}/issues/{issue_number}/comments",
    { owner, repo, issue_number: pullNumber }
  );
  const hasRequestedReview = getHasRequestedReview(comments);

  if (author === "ms-bot" || author === "dependabot[bot]") {
    console.log(
      `Not checking PR ${pullNumber} that has been created by ${author}`
    );
    return;
  }

  if (["main", "master", "preprod", "prod"].indexOf(baseRef) === -1) {
    console.log(
      `Not checking PR ${pullNumber} based on “${baseRef}”, which is an unprotected branch`
    );
    return;
  }

  if (draft) {
    console.log(`Not checking PR ${pullNumber} that is in draft mode`);
    return;
  }

  if (requestedReviewers.length > 0) {
    console.log(
      `PR ${pullNumber} has ${requestedReviewers.length} requested reviewer${
        requestedReviewers.length !== 1 ? "s" : ""
      }, everything is OK`
    );
    return;
  }

  if (hasRequestedReview) {
    console.log(
      `PR ${pullNumber} has been requested review on #mobsuccess-review-requested, everything is OK`
    );
    return;
  }

  throw new Error(
    `PR ${pullNumber} should have its review requested in #mobsuccess-review-requested`
  );
}