dangerfile.js

'use strict';

const { danger, message, warn, fail, markdown } = require('danger');

const { MSK, Apply, K8S, Changelog, Common,
  Infrastructure, Checks } = require("./src/models");

const
  { isInCollection } = require("./src/utils");

let msk = new MSK(danger);
let apply = new Apply(danger);
let k8s = new K8S(danger);
let chg = new Changelog(danger);
let infra = new Infrastructure(danger);
let checks = new Checks(danger);

const repoSlug = danger.gitlab.metadata.repoSlug.toLowerCase();
const web_url = danger.gitlab.mr.web_url;

if (process.env.DANGER_SKIP_REVIEW === "true" || !checks.skipReview()) {
  console.log(`\tMR "${web_url}" review..`);
  let cmn = new Common(danger);
  cmn.run();

  if (isInCollection(repoSlug, ['kafka/msk-topics'])) {
    apply.addManualApplyMsg();
    (async function () {
      await msk.run();
    })();
  }

  if (isInCollection(repoSlug, ['k8s-cluster-config'])) {
    (async function () {
      await chg.changelogNotPresent();
    })();
  }

  if (isInCollection(repoSlug, ['k8s-deploy'])) {
    k8s.k8sDeployTestsAdded();
    chg.changelogNotPresent();
    chg.changelogUnreleased();
  }

  if (isInCollection(repoSlug, ['platform-as-a-service/oauth2-proxy'])) {
    apply.addPaasManualApplyMsg();
  }

  if (isInCollection(repoSlug, ['platform-as-a-service/infrastructure'])) {
    apply.addManualApplyMsg();
    (async function () {
      await infra.run();
    })();
  }

  if (process.env.IS_CI) {
    cmn.welcomeMsg({ url: process.env.CI_JOB_URL });

    (async function () {
      await cmn.addLabels(['review-bot']);
    })();
  }
}