Merge pull request #45 from MisRob/fix-slack-snippet

Fix Slack notification snippet

Author: MisRob

scripts/constants.js

@@ -22,10 +22,12 @@ const CLOSE_CONTRIBUTORS = [
   'muditchoudhary',
   'nathanaelg16',
   'nikkuAg',
+  'Prashant-thakur77',
   'Sahil-Sinha-11',
   'shivam-daksh',
   'shruti862',
   'thesujai',
+  'vtushar06',
   'WinnyChang',
   'yeshwanth235',
 ];
@@ -96,6 +98,9 @@ const PR_STATS_REPOS = [
   'ricecooker',
 ];
 
+// Repositories in which we accept open-source contributions
+const COMMUNITY_REPOS = [...PR_STATS_REPOS];
+
 module.exports = {
   LE_BOT_USERNAME,
   SENTRY_BOT_USERNAME,
@@ -109,4 +114,5 @@ module.exports = {
   TEAMS_WITH_CLOSE_CONTRIBUTORS,
   HOLIDAY_MESSAGE,
   PR_STATS_REPOS,
+  COMMUNITY_REPOS,
 };

scripts/contributor-issue-comment.js

@@ -6,59 +6,18 @@ const {
   ISSUE_LABEL_HELP_WANTED,
   BOT_MESSAGE_ISSUE_NOT_OPEN,
   BOT_MESSAGE_ALREADY_ASSIGNED,
+  COMMUNITY_REPOS,
 } = require('./constants');
 const {
   isCloseContributor,
   sendBotMessage,
   escapeIssueTitleForSlackMessage,
   hasRecentBotComment,
+  hasLabel,
+  getIssues,
+  getPullRequests,
 } = require('./utils');
 
-async function hasLabel(name, owner, repo, issueNumber, github, core) {
-  let labels = [];
-  try {
-    const response = await github.rest.issues.listLabelsOnIssue({
-      owner,
-      repo,
-      issue_number: issueNumber,
-    });
-    labels = response.data.map(label => label.name);
-  } catch (error) {
-    core.warning(`Failed to fetch labels on issue #${issueNumber}: ${error.message}`);
-    labels = [];
-  }
-  return labels.some(label => label.toLowerCase() === name.toLowerCase());
-}
-
-async function getIssues(assignee, state, owner, repo, github, core) {
-  try {
-    const response = await github.rest.issues.listForRepo({
-      owner,
-      repo,
-      assignee,
-      state,
-    });
-    return response.data.filter(issue => !issue.pull_request);
-  } catch (error) {
-    core.warning(`Failed to fetch issues: ${error.message}`);
-    return [];
-  }
-}
-
-async function getPullRequests(assignee, state, owner, repo, github, core) {
-  try {
-    const response = await github.rest.pulls.list({
-      owner,
-      repo,
-      state,
-    });
-    return response.data.filter(pr => pr.user.login === assignee);
-  } catch (error) {
-    core.warning(`Failed to fetch pull requests: ${error.message}`);
-    return [];
-  }
-}
-
 // Format information about author's assigned open issues
 // as '(Issues #1 #2 | PRs #3)' and PRs for Slack message
 function formatAuthorActivity(issues, pullRequests) {
@@ -201,8 +160,8 @@ module.exports = async ({ github, context, core }) => {
 
     if (contactSupport) {
       const [assignedOpenIssues, openPRs] = await Promise.all([
-        getIssues(commentAuthor, 'open', owner, repo, github, core),
-        getPullRequests(commentAuthor, 'open', owner, repo, github, core),
+        getIssues(commentAuthor, 'open', owner, COMMUNITY_REPOS, github, core),
+        getPullRequests(commentAuthor, 'open', owner, COMMUNITY_REPOS, github, core),
       ]);
       const authorActivity = formatAuthorActivity(assignedOpenIssues, openPRs);
       slackMessage += ` _${authorActivity}_`;

scripts/utils.js

@@ -170,11 +170,78 @@ async function hasRecentBotComment(
   }
 }
 
+/**
+ * Checks if an issue has a label with the given name (case-insensitive).
+ */
+async function hasLabel(name, owner, repo, issueNumber, github, core) {
+  let labels = [];
+  try {
+    const allLabels = await github.paginate(github.rest.issues.listLabelsOnIssue, {
+      owner,
+      repo,
+      issue_number: issueNumber,
+    });
+    labels = allLabels.map(label => label.name);
+  } catch (error) {
+    core.warning(`Failed to fetch labels on issue #${issueNumber}: ${error.message}`);
+    labels = [];
+  }
+  return labels.some(label => label.toLowerCase() === name.toLowerCase());
+}
+
+/**
+ * Fetches issues assigned to an assignee in given repositories.
+ */
+async function getIssues(assignee, state, owner, repos, github, core) {
+  const promises = repos.map(repo =>
+    github
+      .paginate(github.rest.issues.listForRepo, {
+        owner,
+        repo,
+        assignee,
+        state,
+      })
+      .then(issues => issues.filter(issue => !issue.pull_request))
+      .catch(error => {
+        core.warning(`Failed to fetch issues from ${repo}: ${error.message}`);
+        return [];
+      }),
+  );
+
+  const results = await Promise.all(promises);
+  return results.flat();
+}
+
+/**
+ * Fetches pull requests by an author in given repositories.
+ */
+async function getPullRequests(author, state, owner, repos, github, core) {
+  const promises = repos.map(repo =>
+    github
+      .paginate(github.rest.pulls.list, {
+        owner,
+        repo,
+        state,
+      })
+      .then(prs => prs.filter(pr => pr.user.login === author))
+      .catch(error => {
+        core.warning(`Failed to fetch pull requests from ${repo}: ${error.message}`);
+        return [];
+      }),
+  );
+
+  const results = await Promise.all(promises);
+  return results.flat();
+}
+
 module.exports = {
   isContributor,
   isCloseContributor,
   isBot,
   sendBotMessage,
   escapeIssueTitleForSlackMessage,
   hasRecentBotComment,
+  hasLabel,
+  getIssues,
+  getPullRequests,
 };