app.js

"use strict";

const { Octokit } = require("@octokit/rest");
const axios = require("axios");
require("dotenv").config();

const SLACK_WEBHOOK_URL = process.env.SLACK_WEBHOOK_URL;

/**
 * This is the main entrypoint to your Probot app
 * @param {import('probot').Probot} app
 */
module.exports = (app) => {
  app.log.info("Yay, the app was loaded!");

  /**
   * On an issue being opened
   * @param {import('probot').Context} context
   */
  app.on("issues.opened", async (context) => {
    console.log("issue opened");

    if (
      context.payload.repository.owner.login !== "fairdataihub" &&
      context.payload.repository.owner.login !== "misanlab"
    ) {
      return;
    }

    // Don't respond to the status messages
    if (
      context.payload.repository.name === "uptime" ||
      context.payload.repository.name === "upptime"
    ) {
      return;
    }

    // Don't respond to the issues opened by our bots or renovate
    if (context.payload.issue.user.type === "Bot") {
      if (
        context.payload.issue.user.login === "renovate[bot]" ||
        context.payload.issue.user.login === "doi-checker-app[bot]" ||
        context.payload.issue.user.login === "license-check-bot[bot]" || 
        context.payload.issue.user.login === "codefair-app[bot]"
      ) {
        return;
      }
    }

    const issueComment = context.issue({
      body: "Hello! Thank you for opening this issue. Your input is valuable and helps improve the project. Can you please provide a detailed description of the problem you're encountering? Any additional information such as steps to reproduce the issue would be greatly appreciated. Thank you!",
    });

    await axios.post(SLACK_WEBHOOK_URL, {
      blocks: [
        {
          type: "header",
          text: {
            type: "plain_text",
            text: `New issue opened in ${context.payload.repository.full_name}`,
            emoji: true,
          },
        },
        {
          type: "divider",
        },
        {
          type: "section",
          text: {
            type: "mrkdwn",
            text: `*Issue title:* ${context.payload.issue.title}`,
          },
        },
        {
          type: "section",
          text: {
            type: "mrkdwn",
            text: `*Issue Link:* ${context.payload.issue.html_url}`,
          },
        },
      ],
    });

    console.log("sending issue comment");
    return context.octokit.issues.createComment(issueComment);
  });

  /**
   * On an issue being closed
   * @param {import('probot').Context} context
   */
  app.on("issues.closed", async (context) => {
    console.log("issue closed");

    if (
      context.payload.repository.owner.login !== "fairdataihub" &&
      context.payload.repository.owner.login !== "misanlab"
    ) {
      return;
    }

    /**
     * * Don't respond to the status messages
     */
    if (
      context.payload.repository.name === "uptime" ||
      context.payload.repository.name === "upptime"
    ) {
      return;
    }

    // Don't respond to the issues closed by our bots or renovate
    if (context.payload.issue.user.type === "Bot") {
      if (
        context.payload.issue.user.login === "renovate[bot]" ||
        context.payload.issue.user.login === "doi-checker-app[bot]" ||
        context.payload.issue.user.login === "license-check-bot[bot]" ||
        context.payload.issue.user.login === "codefair-app[bot]"
      ) {
        return;
      }
    }

    const issueComment = context.issue({
      body: "If you're still experiencing any problems, please don't hesitate to open a new issue. Have a great day!",
    });

    console.log("sending issue comment");
    return context.octokit.issues.createComment(issueComment);
  });

  /**
   * On a pull request being opened
   * @param {import('probot').Context} context
   */
  app.on("pull_request.opened", async (context) => {
    console.log("pull request opened");

    if (
      context.payload.repository.owner.login !== "fairdataihub" &&
      context.payload.repository.owner.login !== "misanlab"
    ) {
      return;
    }

    // Don't respond to the pull requests opened by renovate
    if (context.payload.pull_request.user.type === "Bot") {
      if (context.payload.pull_request.user.login === "renovate[bot]") {
        return;
      }
    }

    // Get the pull request number
    const prNumber = context.payload.pull_request.number;

    const issueComment = context.issue({
      body: "Thank you for submitting this pull request! We appreciate your contribution to the project. Before we can merge it, we need to review the changes you've made to ensure they align with our code standards and meet the requirements of the project. We'll get back to you as soon as we can with feedback. Thanks again!",
      issue_number: prNumber,
    });

    console.log("sending pr comment");
    return context.octokit.issues.createComment(issueComment);
  });

  /**
   * On a pull request being closed/merged
   * @param {import('probot').Context} context
   */
  app.on("pull_request.closed", async (context) => {
    console.log("pull request closed");

    if (
      context.payload.repository.owner.login !== "fairdataihub" &&
      context.payload.repository.owner.login !== "misanlab"
    ) {
      return;
    }

    // Don't respond to the pull requests closed by renovate
    if (context.payload.pull_request.user.type === "Bot") {
      if (context.payload.pull_request.user.login === "renovate[bot]") {
        return;
      }
    }

    // Get the pull request number
    const prNumber = context.payload.pull_request.number;

    const issueComment = context.issue({
      body: "Thanks for closing this pull request! If you have any further questions, please feel free to open a new issue. We are always happy to help!",
      issue_number: prNumber,
    });

    console.log("sending pr comment");
    return context.octokit.issues.createComment(issueComment);
  });

  /**
   * On a pull request being edited
   * @param {import('probot').Context} context
   */
  app.on("pull_request.edited", async (context) => {
    console.log("pull request edited");

    if (
      context.payload.repository.owner.login !== "fairdataihub" &&
      context.payload.repository.owner.login !== "misanlab"
    ) {
      return;
    }

    // Don't respond to the pull requests opened by renovate
    if (context.payload.pull_request.user.type === "Bot") {
      if (context.payload.pull_request.user.login === "renovate[bot]") {
        return;
      }
    }

    // Get the pull request number
    const prNumber = context.payload.pull_request.number;

    const issueComment = context.issue({
      body: "Thanks for making updates to your pull request. Our team will take a look and provide feedback as soon as possible. Please wait for any GitHub Actions to complete before editing your pull request. If you have any additional questions or concerns, feel free to let us know. Thank you for your contributions!",
      issue_number: prNumber,
    });

    console.log("sending pr comment");
    return context.octokit.issues.createComment(issueComment);
  });

  /**
   * On a pull request being marked as ready for review
   * @param {import('probot').Context} context
   */
  app.on("pull_request.ready_for_review", async (context) => {
    console.log("pull request ready for review");

    if (
      context.payload.repository.owner.login !== "fairdataihub" &&
      context.payload.repository.owner.login !== "misanlab"
    ) {
      return;
    }

    // Get the pull request number
    const prNumber = context.payload.pull_request.number;

    const issueComment = context.issue({
      body: "Thanks for making your pull request ready for review! Our team will take a look and provide feedback as soon as possible.",
      issue_number: prNumber,
    });

    console.log("sending pr comment");
    return context.octokit.issues.createComment(issueComment);
  });

  /**
   * On a new star being added to a repository
   * @param {import('probot').Context} context
   */
  app.on("star.created", async (context) => {
    console.log("repo starred");

    if (
      context.payload.repository.owner.login !== "fairdataihub" &&
      context.payload.repository.owner.login !== "misanlab"
    ) {
      console.log("repo not fairdataihub or misanlab");
      return;
    }

    await axios.post(SLACK_WEBHOOK_URL, {
      blocks: [
        {
          type: "section",
          text: {
            type: "mrkdwn",
            text: `New star created! :star: \n The <${context.payload.repository.html_url}|${context.payload.repository.name}> repository in the <${context.payload.repository.owner.html_url}|${context.payload.repository.owner.login}> organization was just starred by <${context.payload.sender.html_url}|${context.payload.sender.login}>! :tada: `,
          },
          accessory: {
            type: "image",
            image_url: `https://api.dicebear.com/5.x/thumbs/png?seed=${context.id}`,
            alt_text: "image",
          },
        },
        {
          type: "divider",
        },
      ],
    });

    return;
  });

  /**
   * On repository being unstarred
   * @param {import('probot').Context} context
   */
  app.on("star.deleted", async (context) => {
    console.log("repo unstarred");

    if (
      context.payload.repository.owner.login !== "fairdataihub" &&
      context.payload.repository.owner.login !== "misanlab"
    ) {
      return;
    }

    await axios.post(SLACK_WEBHOOK_URL, {
      blocks: [
        {
          type: "section",
          text: {
            type: "mrkdwn",
            text: `Star removed! :star: \n The <${context.payload.repository.html_url}|${context.payload.repository.name}> repository in the <${context.payload.repository.owner.html_url}|${context.payload.repository.owner.login}> organization lost a star from <${context.payload.sender.html_url}|${context.payload.sender.login}>! :cry: `,
          },
          accessory: {
            type: "image",
            image_url: `https://api.dicebear.com/5.x/micah/png?seed=${context.id}&mouth=frown,nervous,sad,surprised`,
            alt_text: "image",
          },
        },
        {
          type: "divider",
        },
      ],
    });

    return;
  });

  /**
   * On repository being forked
   * @param {import('probot').Context} context
   */
  app.on("fork", async (context) => {
    console.log("repo forked");

    await axios.post(SLACK_WEBHOOK_URL, {
      blocks: [
        {
          type: "section",
          text: {
            type: "mrkdwn",
            text: `New fork created! :fork_and_knife: \n The <${context.payload.repository.html_url}|${context.payload.repository.name}> repository in the <${context.payload.repository.owner.html_url}|${context.payload.repository.owner.login}> organization was just forked by <${context.payload.forkee.owner.html_url}|${context.payload.forkee.owner.login}>! :monocle_face: `,
          },
          accessory: {
            type: "image",
            image_url: `https://api.dicebear.com/5.x/shapes/png?seed=${context.id}`,
            alt_text: "image",
          },
        },
        {
          type: "divider",
        },
      ],
    });

    return;
  });

  /**
   * On a release being published
   * @param {import('probot').Context} context
   */
  app.on("release.published", async (context) => {
    console.log("release published");

    if (
      context.payload.repository.owner.login !== "fairdataihub" &&
      context.payload.repository.owner.login !== "misanlab"
    ) {
      return;
    }

    // if the repository name is SODA-for-SPARC and the release is a beta release, return
    if (
      context.payload.repository.name === "SODA-for-SPARC" &&
      context.payload.release.name.includes("beta")
    ) {
      return;
    }

    // Get the release
    const release = context.payload.release;

    // Get repo owner and name
    const owner = context.payload.repository.owner.login;
    const repo = context.payload.repository.name;

    // Add reactions to the release
    await addReactionsToRelease(owner, repo, release.id);

    await axios.post(SLACK_WEBHOOK_URL, {
      blocks: [
        {
          type: "section",
          text: {
            type: "mrkdwn",
            text: `New release published! :rocket: \n The <${context.payload.repository.html_url}|${context.payload.repository.name}> repository in the <${context.payload.repository.owner.html_url}|${context.payload.repository.owner.login}> organization just published a new release! :tada: `,
          },
          accessory: {
            type: "image",
            image_url: `https://api.dicebear.com/5.x/big-smile/png?seed=${context.id}`,
            alt_text: "image",
          },
        },
        {
          type: "divider",
        },
      ],
    });

    return;
  });

  /**
   * On a label being added to an issue
   * @param {import('probot').Context} context
   */
  app.on("label.created", async (context) => {
    console.log("label added");

    let issueComment = "";

    // Get the label name
    const labelName = context.payload.label.name;

    if (labelName === "bug" || labelName === "needs-more-info") {
      issueComment = context.issue({
        body: "We appreciate your contribution to the project. Can you please provide more details, such as steps to reproduce the problem, and any relevant information to help us understand the issue better? This will help us in resolving the issue as soon as possible.",
      });
    } else if (labelName === "enhancement") {
      issueComment = context.issue({
        body: "We appreciate your contribution to the project. Can you please provide more details, such as the use case for the enhancement, and any relevant information to help us understand the issue better? This will help us in resolving the issue as soon as possible.",
      });
    } else {
      return;
    }

    console.log("sending issue comment");
    return context.octokit.issues.createComment(issueComment);
  });

  /**
   * On adding the GitHub App to an organization
   * @param {import('probot').Context} context
   */
  app.on("installation.created", async (context) => {
    console.log("app installed");

    const owner = context.payload.installation.account.login;

    // Check if the repo is in the fairdataihub or misanlab org
    if (owner !== "fairdataihub" && owner !== "misanlab") {
      return;
    }

    for (const repo of context.payload.repositories) {
      const repoName = repo.name;

      // Star the repo
      await starRepository(owner, repoName);

      // Get the repo's releases
      const releases = await context.octokit.repos.listReleases({
        owner: owner,
        repo: repoName,
      });

      // loop through the releases
      for (const release of releases.data) {
        // Check if the release is a draft
        if (release.draft) {
          continue;
        }

        await addReactionsToRelease(owner, repoName, release.id);
      }

      // Send a slack message
      await axios.post(SLACK_WEBHOOK_URL, {
        blocks: [
          {
            type: "section",
            text: {
              type: "mrkdwn",
              text: `New installation created! :rocket: \n The app was installed to the ${repoName} repository in the <${context.payload.installation.account.html_url}|${owner}> organization! :tada:`,
            },
            accessory: {
              type: "image",
              image_url: `https://api.dicebear.com/5.x/fun-emoji/png?seed=${context.id}`,
              alt_text: "image",
            },
          },
          {
            type: "divider",
          },
        ],
      });
    }

    return;
  });

  /**
   * On adding a repository to the app
   * @param {import('probot').Context} context
   */
  app.on("installation_repositories.added", async (context) => {
    console.log("repo added");

    const owner = context.payload.installation.account.login;

    for (const repo of context.payload.repositories_added) {
      const repoName = repo.name;

      // Check if the repo is in the fairdataihub or misanlab org
      if (owner !== "fairdataihub" && owner !== "misanlab") {
        continue;
      }

      // Check if the repo is a fork
      if (repo.fork) {
        continue;
      }

      // Star the repo
      await starRepository(owner, repoName);

      // Get the repo's releases
      const releases = await context.octokit.repos.listReleases({
        owner: owner,
        repo: repoName,
      });

      // loop through the releases
      for (const release of releases.data) {
        // Check if the release is a draft
        if (release.draft) {
          continue;
        }

        await addReactionsToRelease(owner, repoName, release.id);
      }

      await axios.post(SLACK_WEBHOOK_URL, {
        blocks: [
          {
            type: "section",
            text: {
              type: "mrkdwn",
              text: `New repository added! ➕ \n The app was installed to the ${repoName} repository in the <${context.payload.installation.account.html_url}|${owner}> organization! :tada:`,
            },
            accessory: {
              type: "image",
              image_url: `https://api.dicebear.com/5.x/fun-emoji/png?seed=${context.id}`,
              alt_text: "image",
            },
          },
          {
            type: "divider",
          },
        ],
      });
    }

    return;
  });

  /**
   * On creating a repository
   * @param {import('probot').Context} context
   */
  app.on("repository.created", async (context) => {
    console.log("repo created");

    const owner = context.payload.repository.owner.login;
    const repoName = context.payload.repository.name;

    // Check if the repo is in the fairdataihub or misanlab org
    if (owner !== "fairdataihub" && owner !== "misanlab") {
      return;
    }

    // Check if the repo is a fork
    if (repo.fork) {
      return;
    }

    // Star the repo
    await context.octokit.activity.starRepo({
      owner: owner,
      repo: repoName,
    });

    // Get the repo's releases
    const releases = await context.octokit.repos.listReleases({
      owner: owner,
      repo: repoName,
    });

    // loop through the releases
    for (const release of releases.data) {
      // Check if the release is a draft
      if (release.draft) {
        continue;
      }

      await addReactionsToRelease(owner, repoName, release.id);
    }

    await axios.post(SLACK_WEBHOOK_URL, {
      blocks: [
        {
          type: "section",
          text: {
            type: "mrkdwn",
            text: `New repository created! ✨ \n The app was installed to the ${repoName} repository in the <${context.payload.installation.account.html_url}|${owner}> organization! :tada:`,
          },
          accessory: {
            type: "image",
            image_url: `https://api.dicebear.com/5.x/fun-emoji/png?seed=${context.id}`,
            alt_text: "image",
          },
        },
        {
          type: "divider",
        },
      ],
    });

    return;
  });

  /**
   * On push to master
   * @param {import("probot").Context} context
   */
  app.on("push", async (context) => {
    console.log("push to master");
  });
};

/**
 * Star a repository using an authenticated user
 * @param {string} owner
 * @param {string} repo
 * @returns
 */
const starRepository = async (owner, repo) => {
  const octokit = new Octokit({
    auth: process.env.GITHUB_PAT,
  });

  await octokit.activity.starRepoForAuthenticatedUser({
    owner,
    repo,
  });

  return;
};

/**
 * Add reactions to a release using an authenticated user
 * @param {string} owner
 * @param {string} repo
 * @param {string} releaseId
 * @returns {Promise<void>}
 */
const addReactionsToRelease = async (owner, repo, releaseId) => {
  const octokit = new Octokit({
    auth: process.env.GITHUB_PAT,
  });

  const reactions = ["+1", "heart", "hooray", "rocket"];

  for (const reaction of reactions) {
    await octokit.reactions.createForRelease({
      owner,
      repo,
      release_id: releaseId,
      content: reaction,
    });
  }

  return;
};