export function setupBuildTrigger()

in github_bot/src/github/events/pull_request/trigger_build.ts [38:132]
54 lines of code
11 McCabe index (conditional complexity)

export function setupBuildTrigger(app: Probot) {
  // @ts-ignore - TS complains here about ctx being too large of a union
  app.on('pull_request', async (ctx) => {
    if (
      !prActionTriggers.has(ctx.payload.action) ||
      !getConfig().github.env.branch.base.some(testPatternString(ctx.payload.pull_request.base.ref))
    ) {
      return;
    }

    console.log(`------- Triggered probot ${ctx.name} | ${ctx.payload.action}`);

    const { head, base, number, labels = [] } = ctx.payload.pull_request;
    const labelCheck = labelCheckFn(labels);

    if (labelCheck('skip')) {
      if (ctx.payload.action === 'labeled') {
        // Try to cancel any running buildkite build for ref
        await buildkiteClient.cancelRunningBuilds(head.sha, async (buildUrl) => {
          await updateAllChecks(
            ctx,
            {
              status: 'completed',
              conclusion: 'skipped',
            },
            buildUrl,
            true,
          );
        });
      } else if (['synchronize', 'opened', 'reopened'].includes(ctx.payload.action)) {
        await updateAllChecks(
          ctx,
          {
            status: 'completed',
            conclusion: 'skipped',
          },
          undefined,
          true,
        );
      }

      return;
    }

    if (!(await isApprovedPR(ctx))) {
      await postIssueComment(ctx, getComment('communityPR'));

      return;
    }

    const builds = await buildkiteClient.getRunningBuilds(head.sha);

    // Already has a running build on latest commit
    if (builds.length > 0) return;

    const { status, data: commit } = await ctx.octokit.repos.getCommit({
      ...ctx.repo(),
      ref: head.sha,
    });
    if (status !== 200) throw new Error('Unable to find commit for ref');

    if (checkCommitFn(commit.commit.message)('skip')) {
      if (checkUserFn(ctx.payload.sender)('bot')) {
        await syncChecks(ctx);
      } else {
        await updateAllChecks(ctx, {
          status: 'completed',
          conclusion: 'skipped',
        });
      }
      return;
    }

    const build = await buildkiteClient.triggerBuild<PullRequestBuildEnv>({
      context: ` - ${ctx.name} | ${ctx.payload.action}`,
      branch: head.label, // <user>:<branch>
      commit: head.sha,
      message: commit.commit.message,
      ignore_pipeline_branch_filters: true,
      pull_request_base_branch: base.ref,
      pull_request_id: number,
      pull_request_repository: head.repo.git_url,
      env: getPRBuildParams(ctx.payload.pull_request, commit),
    });

    await updateAllChecks(
      ctx,
      {
        status: 'queued',
      },
      build.web_url,
      ['labeled', 'unlabeled', 'reopened'].includes(ctx.payload.action),
    );
  });
}