test.js

const { suite } = require("uvu");
const assert = require("uvu/assert");

const nock = require("nock").default;
nock.disableNetConnect();

const {
  Probot,
  ProbotOctokit,
} = require("@probot/adapter-aws-lambda-serverless");

const payloadPrLabeled = {
  loadName: "payloadPrLabeled",
  name: "pull_request",
  id: "1",
  payload: {
    action: "labeled",
    label: {
      name: "emergency"
    },
    repository: {
      owner: {
        login: "robandpdx",
      },
      name: "superbigmono",
      url: "https://api.github.com/repos/robandpdx/superbigmono"
    },
    pull_request: {
      number: 1,
      url: "https://api.github.com/repos/robandpdx/superbigmono/pulls/1",
      html_url: "https://github.com/robandpdx/superbigmono/pull/1",
      merged: false,
      base: {
        repo: {
          allow_merge_commit: true,
          allow_squash_merge: true,
          allow_rebase_merge: true
        }
      }
    },
    organization: {
      login: "robandpdx",
    },
    sender: {
      login: "robandpdx",
    }
  },
}

const payloadPrLabeledByBot = {
  loadName: "payloadPrLabeled",
  name: "pull_request",
  id: "1",
  payload: {
    action: "labeled",
    label: {
      name: "emergency"
    },
    repository: {
      owner: {
        login: "robandpdx",
      },
      name: "superbigmono",
      url: "https://api.github.com/repos/robandpdx/superbigmono"
    },
    pull_request: {
      number: 1,
      url: "https://api.github.com/repos/robandpdx/superbigmono/pulls/1",
      html_url: "https://github.com/robandpdx/superbigmono/pull/1",
      merged: false,
      base: {
        repo: {
          allow_merge_commit: true,
          allow_squash_merge: true,
          allow_rebase_merge: true
        }
      }
    },
    organization: {
      login: "robandpdx",
    },
    sender: {
      login: "emergency-pr[bot]",
    }
  },
}

const payloadPrLabeledByOtherBot = {
  loadName: "payloadPrLabeled",
  name: "pull_request",
  id: "1",
  payload: {
    action: "labeled",
    label: {
      name: "emergency"
    },
    repository: {
      owner: {
        login: "robandpdx",
      },
      name: "superbigmono",
      url: "https://api.github.com/repos/robandpdx/superbigmono"
    },
    pull_request: {
      number: 1,
      url: "https://api.github.com/repos/robandpdx/superbigmono/pulls/1",
      html_url: "https://github.com/robandpdx/superbigmono/pull/1",
      merged: false,
      base: {
        repo: {
          allow_merge_commit: true,
          allow_squash_merge: true,
          allow_rebase_merge: true
        }
      }
    },
    organization: {
      login: "robandpdx",
    },
    sender: {
      login: "dependabot[bot]",
    }
  },
}

const payloadUnlabeled = {
  loadName: "payloadUnlabeled",
  name: "pull_request",
  id: "1",
  payload: {
    action: "unlabeled",
    label: {
      name: "emergency"
    },
    pull_request: {
      number: 1,
      issue_url: "https://api.github.com/repos/robandpdx/superbigmono/issues/1",
      html_url: "https://github.com/robandpdx/superbigmono/pull/1",
    },
    repository: {
      owner: {
        login: "robandpdx",
      },
      name: "superbigmono"
    },
    sender: {
      login: "robandpdx",
    }
  },
}

const payloadUnlabeledByBot = {
  loadName: "payloadUnlabeledByBoy",
  name: "pull_request",
  id: "1",
  payload: {
    action: "unlabeled",
    label: {
      name: "emergency"
    },
    pull_request: {
      number: 1,
      issue_url: "https://api.github.com/repos/robandpdx/superbigmono/issues/1",
      html_url: "https://github.com/robandpdx/superbigmono/pull/1",
    },
    repository: {
      owner: {
        login: "robandpdx",
      },
      name: "superbigmono"
    },
    sender: {
      login: "emergency-pr[bot]",
    }
  },
}

const payloadIssueUnlabeled = {
  loadName: "payloadIssueUnlabeled",
  name: "issues",
  id: "1",
  payload: {
    action: "unlabeled",
    label: {
      name: "emergency"
    },
    issue: {
      url: "https://api.github.com/repos/robandpdx/superbigmono/issues/1",
      html_url: "https://github.com/robandpdx/superbigmono/pull/1",
      number: 1,
    },
    repository: {
      owner: {
        login: "robandpdx",
      },
      name: "superbigmono"
    },
    sender: {
      login: "robandpdx",
    }
  },
}

const payloadIssueUnlabeledByBot = {
  loadName: "payloadIssueUnlabeled",
  name: "issues",
  id: "1",
  payload: {
    action: "unlabeled",
    label: {
      name: "emergency"
    },
    issue: {
      url: "https://api.github.com/repos/robandpdx/superbigmono/issues/1",
      html_url: "https://github.com/robandpdx/superbigmono/pull/1",
      number: 1,
    },
    repository: {
      owner: {
        login: "robandpdx",
      },
      name: "superbigmono"
    },
    sender: {
      login: "emergency-pr[bot]",
    }
  },
}

const payloadPrOpened = {
  loadName: "payloadPrOpened",
  name: "pull_request",
  id: "1",
  payload: {
    action: "opened",
    pull_request: {
      number: 1,
      body: "We need an Emergency landing - this bug is critical!",
      issue_url: "https://api.github.com/repos/robandpdx/superbigmono/issues/1",
      html_url: "https://github.com/robandpdx/superbigmono/pull/1",
    },
    repository: {
      owner: {
        login: "robandpdx",
      },
      name: "superbigmono"
    },
    organization: {
      login: "robandpdx",
    },
    sender: {
      login: "robandpdx",
    }
  }
}

const payloadPrComment = {
  loadName: "payloadPrComment",
  name: "issue_comment",
  id: "1",
  payload: {
    action: "created",
    issue: {
      url:  "https://api.github.com/repos/robandpdx/superbigmono/issues/1",
      pull_request: {
        html_url: "https://github.com/robandpdx/superbigmono/pull/1"
      },
      number: 1,
    },
    comment: {
      body: "We need an Emergency landing - this bug is critical!"
    },
    pull_request: {
      number: 1,
    },
    repository: {
      owner: {
        login: "robandpdx",
      },
      name: "superbigmono"
    },
    organization: {
      login: "robandpdx",
    },
    sender: {
      login: "robandpdx",
    }
  }
}

const payloadMembershipResponse = {
  "url": "https://api.github.com/teams/1/memberships/robandpdx",
  "role": "maintainer",
  "state": "active"
}

const payloadNonMembershipResponse = {
  "url": "https://api.github.com/teams/1/memberships/robandpdx",
  "role": "member",
  "state": "inactive"
}

// Unset EMERGENCY_LABEL before requiring ./app so the module-level
// `process.env.EMERGENCY_LABEL || 'emergency'` fallback branch is exercised.
// All tests use the literal 'emergency' value anyway, so behavior is unchanged.
delete process.env.EMERGENCY_LABEL;
const app = require("./app");

/** @type {import('probot').Probot */
let probot;
const test = suite("app");
test.before.each(() => {
  process.env.ISSUE_TITLE = 'Emergency PR Audit';
  process.env.ISSUE_BODY_FILE = 'issueBody.md';
  process.env.ISSUE_ASSIGNEES = 'tonyclifton,andykaufman';
  process.env.EMERGENCY_LABEL = 'emergency';
  process.env.TRIGGER_STRING = 'emergency landing';
  process.env.SLACK_SIGNING_SECRET="fake-signing-secret";
  process.env.SLACK_BOT_TOKEN="xoxb-fake-bot-token";
  process.env.SLACK_CHANNEL_ID="fake-channel-id";

  probot = new Probot({
    // simple authentication as alternative to appId/privateKey
    githubToken: "test",
    // disable logs
    logLevel: "warn",
    // disable request throttling and retries
    Octokit: ProbotOctokit.defaults({
      throttle: { enabled: false },
      retry: { enabled: false },
      request: {
        headers: {
          "X-GitHub-Api-Version": "2026-03-10",
        },
      },
    }),
  });
  probot.load(app);
});

test.after.each(() => {
  nock.cleanAll();
  delete process.env.APPROVE_PR;
  delete process.env.CREATE_ISSUE;
  delete process.env.MERGE_PR;
  delete process.env.SLACK_NOTIFY;
  delete process.env.SLACK_MESSAGE_FILE;
  delete process.env.EMERGENCY_LABEL_PERMANENT;
  delete process.env.AUTHORIZED_TEAM;
  payloadPrLabeled.payload.pull_request.base.repo.allow_merge_commit = true;
  payloadPrLabeled.payload.pull_request.base.repo.allow_squash_merge = true;
});

// This test sends a payload that is not an emergency label
test("receives pull_request.labeled event, does nothing because not emergency label", async function () {
  delete process.env.AUTHORIZED_TEAM;
  await probot.receive({
    name: "pull_request",
    id: "1",
    payload: {
      action: "labeled",
      label: {
        name: "other"
      },
      organization: {
        login: 'robandpdx'
      },
      sender: { 
        login: 'robandpdx'
      }
    },
  });
});

// This test will do all 4 things: approve, create issue, merge, and send slack notification
test("receives pull_request.labeled event, approve, create issue, merge, slack notify", async function () {
  process.env.APPROVE_PR = 'true';
  process.env.CREATE_ISSUE = 'true';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'true';
  process.env.SLACK_MESSAGE_FILE = 'slackMessage.txt';
  
  // mock the request to add approval to the pr
  const mock = nock("https://api.github.com")
    .post(
      "/repos/robandpdx/superbigmono/pulls/1/reviews",
      (requestBody) => {
        checkApprovalRequest(requestBody);
        return true;
      }
    )
    .reply(200);
  // mock the request to create the an issue
  mock.post("/repos/robandpdx/superbigmono/issues",
    (requestBody) => {
      checkIssueRequest(requestBody);
      return true;
    }
  ).reply(200, {
    html_url: "https://github.com/robandpdx/superbigmono/issues/44",
  });
  // mock the request to merge the pr
  mock.put("/repos/robandpdx/superbigmono/pulls/1/merge").reply(200);
  // mock the request to send the slack notification
  const mockSlack = nock("https://slack.com")
    .post("/api/chat.postMessage",
    (requestBody) => {
      //console.log(requestBody);
      checkSlackNotifyRequest(requestBody);
      return true;
    }
    ).reply(200, {
      ok: true,
      channel: "C1H9RESGL",
      ts: "1503435956.000247",
      message: {
          text: "Here's a message for you",
          username: "ecto1",
          bot_id: "B19LU7CSY",
          attachments: [
              {
                  text: "This is an attachment",
                  id: 1,
                  fallback: "This is an attachment's fallback"
              }
          ],
          type: "message",
          subtype: "bot_message",
          ts: "1503435956.000247"
      }
    });

  await probot.receive(payloadPrLabeled);
  assert.equal(mock.pendingMocks(), []);
  assert.equal(mockSlack.pendingMocks(), []);
});

// This test will only approve the PR
test("receives pull_request.labeled event, approve PR", async function () {
  process.env.APPROVE_PR = 'true';
  process.env.CREATE_ISSUE = 'false';
  process.env.MERGE_PR = 'false';
  process.env.SLACK_NOTIFY = 'false';

  // mock the request to add approval to the pr
  const mock = nock("https://api.github.com")
    .post(
      "/repos/robandpdx/superbigmono/pulls/1/reviews",
      (requestBody) => {
        //console.log(requestBody);
        checkApprovalRequest(requestBody);
        return true;
      }
    )
    .reply(200);

  await probot.receive(payloadPrLabeled);
  assert.equal(mock.pendingMocks(), []);
});

// This test will only create an issue
test("receives pull_request.labeled event, create issue", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'true';
  process.env.MERGE_PR = 'false';
  process.env.SLACK_NOTIFY = 'false';

  // mock the request to create the an issue
  const mock = nock("https://api.github.com")
    .post("/repos/robandpdx/superbigmono/issues",
      (requestBody) => {
        checkIssueRequest(requestBody);
        return true;
      }
    )
    .reply(200);

  await probot.receive(payloadPrLabeled);
  assert.equal(mock.pendingMocks(), []);
});

// This test will only create an issue without assingees
test("receives pull_request.labeled event, create issue no assignees", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'true';
  process.env.MERGE_PR = 'false';
  process.env.SLACK_NOTIFY = 'false';
  delete process.env.ISSUE_ASSIGNEES

  // mock the request to create the an issue
  const mock = nock("https://api.github.com")
    .post("/repos/robandpdx/superbigmono/issues",
      (requestBody) => {
        checkIssueNoAssigneesRequest(requestBody);
        return true;
      }
    )
    .reply(200);

  await probot.receive(payloadPrLabeled);
  assert.equal(mock.pendingMocks(), []);
});

// This test will only merge the PR
test("receives pull_request.labeled event, merge the PR", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'false';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'false';
  
  // mock the request to add approval to the pr
  const mock = nock("https://api.github.com")
    .put("/repos/robandpdx/superbigmono/pulls/1/merge",
      (requestBody) => {
        assert.equal(requestBody.merge_method, "merge");
        return true;
    }
  ).reply(200);

  await probot.receive(payloadPrLabeled);
  assert.equal(mock.pendingMocks(), []);
});

// This test will only merge the PR, using squash merge
test("receives pull_request.labeled event, squash merge the PR", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'false';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'false';
  payloadPrLabeled.payload.pull_request.base.repo.allow_merge_commit = false;
  
  // mock the request to add approval to the pr
  const mock = nock("https://api.github.com")
    .put("/repos/robandpdx/superbigmono/pulls/1/merge",
      (requestBody) => {
        assert.equal(requestBody.merge_method, "squash");
        return true;
      }
    ).reply(200);
    

  await probot.receive(payloadPrLabeled);
  assert.equal(mock.pendingMocks(), []);
});

// This test will only merge the PR, using rebase merge
test("receives pull_request.labeled event, rebase merge the PR", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'false';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'false';
  payloadPrLabeled.payload.pull_request.base.repo.allow_merge_commit = false;
  payloadPrLabeled.payload.pull_request.base.repo.allow_squash_merge = false;
  
  // mock the request to add approval to the pr
  const mock = nock("https://api.github.com")
    .put("/repos/robandpdx/superbigmono/pulls/1/merge",
      (requestBody) => {
        assert.equal(requestBody.merge_method, "rebase");
        return true;
      }
    ).reply(200);

  await probot.receive(payloadPrLabeled);
  assert.equal(mock.pendingMocks(), []);
});

// This test will merge the PR because the user is a member of the emergency team
test("receives pull_request.labeled event, check team membership, merge the PR", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'false';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'false';
  process.env.AUTHORIZED_TEAM = 'emergency-team'
  
  // mock the request to add approval to the pr
  const mock = nock("https://api.github.com")
    .put("/repos/robandpdx/superbigmono/pulls/1/merge").reply(200);

  // mock the request to check if the user is a member of the emergency team
  mock.get("/orgs/robandpdx/teams/emergency-team/memberships/robandpdx")
    .query({ org: "robandpdx", team_slug: "emergency-team", username: "robandpdx" })
  .reply(200, payloadMembershipResponse);

  await probot.receive(payloadPrLabeled);
  assert.equal(mock.pendingMocks(), []);
});

// This test will merge the PR because the label was applied by this app's own bot,
// which the app self-detects via GET /app.
test("receives pull_request.labeled event from a bot, merge the PR", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'false';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'false';
  process.env.AUTHORIZED_TEAM = 'emergency-team'

  // mock the GitHub App self-introspection used to detect this app's bot login
  const mock = nock("https://api.github.com")
    .get("/app").reply(200, { slug: "emergency-pr" })
    .put("/repos/robandpdx/superbigmono/pulls/1/merge").reply(200);

  await probot.receive(payloadPrLabeledByBot);
  assert.equal(mock.pendingMocks(), []);
});

// Two bot-triggered events in the same test exercise the cached path of
// getAppBotLogin: the first event populates cachedAppBotLogin via GET /app,
// the second hits the `cachedAppBotLogin !== undefined` early-return branch
// and must NOT call GET /app again.
test("receives pull_request.labeled event from a bot twice, second call uses cached app bot login", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'false';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'false';
  process.env.AUTHORIZED_TEAM = 'emergency-team'

  // First event: self-introspection happens once and PR is merged.
  const mock = nock("https://api.github.com")
    .get("/app").reply(200, { slug: "emergency-pr" })
    .put("/repos/robandpdx/superbigmono/pulls/1/merge").reply(200);

  await probot.receive(payloadPrLabeledByBot);
  assert.equal(mock.pendingMocks(), []);

  // Second event: cachedAppBotLogin is already set, so GET /app must NOT be
  // called. Only the merge mock is registered; if the code re-introspects,
  // nock will throw "Nock: No match for request" on GET /app.
  const mock2 = nock("https://api.github.com")
    .put("/repos/robandpdx/superbigmono/pulls/1/merge").reply(200);

  await probot.receive(payloadPrLabeledByBot);
  assert.equal(mock2.pendingMocks(), []);
});

// This test will not merge the PR because the sender is a bot but not this app's
// own bot. External bots cannot be allowlisted (GitHub teams cannot contain bot
// identities), so the team-membership check returns 404 and the bot is rejected.
test("receives pull_request.labeled event from a non-app bot, do not merge the PR", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'false';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'false';
  process.env.AUTHORIZED_TEAM = 'emergency-team'

  const mock = nock("https://api.github.com")
    // mock self-introspection — the detected bot login differs from the sender
    .get("/app").reply(200, { slug: "emergency-pr" })
    // mock the membership check returning 404 — the bot is not on the team
    .get("/orgs/robandpdx/teams/emergency-team/memberships/dependabot[bot]")
    .query({ org: "robandpdx", team_slug: "emergency-team", username: "dependabot[bot]" })
      .reply(404);

  // mock the unauthorized comment
  mock.post("/repos/robandpdx/superbigmono/issues/1/comments",
    (requestBody) => {
      assert.equal(requestBody.body, "@dependabot[bot] is not authorized to apply the emergency label.");
      return true;
    }
  ).reply(200);

  // mock the label removal
  mock.delete("/repos/robandpdx/superbigmono/issues/1/labels/emergency",
    (requestBody) => {
      return true;
    }
  ).reply(200);

  await probot.receive(payloadPrLabeledByOtherBot);
  assert.equal(mock.pendingMocks(), []);
});

// This test confirms that if self-introspection (GET /app) fails, the app fails
// safe: no bots bypass authorization. The bot then has to pass the team check.
test("receives pull_request.labeled event from a bot when self-introspection fails, do not merge the PR", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'false';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'false';
  process.env.AUTHORIZED_TEAM = 'emergency-team'

  const mock = nock("https://api.github.com")
    // self-introspection fails
    .get("/app").reply(500)
    // membership check returns 404 — the bot is not on the team
    .get("/orgs/robandpdx/teams/emergency-team/memberships/dependabot[bot]")
    .query({ org: "robandpdx", team_slug: "emergency-team", username: "dependabot[bot]" })
      .reply(404);

  mock.post("/repos/robandpdx/superbigmono/issues/1/comments",
    (requestBody) => {
      assert.equal(requestBody.body, "@dependabot[bot] is not authorized to apply the emergency label.");
      return true;
    }
  ).reply(200);

  mock.delete("/repos/robandpdx/superbigmono/issues/1/labels/emergency",
    (requestBody) => {
      return true;
    }
  ).reply(200);

  await probot.receive(payloadPrLabeledByOtherBot);
  assert.equal(mock.pendingMocks(), []);
});

// This test will not merge the PR because the user is not a member of the emergency team
test("receives pull_request.labeled event, check non team membership, do not merge the PR", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'false';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'false';
  process.env.AUTHORIZED_TEAM = 'emergency-team'
  
  // mock the request to check if the user is a member of the emergency team
  const mock = nock("https://api.github.com")
    .get("/orgs/robandpdx/teams/emergency-team/memberships/robandpdx")
    .query({ org: "robandpdx", team_slug: "emergency-team", username: "robandpdx" })
      .reply(200, payloadNonMembershipResponse);

  // mock the request to create the issue comment
  mock.post("/repos/robandpdx/superbigmono/issues/1/comments",
    (requestBody) => {
      assert.equal(requestBody.body, "@robandpdx is not authorized to apply the emergency label.");
      return true;
    }
  ).reply(200);

  // mock the request to delete the label
  mock.delete("/repos/robandpdx/superbigmono/issues/1/labels/emergency",
    (requestBody) => {
      return true;
    }
  ).reply(200);

  await probot.receive(payloadPrLabeled);
  assert.equal(mock.pendingMocks(), []);
});

// This test will not merge the PR because non team membership
test("receives pull_request.labeled event, non team membership, do not merge the PR", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'false';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'false';
  process.env.AUTHORIZED_TEAM = 'emergency-team'
  
  // mock the request to check if the user is a member of the emergency team
  const mock = nock("https://api.github.com")
    .get("/orgs/robandpdx/teams/emergency-team/memberships/robandpdx")
    .query({ org: "robandpdx", team_slug: "emergency-team", username: "robandpdx" })
      .reply(404);

  // mock the request to create the issue comment
  mock.post("/repos/robandpdx/superbigmono/issues/1/comments",
    (requestBody) => {
      assert.equal(requestBody.body, "@robandpdx is not authorized to apply the emergency label.");
      return true;
    }
  ).reply(200);

  // mock the request to delete the label
  mock.delete("/repos/robandpdx/superbigmono/issues/1/labels/emergency",
    (requestBody) => {
      return true;
    }
  ).reply(200);

  await probot.receive(payloadPrLabeled);
  assert.equal(mock.pendingMocks(), []);
});

// This test will only slack notify
test("receives pull_request.labeled event, slack notify", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'false';
  process.env.MERGE_PR = 'false';
  process.env.SLACK_NOTIFY = 'true';
  process.env.SLACK_MESSAGE_FILE = 'slackMessageNoIssue.txt';
  
  // mock the request to send the slack notification
  const mockSlack = nock("https://slack.com")
    .post("/api/chat.postMessage",
    (requestBody) => {
      //console.log(requestBody);
      checkSlackNotifyRequestNoIssue(requestBody);
      return true;
    }
    ).reply(200, {
      ok: true,
      channel: "C1H9RESGL",
      ts: "1503435956.000247",
      message: {
          text: "Here's a message for you",
          username: "ecto1",
          bot_id: "B19LU7CSY",
          attachments: [
              {
                  text: "This is an attachment",
                  id: 1,
                  fallback: "This is an attachment's fallback"
              }
          ],
          type: "message",
          subtype: "bot_message",
          ts: "1503435956.000247"
      }
    });

  await probot.receive(payloadPrLabeled);
  assert.equal(mockSlack.pendingMocks(), []);
});

// This test will only slack notify (fail)
test("receives pull_request.labeled event, slack notify (fail)", async function () {
  process.env.APPROVE_PR = 'false';
  process.env.CREATE_ISSUE = 'false';
  process.env.MERGE_PR = 'false';
  process.env.SLACK_NOTIFY = 'true';
  process.env.SLACK_MESSAGE_FILE = 'slackMessageNoIssue.txt';
  process.env.SLACK_RETYRY_CONFIG = '0';
  
  // mock the request to send the slack notification
  const mockSlack = nock("https://slack.com")
    .post("/api/chat.postMessage",
    (requestBody) => {
      //console.log(requestBody);
      checkSlackNotifyRequestNoIssue(requestBody);
      return true;
    }
    ).reply(500);

    try {
      await probot.receive(payloadPrLabeled);
    } catch (err) {
      assert.equal(mockSlack.pendingMocks(), []);
      assert.equal(err.errors[0][0].message, "An HTTP protocol error occurred: statusCode = 500");
      assert.equal(err.errors[0].length, 1);
      return;
    }
});

// This test will do 3 things: approve, create issue, merge, but the appoval will fail
test("receives pull_request.labeled event, approve (fails), create issue, merge", async function () {
  process.env.APPROVE_PR = 'true';
  process.env.CREATE_ISSUE = 'true';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'false';
  
  // mock the request to add approval to the pr
  const mock = nock("https://api.github.com")
    .post(
      "/repos/robandpdx/superbigmono/pulls/1/reviews",
      (requestBody) => {
        checkApprovalRequest(requestBody);
        return true;
      }
    )
    .replyWithError('something awful happened');
  // mock the request to create the an issue
  mock.post("/repos/robandpdx/superbigmono/issues",
    (requestBody) => {
      checkIssueRequest(requestBody);
      return true;
    }
  ).reply(200);
  // mock the request to merge the pr
  mock.put("/repos/robandpdx/superbigmono/pulls/1/merge").reply(200);

  try {
    await probot.receive(payloadPrLabeled);
  } catch (err) {
    assert.equal(mock.pendingMocks(), []);
    assert.equal(err.errors[0][0].message, "something awful happened");
    assert.equal(err.errors[0].length, 1);
    return;
  }
});

// This test will do 3 things: approve, create issue, merge, but creating the issue will fail
test("receives pull_request.labeled event, approve, create issue (fails), merge", async function () {
  process.env.APPROVE_PR = 'true';
  process.env.CREATE_ISSUE = 'true';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'false';
  
  // mock the request to add approval to the pr
  const mock = nock("https://api.github.com")
    .post(
      "/repos/robandpdx/superbigmono/pulls/1/reviews",
      (requestBody) => {
        checkApprovalRequest(requestBody);
        return true;
      }
    )
    .reply(200);
  // mock the request to create the an issue
  mock.post("/repos/robandpdx/superbigmono/issues",
    (requestBody) => {
      checkIssueRequest(requestBody);
      return true;
    }
  ).replyWithError('something awful happened');
  // mock the request to merge the pr
  mock.put("/repos/robandpdx/superbigmono/pulls/1/merge").reply(200);

  try {
    await probot.receive(payloadPrLabeled);
  } catch (err) {
    assert.equal(mock.pendingMocks(), []);
    assert.equal(err.errors[0][0].message, "something awful happened");
    assert.equal(err.errors[0].length, 1);
    return;
  }
});

// This test will do 3 things: approve, create issue, merge, but merging the PR will fail
test("receives pull_request.labeled event, approve, create issue, merge (fails)", async function () {
  process.env.APPROVE_PR = 'true';
  process.env.CREATE_ISSUE = 'true';
  process.env.MERGE_PR = 'true';
  process.env.SLACK_NOTIFY = 'false';
  
  // mock the request to add approval to the pr
  const mock = nock("https://api.github.com")
    .post(
      "/repos/robandpdx/superbigmono/pulls/1/reviews",
      (requestBody) => {
        checkApprovalRequest(requestBody);
        return true;
      }
    )
    .reply(200);
  // mock the request to create the an issue
  mock.post("/repos/robandpdx/superbigmono/issues",
    (requestBody) => {
      checkIssueRequest(requestBody);
      return true;
    }
  ).reply(200);
  // mock the request to merge the pr
  mock.put("/repos/robandpdx/superbigmono/pulls/1/merge").replyWithError('something awful happened')

  try {
    await probot.receive(payloadPrLabeled);
  } catch (err) {
    assert.equal(mock.pendingMocks(), []);
    assert.equal(err.errors[0][0].message, "something awful happened");
    assert.equal(err.errors[0].length, 1);
    return;
  }
});

// This test will reapply the emergency label to a PR
test("receives pull_request.unlabeled event, reapply emergency label", async function () {
  process.env.EMERGENCY_LABEL_PERMANENT = 'true';
  // mock the request to reapply the emergency label
  const mock = nock("https://api.github.com")
    .post("/repos/robandpdx/superbigmono/issues/1/labels",
      (requestBody) => {
        assert.equal(requestBody.labels[0], "emergency");
        return true;
      }
    )
    .reply(200);

  await probot.receive(payloadUnlabeled);
  assert.equal(mock.pendingMocks(), []);
});

// This test will not reapply the emergency label to a PR if removed by bot
test("receives pull_request.unlabeled event from bot user, do not reapply emergency label", async function () {
  process.env.EMERGENCY_LABEL_PERMANENT = 'true';

  await probot.receive(payloadUnlabeledByBot);
});

// This test will fail to reapply the emergency label to a PR
test("receives pull_request.unlabeled event, fail to reapply emergency label", async function () {
  process.env.EMERGENCY_LABEL_PERMANENT = 'true';
  // mock the request to reapply the emergency label
  const mock = nock("https://api.github.com")
    .post("/repos/robandpdx/superbigmono/issues/1/labels",
      (requestBody) => {
        assert.equal(requestBody.labels[0], "emergency");
        return true;
      }
    )
    .replyWithError('something awful happened');

  try {
    await probot.receive(payloadUnlabeled);
  } catch (err) {
    assert.equal(mock.pendingMocks(), []);
    assert.equal(err.errors[0][0].message, "something awful happened");
    assert.equal(err.errors[0].length, 1);
    return;
  }
  assert.equal(mock.pendingMocks(), []);
});

// This test will not reapply the emergency label to a PR
test("receives pull_request.unlabeled event, don't emergency label", async function () {
  delete process.env.EMERGENCY_LABEL_PERMANENT;
  process.env.EMERGENCY_LABEL_PERMANENT = 'false';
  await probot.receive(payloadUnlabeled);
});

// This test will reapply the emergency label to an issue
test("receives issue.unlabeled event, reapply emergency label", async function () {
  process.env.EMERGENCY_LABEL_PERMANENT = 'true';
  // mock the request to reapply the emergency label
  const mock = nock("https://api.github.com")
    .post("/repos/robandpdx/superbigmono/issues/1/labels",
      (requestBody) => {
        assert.equal(requestBody.labels[0], "emergency");
        return true;
      }
    )
    .reply(200);

  await probot.receive(payloadIssueUnlabeled);
  assert.equal(mock.pendingMocks(), []);
});

// This test will not reapply the emergency label to an issue if removed by bot
test("receives issue.unlabeled event from bot, do not reapply emergency label", async function () {
  process.env.EMERGENCY_LABEL_PERMANENT = 'true';

  await probot.receive(payloadIssueUnlabeledByBot);
});

// This test will fail to reapply the emergency label to an issue
test("receives issue.unlabeled event, fail to reapply emergency label", async function () {
  process.env.EMERGENCY_LABEL_PERMANENT = 'true';
  // mock the request to reapply the emergency label
  const mock = nock("https://api.github.com")
    .post("/repos/robandpdx/superbigmono/issues/1/labels",
      (requestBody) => {
        assert.equal(requestBody.labels[0], "emergency");
        return true;
      }
    )
    .replyWithError('something awful happened');

  try {
    await probot.receive(payloadIssueUnlabeled);
  } catch (err) {
    assert.equal(mock.pendingMocks(), []);
    assert.equal(err.errors[0][0].message, "something awful happened");
    assert.equal(err.errors[0].length, 1);
    return;
  }
  assert.equal(mock.pendingMocks(), []);
});

// This test will not reapply the emergency label to an issue
test("receives pull_request.unlabeled event, dont't emergency label", async function () {
  delete process.env.EMERGENCY_LABEL_PERMANENT;
  process.env.EMERGENCY_LABEL_PERMANENT = 'false';
  await probot.receive(payloadIssueUnlabeled);
});

// This test will apply the emergency label based on the PR contents
test("receives pull_request.opened event, applies emergency label", async function () {
  // mock the request to apply the emergency label
  const mock = nock("https://api.github.com")
    .post("/repos/robandpdx/superbigmono/issues/1/labels",
      (requestBody) => {
        assert.equal(requestBody.labels[0], "emergency");
        return true;
      }
    )
    .reply(200);

  await probot.receive(payloadPrOpened);
  assert.equal(mock.pendingMocks(), []);
});

// This test will apply the emergency label based on the PR contents checking team membership
test("receives pull_request.opened event, applies emergency label checking team membership", async function () {
  process.env.AUTHORIZED_TEAM = 'emergency-team'

  // mock the request to apply the emergency label
  const mock = nock("https://api.github.com")
    .post("/repos/robandpdx/superbigmono/issues/1/labels",
      (requestBody) => {
        if (!requestBody?.labels) return false;
        assert.equal(requestBody.labels[0], "emergency");
        return true;
      }
    )
    .reply(200);

  // mock the request to check if the user is a member of the emergency team
  mock.get("/orgs/robandpdx/teams/emergency-team/memberships/robandpdx")
    .query({ org: "robandpdx", team_slug: "emergency-team", username: "robandpdx" })
  .reply(200, payloadMembershipResponse);

  await probot.receive(payloadPrOpened);
  assert.equal(mock.pendingMocks(), []);
});

// This test will not apply the emergency label due to non team membership
test("receives pull_request.opened event, does not apply emergency label due to non team membership", async function () {
  process.env.AUTHORIZED_TEAM = 'emergency-team'

  // mock the request to apply the emergency label
  const mock = nock("https://api.github.com")
    .get("/orgs/robandpdx/teams/emergency-team/memberships/robandpdx")
    .query({ org: "robandpdx", team_slug: "emergency-team", username: "robandpdx" })
      .reply(200, payloadNonMembershipResponse);

  // mock the request to create the issue comment
  mock.post("/repos/robandpdx/superbigmono/issues/1/comments",
    (requestBody) => {
      assert.equal(requestBody.body, "@robandpdx is not authorized to apply the emergency label.");
      return true;
    }
  ).reply(200);

  await probot.receive(payloadPrOpened);
  assert.equal(mock.pendingMocks(), []);
});

// This test will fail to apply the emergency label based on the PR contents
test("receives pull_request.opened event, fails to apply emergency label", async function () {
  // mock the request to apply the emergency label
  const mock = nock("https://api.github.com")
    .post("/repos/robandpdx/superbigmono/issues/1/labels",
      (requestBody) => {
        assert.equal(requestBody.labels[0], "emergency");
        return true;
      }
    )
    .replyWithError('something awful happened');

    try {
      await probot.receive(payloadPrOpened);
    } catch (err) {
      assert.equal(mock.pendingMocks(), []);
      assert.equal(err.errors[0][0].message, "something awful happened");
      assert.equal(err.errors[0].length, 1);
      return;
    }
});

// This test will not reapply the emergency label because the TRIGGER_STRING is not found
test("receives pull_request.unlabeled event, dont't emergency label", async function () {
  delete process.env.TRIGGER_STRING;
  await probot.receive(payloadPrOpened);
});

// This test will apply the emergency label based on the contents of a comment on the PR
test("receives issue_comment.created event, applies emergency label", async function () {
  // mock the request to apply the emergency label
  const mock = nock("https://api.github.com")
    .post("/repos/robandpdx/superbigmono/issues/1/labels",
      (requestBody) => {
        assert.equal(requestBody.labels[0], "emergency");
        return true;
      }
    )
    .reply(200);

  await probot.receive(payloadPrComment);
  assert.equal(mock.pendingMocks(), []);
});

// This test will apply the emergency label based on the contents of a comment on the PR, checking team membership
test("receives issue_comment.created event, applies emergency label", async function () {
  process.env.AUTHORIZED_TEAM = 'emergency-team'

  // mock the request to apply the emergency label
  const mock = nock("https://api.github.com")
    .post("/repos/robandpdx/superbigmono/issues/1/labels",
      (requestBody) => {
        if (!requestBody?.labels) return false;
        assert.equal(requestBody.labels[0], "emergency");
        return true;
      }
    )
    .reply(200);

  // mock the request to check if the user is a member of the emergency team
  mock.get("/orgs/robandpdx/teams/emergency-team/memberships/robandpdx")
    .query({ org: "robandpdx", team_slug: "emergency-team", username: "robandpdx" })
  .reply(200, payloadMembershipResponse);

  await probot.receive(payloadPrComment);
  assert.equal(mock.pendingMocks(), []);
});

// This test will not apply the emergency label due to non team membership and comment
test("receives issue_comment.created event, does not apply emergency label due to non membership", async function () {
  process.env.AUTHORIZED_TEAM = 'emergency-team'

  // mock the request to apply the emergency label
  const mock = nock("https://api.github.com")
    .get("/orgs/robandpdx/teams/emergency-team/memberships/robandpdx")
    .query({ org: "robandpdx", team_slug: "emergency-team", username: "robandpdx" })
      .reply(200, payloadNonMembershipResponse);

  // mock the request to create the issue comment
  mock.post("/repos/robandpdx/superbigmono/issues/1/comments",
    (requestBody) => {
      assert.equal(requestBody.body, "@robandpdx is not authorized to apply the emergency label.");
      return true;
    }
  ).reply(200);

  await probot.receive(payloadPrComment);
  assert.equal(mock.pendingMocks(), []);
});

// This test will not apply the emergency label due failed membership check
test("receives issue_comment.created event, does not apply emergency label due to failed membership check", async function () {
  process.env.AUTHORIZED_TEAM = 'emergency-team'

  // mock the request to apply the emergency label
  const mock = nock("https://api.github.com")
    .get("/orgs/robandpdx/teams/emergency-team/memberships/robandpdx")
    .query({ org: "robandpdx", team_slug: "emergency-team", username: "robandpdx" })
      .reply(500);

  try {
    await probot.receive(payloadPrComment);
  } catch (err) {
    assert.equal(mock.pendingMocks(), []);
    assert.equal(err.errors[0].message, "Error checking membership");
  }
});

// This test will not apply the emergency label due to non team membership, fail to comment
test("receives issue_comment.created event, does not applies emergency label, fail to comment", async function () {
  process.env.AUTHORIZED_TEAM = 'emergency-team'

  // mock the request to apply the emergency label
  const mock = nock("https://api.github.com")
    .get("/orgs/robandpdx/teams/emergency-team/memberships/robandpdx")
    .query({ org: "robandpdx", team_slug: "emergency-team", username: "robandpdx" })
      .reply(200, payloadNonMembershipResponse);

  // mock the request to create the issue comment
  mock.post("/repos/robandpdx/superbigmono/issues/1/comments",
    (requestBody) => {
      assert.equal(requestBody.body, "@robandpdx is not authorized to apply the emergency label.");
      return true;
    }
  ).reply(404);
  
  try {
    await probot.receive(payloadPrComment);
  } catch (err) {
    assert.equal(mock.pendingMocks(), []);
    assert.equal(err.errors.length, 1);
  }
  assert.equal(mock.pendingMocks(), []);
});

// This test will fail to apply the emergency label based on the contents of a comment on the PR
test("receives issue_comment.created event, failes to apply emergency label", async function () {
  // mock the request to apply the emergency label
  const mock = nock("https://api.github.com")
    .post("/repos/robandpdx/superbigmono/issues/1/labels",
      (requestBody) => {
        assert.equal(requestBody.labels[0], "emergency");
        return true;
      }
    )
    .replyWithError('something awful happened');

    try {
      await probot.receive(payloadPrComment);
    } catch (err) {
      assert.equal(mock.pendingMocks(), []);
      assert.equal(err.errors[0][0].message, "something awful happened");
      assert.equal(err.errors[0].length, 1);
      return;
    }
});

// This test will not reapply the emergency label because the TRIGGER_STRING is not found
test("receives issue_comment.created event, dont't emergency label", async function () {
  delete process.env.TRIGGER_STRING;
  await probot.receive(payloadPrComment);
});

// This test exercises the else-if "false" decision branch when the PR body
// does not contain the trigger string (TRIGGER_STRING is set).
test("receives pull_request.opened event, does nothing because trigger string not in body", async function () {
  await probot.receive({
    name: "pull_request",
    id: "1",
    payload: {
      action: "opened",
      pull_request: {
        number: 1,
        body: "Just a regular pull request",
        issue_url: "https://api.github.com/repos/robandpdx/superbigmono/issues/1",
        html_url: "https://github.com/robandpdx/superbigmono/pull/1",
      },
      repository: {
        owner: { login: "robandpdx" },
        name: "superbigmono"
      },
      organization: { login: "robandpdx" },
      sender: { login: "robandpdx" }
    }
  });
});

// This test exercises the else-if "false" decision branch when the comment body
// does not contain the trigger string (TRIGGER_STRING is set).
test("receives issue_comment.created event, does nothing because trigger string not in comment", async function () {
  await probot.receive({
    name: "issue_comment",
    id: "1",
    payload: {
      action: "created",
      issue: {
        url: "https://api.github.com/repos/robandpdx/superbigmono/issues/1",
        pull_request: {
          html_url: "https://github.com/robandpdx/superbigmono/pull/1"
        },
        number: 1,
      },
      comment: {
        body: "Just a regular comment"
      },
      pull_request: {
        number: 1,
      },
      repository: {
        owner: { login: "robandpdx" },
        name: "superbigmono"
      },
      organization: { login: "robandpdx" },
      sender: { login: "robandpdx" }
    }
  });
});

// This test exercises the truthy side of `process.env.EMERGENCY_LABEL || 'emergency'`
// at module top-level by re-requiring app.js with EMERGENCY_LABEL set.
test("loads app.js with EMERGENCY_LABEL env set", function () {
  process.env.EMERGENCY_LABEL = 'emergency';
  delete require.cache[require.resolve("./app")];
  require("./app");
  delete require.cache[require.resolve("./app")];
});

function checkIssueRequest(requestBody) {
  assert.equal(requestBody.title, "Emergency PR Audit");
  assert.equal(requestBody.assignees, ["tonyclifton", "andykaufman"]);
  assert.equal(requestBody.labels, ["emergency"]);
  assert.equal(requestBody.body, "Pull request https://github.com/robandpdx/superbigmono/pull/1 was labeled as an emergency.\n- [ ] Reviewed");
}

function checkIssueNoAssigneesRequest(requestBody) {
  assert.equal(requestBody.title, "Emergency PR Audit");
  assert.equal((typeof requestBody.assignees), 'undefined');
  assert.equal(requestBody.labels, ["emergency"]);
  assert.equal(requestBody.body, "Pull request https://github.com/robandpdx/superbigmono/pull/1 was labeled as an emergency.\n- [ ] Reviewed");
}

function checkApprovalRequest(requestBody) {
  assert.equal(requestBody.event, "APPROVE");
}

function checkSlackNotifyRequest(requestBody) {
  assert.equal(requestBody.text, "<https://github.com/robandpdx/superbigmono/pull/1|Pull request> has been labeled as `emergency`\n<https://github.com/robandpdx/superbigmono/issues/44|Audit issue created>");
}

function checkSlackNotifyRequestNoIssue(requestBody) {
  assert.equal(requestBody.text, "<https://github.com/robandpdx/superbigmono/pull/1|Pull request> has been labeled as `emergency`");
}

test.run();