create comment (dry)

Author: mydea

dev-packages/release-comment-issues-gh-action/index.mjs

@@ -1,18 +1,20 @@
 import * as core from '@actions/core';
-import {  context, getOctokit } from '@actions/github';
+import { context, getOctokit } from '@actions/github';
+
+const RELEASE_COMMENT_HEADING = '## A PR closing this issue has just been released 🚀';
 
 async function run() {
   const { getInput } = core;
 
   const githubToken = getInput('github_token');
-  const version  = getInput('version');
+  const version = getInput('version');
 
   if (!githubToken || !version) {
     core.debug('Skipping because github_token or version are empty.');
     return;
   }
 
-  const {owner, repo} = context.repo;
+  const { owner, repo } = context.repo;
 
   const octokit = getOctokit(githubToken);
 
@@ -21,34 +23,50 @@ async function run() {
     repo,
     tag: version,
     headers: {
-      'X-GitHub-Api-Version': '2022-11-28'
-    }
+      'X-GitHub-Api-Version': '2022-11-28',
+    },
   });
 
-
   const prNumbers = extractPrsFromReleaseBody(release.data.body);
 
-  if(!prNumbers.length) {
+  if (!prNumbers.length) {
     core.debug('No PRs found in release body.');
     return;
   }
 
   core.debug(`Found PRs in release body: ${prNumbers.join(', ')}`);
 
-  const linkedIssues = await Promise.all(prNumbers.map((prNumber) => getLinkedIssuesForPr(octokit, { repo, owner, prNumber })));
-
-  console.log(linkedIssues);
+  const linkedIssues = await Promise.all(
+    prNumbers.map(prNumber => getLinkedIssuesForPr(octokit, { repo, owner, prNumber })),
+  );
 
-  for(const pr of linkedIssues) {
-    if(!pr.issues.length) {
+  for (const pr of linkedIssues) {
+    if (!pr.issues.length) {
       core.debug(`No linked issues found for PR #${pr.prNumber}`);
       continue;
     }
 
     core.debug(`Linked issues for PR #${pr.prNumber}: ${pr.issues.map(issue => issue.number).join(',')}`);
-  }
 
+    for (const issue of pr.issues) {
+      if (await hasExistingComment(octokit, { repo, owner, issueNumber: issue.number })) {
+        core.debug(`Comment already exists for issue #${issue.number}`);
+        continue;
+      }
+
+      const body = `${RELEASE_COMMENT_HEADING}\n\nThis issue was closed by PR #${pr.prNumber}, which was included in the [${version} release](https://github.com/${owner}/${repo}/releases/tag/${version}).`;
+
+      core.debug(`Creating comment for issue #${issue.number}`);
+      core.debug(body);
 
+      /* await octokit.rest.issues.createComment({
+        repo,
+        owner,
+        issue_number: issue.number,
+        body,
+      }); */
+    }
+  }
 }
 
 /**
@@ -58,10 +76,12 @@ async function run() {
  */
 function extractPrsFromReleaseBody(body) {
   const regex = /\[#(\d+)\]\(https:\/\/github\.com\/getsentry\/sentry-javascript\/pull\/(?:\d+)\)/gm;
- const prNumbers = Array.from(new Set([...body.matchAll(regex)].map((match) => parseInt(match[1]))));
+  const prNumbers = Array.from(new Set([...body.matchAll(regex)].map(match => parseInt(match[1]))));
+
+  return prNumbers.filter(number => !!number && !Number.isNaN(number));
+}
 
- return prNumbers.filter(number => !!number && !Number.isNaN(number));
-}/**
+/**
  *
  * @param {ReturnType<import('@actions/github').getOctokit>} octokit
  * @param {{ repo: string, owner: string, prNumber: number}} options
@@ -92,13 +112,27 @@ query issuesForPr($owner: String!, $repo: String!, $prNumber: Int!) {
     },
   );
 
-  console.log(res);
-
   const issues = res.repository?.pullRequest?.closingIssuesReferences.edges.map(edge => edge.node);
   return {
     prNumber,
-    issues
+    issues,
   };
 }
 
+/**
+ *
+ * @param {ReturnType<import('@actions/github').getOctokit>} octokit
+ * @param {{ repo: string, owner: string, issueNumber: number}} options
+ * @returns {Promise<boolean>}
+ */
+async function hasExistingComment(octokit, { repo, owner, issueNumber }) {
+  const { data: commentList } = await octokit.rest.issues.listComments({
+    repo,
+    owner,
+    issue_number: issueNumber,
+  });
+
+  return commentList.some(comment => comment.body.startsWith(RELEASE_COMMENT_HEADING));
+}
+
 run();