feat: notify on slack when product review label is added (#82)

Author: gitcommitshow

.codesandbox/tasks.json

@@ -11,15 +11,15 @@
   "tasks": {
     "server": {
       "name": "server",
-      "command": "npm start"
+      "command": "npm run staging"
     },
     "lint": {
       "name": "lint",
       "command": "npm run lint"
     },
     "n": {
       "name": "n",
-      "command": "npm start",
+      "command": "npm run staging",
       "runAtStart": true,
       "preview": {
         "port": 3000

.env.sample

@@ -3,6 +3,7 @@ LOGIN_USER=username
 LOGIN_PASSWORD=strongpassword
 DEFAULT_GITHUB_ORG=Git-Commit-Show
 ONE_CLA_PER_ORG=true
+SLACK_DEFAULT_MESSAGE_CHANNEL_WEBHOOK_URL=https://hooks.slack.com/services/T05487DUMMY/B59DUMMY1U/htdsEdsdf7CNeDUMMY
 GITHUB_BOT_USERS=dependabot[bot],devops-github-rudderstack
 GITHUB_ORG_MEMBERS=
 APP_ID="11"

CODEOWNERS

@@ -1 +0,0 @@
-* @github/ecosystem-apps-reviewers

app.js

@@ -13,6 +13,7 @@ import {
   isCLARequired,
   isMessageAfterMergeRequired,
 } from "./src/helpers.js";
+import Slack from "./src/services/Slack.js";
 
 try {
   const packageJson = await import("./package.json", {
@@ -117,10 +118,15 @@ app.webhooks.on("pull_request.labeled", async ({ octokit, payload }) => {
         body: comment,
       });
     }
+    if(label.name?.toLowerCase() === "product review" && Slack.isConfigured()) {
+      console.log("Sending message to the product review channel");
+      const message = `:mag: <${pull_request.html_url}|#${pull_request.number}: ${pull_request.title}> by ${pull_request.user?.login}`;
+      await Slack.sendMessage(message);
+    }
   } catch (error) {
     if (error.response) {
       console.error(
-        `Error! Status: ${error.response.status}. Message: ${error.response.data.message}`
+        `Error! Status: ${error.response?.status}. Message: ${error.response?.data?.message}`
       );
     } else {
       console.error(error);
@@ -166,7 +172,7 @@ app.webhooks.on("pull_request.closed", async ({ octokit, payload }) => {
 app.webhooks.on("issues.opened", async ({ octokit, payload }) => {
   console.log(`Received a new issue event for #${payload.issue.number}`);
   try {
-    // Docs for octokit.rest.issues.createComment - https://github.com/octokit/plugin-rest-endpoint-methods.js/tree/main/docs/issues/createComment.md 
+    // Docs for octokit.rest.issues.createComment - https://github.com/octokit/plugin-rest-endpoint-methods.js/tree/main/docs/issues/createComment.md
     await octokit.rest.issues.createComment({
       owner: payload.repository.owner.login,
       repo: payload.repository.name,

package-lock.json

@@ -6,7 +6,9 @@
   "type": "module",
   "scripts": {
     "lint": "standard",
+    "proxy": "PORT=3000 & ./node_modules/.bin/smee -u $SMEE_URL -t https://$HOSTNAME-3000.csb.app/api/webhook",
     "start": "node app.js",
+    "staging": "npm run proxy & npm start",
     "test": "RUN_E2E_TESTS=true ./node_modules/.bin/mocha test/lifecycle.test.js test/**/*.test.js",
     "test:integration": "./node_modules/.bin/mocha test/lifecycle.test.js test/integration/**/*.test.js",
     "test:e2e": "RUN_E2E_TESTS=true ./node_modules/.bin/mocha test/lifecycle.test.js test/e2e/**/*.test.js"
@@ -16,13 +18,14 @@
     "chai-http": "^5.0.0",
     "mocha": "^10.7.3",
     "sinon": "^19.0.2",
+    "smee-client": "^4.3.1",
     "standard": "^17.0.0"
   },
   "dependencies": {
     "dotenv": "^16.0.3",
     "octokit": "^3.1.2"
   },
   "engines": {
-    "node": ">=20"
+    "node": ">=20.19.0"
   }
 }

package.json

@@ -0,0 +1,43 @@
+/**
+ * Service for interacting with Slack
+ */
+
+class Slack {
+  constructor() {}
+
+  static isConfigured() {
+    return !!process.env.SLACK_DEFAULT_MESSAGE_CHANNEL_WEBHOOK_URL;
+  }
+
+  static async sendMessage(
+    message,
+    { webhookUrl = process.env.SLACK_DEFAULT_MESSAGE_CHANNEL_WEBHOOK_URL } = {}
+  ) {
+    if (!webhookUrl) {
+      throw new Error("Slack webhook URL is not set");
+    }
+
+    if (!message) {
+      throw new Error("Message is not set");
+    }
+
+    const payload = { text: message };
+
+    const response = await fetch(webhookUrl, {
+      method: "POST",
+      headers: {
+        "Content-Type": "application/json",
+      },
+      body: JSON.stringify(payload),
+    });
+
+    if (!response.ok) {
+      throw new Error(
+        `Slack API error: ${response.status} ${response.statusText}`
+      );
+    }
+    console.log(`Successfully sent message to Slack: ${message}`);
+  }
+}
+
+export default Slack;

src/services/Slack.js

@@ -0,0 +1,34 @@
+/**
+ * E2E tests for the slack related services.
+ */
+
+import { expect } from 'chai';
+import { describe, it } from 'mocha';
+import Slack from '../../src/services/Slack.js';
+
+describe('Slack Services', function () {
+    this.timeout(40000);
+
+    describe('sendMessage', function () {
+        // Happy path
+        it('should send a message to the default channel', async function () {
+            const res = await Slack.sendMessage(':mag: <https://github.com/gitcommitshow/rudder-github-app/pull/82|#82: Test message from our GitHub App>\n*Author:* gitcommitshow\n*Created:* Sep 18, 2025 at 10:00 AM\n\n<!channel>', {
+                webhookUrl: "https://hooks.slack.com/services/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"
+            });
+            expect(res).to.not.throw;
+        });
+
+        // Error path 1 - no message
+        it('should throw an error if the message is not set', async function () {
+            expect(Slack.sendMessage(null, {
+                webhookUrl: "https://hooks.slack.com/services/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"
+            })).to.throw;
+        });
+
+        // Error path 2 - no webhook url
+        it('should throw an error if the webhook url is not set', async function () {
+            expect(Slack.sendMessage("testing error path 2 - no webhook url")).to.throw;
+        });
+    });
+
+})