feat: add comment on pr merge

Author: gitcommitshow

app.js

@@ -5,7 +5,11 @@ import url from "url";
 import { Octokit, App } from "octokit";
 import { createNodeMiddleware } from "@octokit/webhooks";
 import { routes } from "./src/routes.js";
-import { getMessage, isCLARequired } from "./src/helpers.js";
+import {
+  getMessage,
+  isCLARequired,
+  isMessageAfterMergeRequired,
+} from "./src/helpers.js";
 
 // Load environment variables from .env file
 dotenv.config();
@@ -60,16 +64,17 @@ app.webhooks.on("pull_request.opened", async ({ octokit, payload }) => {
     }
     // If the user is not a member of the organization and haven't yet signed CLA,
     //  ask them to sign the CLA
+    const comment = getMessage("ask-to-sign-cla", {
+      username: payload.pull_request.user.login,
+      org: payload.repository.owner.login,
+      repo: payload.repository.name,
+      pr_number: payload.pull_request.number,
+    });
     await octokit.rest.issues.createComment({
       owner: payload.repository.owner.login,
       repo: payload.repository.name,
       issue_number: payload.pull_request.number,
-      body: getMessage("ask-to-sign-cla", {
-        username: payload.pull_request.user.login,
-        org: payload.repository.owner.login,
-        repo: payload.repository.name,
-        pr_number: payload.pull_request.number,
-      }),
+      body: comment,
     });
     // Add a label to the PR
     octokit.rest.issues.addLabels({
@@ -89,6 +94,40 @@ app.webhooks.on("pull_request.opened", async ({ octokit, payload }) => {
   }
 });
 
+app.webhooks.on("pull_request.closed", async ({ octokit, payload }) => {
+  console.log(
+    `Closed a pull request event for #${payload.pull_request.number}`,
+  );
+  if (!payload.pull_request.merged) return;
+  console.log(`This PR is merged`);
+  try {
+    if (!isMessageAfterMergeRequired()) {
+      return;
+    }
+    console.log(`Going to notify the PR author...`);
+    const comment = getMessage("message-after-merge", {
+      username: payload.pull_request.user.login,
+      org: payload.repository.owner.login,
+      repo: payload.repository.name,
+      pr_number: payload.pull_request.number,
+    });
+    await octokit.rest.issues.createComment({
+      owner: payload.repository.owner,
+      repo: payload.repository.name,
+      issue_number: payload.pull_request.number,
+      body: comment,
+    });
+  } catch (error) {
+    if (error.response) {
+      console.error(
+        `Error! Status: ${error.response.status}. Message: ${error.response.data.message}`,
+      );
+    } else {
+      console.error(error);
+    }
+  }
+});
+
 app.webhooks.on("issues.opened", async ({ octokit, payload }) => {
   console.log(
     `Received a new issue event for #${payload.issue.number} by ${pull_request.user.type}: ${pull_request.user.login}`,

src/helpers.js

@@ -40,6 +40,20 @@ export function isCLARequired(pullRequest) {
   return true;
 }
 
+export function isMessageAfterMergeRequired(pullRequest) {
+  if (isABot(pullRequest.user)) {
+    console.log("This PR is from a bot. So no message after merge required.");
+    return false;
+  }
+  if (!isExternalContribution(pullRequest)) {
+    console.log(
+      "This PR is an internal contribution. So no message after merge required.",
+    );
+    return false;
+  }
+  return true;
+}
+
 export function isExternalContribution(pullRequest) {
   if (
     pullRequest?.head?.repo?.full_name !== pullRequest?.base?.repo?.full_name
@@ -117,17 +131,34 @@ export async function afterCLA(app, claSignatureInfo) {
   }
 }
 
-export function getMessage(name, payload) {
+export function getMessage(name, context) {
   let message = "";
   switch (name) {
     case "ask-to-sign-cla":
       const CLA_LINK =
         process.env.WEBSITE_ADDRESS +
         "/cla" +
-        `?org=${payload.org}&repo=${payload.repo}&prNumber=${payload.pr_number}&username=${payload.username}`;
+        `?org=${context.org}&repo=${context.repo}&prNumber=${context.pr_number}&username=${context.username}`;
       message = `Thank you for contributing this PR.
       Please [sign the Contributor License Agreement (CLA)](${CLA_LINK}) before merging.`;
       break;
+    case "message-after-merge":
+      message = `Thank you @${context.username} for contributing this PR.`;
+      if (
+        context.org === "rudderlabs" &&
+        context.repo === "rudder-transformer"
+      ) {
+        message += `For every new integration, a PR needs to be raised in [integartions-config](https://github.com/rudderlabs/rudder-integrations-config) repository as well.
+        Without it, users won't be able to configure the integration. 
+        This is a good time to do that.`;
+      }
+      if (
+        context.org === "rudderlabs" &&
+        context.repo === "integrations-config"
+      ) {
+        message += `To get notified when this integration goes live, join the **product-releases** channel in the [Slack Community](https://www.rudderstack.com/join-rudderstack-slack-community/)`;
+      }
+      break;
     default:
       const filepath = resolve(PROJECT_ROOT_PATH, name + ".md");
       message = fs.readFileSync(filepath, "utf8");