feature: Kafka Parser support

Author: Ran Isenberg

.github/scripts/label_related_issue.js

@@ -1,29 +1,53 @@
-module.exports = async ({github, context, core}) => {
-    const prBody = context.payload.body;
-    const prNumber = context.payload.number;
-    const releaseLabel = process.env.RELEASE_LABEL;
-    const maintainersTeam = process.env.MAINTAINERS_TEAM
+const {
+  PR_AUTHOR,
+  PR_BODY,
+  PR_NUMBER,
+  IGNORE_AUTHORS,
+  LABEL_PENDING_RELEASE,
+  HANDLE_MAINTAINERS_TEAM,
+  PR_IS_MERGED,
+} = require("./constants")
 
-    const RELATED_ISSUE_REGEX = /Issue number:[^\d\r\n]+(?<issue>\d+)/;
+module.exports = async ({ github, context, core }) => {
+  if (IGNORE_AUTHORS.includes(PR_AUTHOR)) {
+    return core.notice("Author in IGNORE_AUTHORS list; skipping...")
+  }
 
-    const isMatch = RELATED_ISSUE_REGEX.exec(prBody);
+  if (PR_IS_MERGED == "false") {
+    return core.notice("Only merged PRs to avoid spam; skipping")
+  }
+
+  const RELATED_ISSUE_REGEX = /Issue number:[^\d\r\n]+(?<issue>\d+)/;
+
+  const isMatch = RELATED_ISSUE_REGEX.exec(PR_BODY);
+
+  try {
     if (!isMatch) {
-      core.setFailed(`Unable to find related issue for PR number ${prNumber}.\n\n Body details: ${prBody}`);
+      core.setFailed(`Unable to find related issue for PR number ${PR_NUMBER}.\n\n Body details: ${PR_BODY}`);
       return await github.rest.issues.createComment({
         owner: context.repo.owner,
         repo: context.repo.repo,
-        body: `${maintainersTeam} No related issues found. Please ensure '${releaseLabel}' label is applied before releasing.`,
-        issue_number: prNumber,
+        body: `${HANDLE_MAINTAINERS_TEAM} No related issues found. Please ensure '${LABEL_PENDING_RELEASE}' label is applied before releasing.`,
+        issue_number: PR_NUMBER,
       });
     }
+  } catch (error) {
+    core.setFailed(`Unable to create comment on PR number ${PR_NUMBER}.\n\n Error details: ${error}`);
+    throw new Error(error);
+  }
 
-    const { groups: {relatedIssueNumber} } = isMatch
+  const { groups: { issue } } = isMatch
 
-    core.info(`Auto-labeling related issue ${relatedIssueNumber} for release`)
+  try {
+    core.info(`Auto-labeling related issue ${issue} for release`)
     return await github.rest.issues.addLabels({
-      issue_number: relatedIssueNumber,
+      issue_number: issue,
       owner: context.repo.owner,
       repo: context.repo.repo,
-      labels: [releaseLabel]
+      labels: [LABEL_PENDING_RELEASE]
     })
-}
+  } catch (error) {
+    core.setFailed(`Is this issue number (${issue}) valid? Perhaps a discussion?`);
+    throw new Error(error);
+  }
+}