Build: deleting im-pipeline-bot PR comments before adding new ones

Author: stevematney

package-lock.json

@@ -80,10 +80,14 @@
     "eslint-plugin-react-hooks": "^4.2.0",
     "fs-extra": "^9.0.1",
     "husky": "^4.3.0",
+    "issue-parser": "^6.0.0",
     "jest": "^26.6.3",
     "jest-environment-jsdom": "^26.6.2",
     "lint-staged": "^10.5.2",
+    "lodash": "^4.17.20",
     "msw": "^0.22.3",
+    "octokit": "^1.0.0-hello-world",
+    "p-filter": "^2.1.0",
     "prettier": "^2.2.0",
     "react": "^17.0.1",
     "react-dom": "^17.0.1",

package.json

@@ -87,6 +87,7 @@ You can test it by using:
 npm install scriptloader-component@\${nextRelease.version}
 \`\`\`
         `,
+        releasedLabels: null,
       },
     ],
   ],

release.config.js

@@ -6,14 +6,20 @@ const originalPackage = path.dirname(
 );
 fs.copySync(originalPackage, path.join(__dirname, "github-prerelease"));
 
-const replaceFileText = (file, ...replaceArgs) => {
+const replaceFileText = (file, newFile, ...replaceArgs) => {
   const fileText = fs.readFileSync(file, { encoding: "utf8" });
   const replacedText = fileText.replace(...replaceArgs);
-  fs.writeFileSync(file, replacedText);
+  fs.writeFileSync(newFile, replacedText);
 };
 
 replaceFileText(
   path.join(__dirname, "github-prerelease", "lib", "success.js"),
+  path.join(__dirname, "github-prerelease", "lib", "new-success.js"),
   "type:pr+is:merged",
   "type:pr+is:open"
 );
+
+fs.copySync(
+  require.resolve("./success"),
+  path.join(__dirname, "github-prerelease", "lib", "success.js")
+);

release/create-github-prerelease.js

@@ -0,0 +1,119 @@
+const { isNil, uniqBy, flatten } = require("lodash");
+const pFilter = require("p-filter");
+const issueParser = require("issue-parser");
+
+// this file will be copied two folders deeper
+const resolveConfig = require("./resolve-config");
+const getClient = require("./resolve-config");
+const parseGithubUrl = require("./parse-github-url");
+const getSearchQueries = require("./get-search-queries");
+const success = require("./new-success");
+
+module.exports = async (pluginConfig, context) => {
+  const {
+    options: { repositoryUrl },
+    commits,
+    logger,
+  } = context;
+  const {
+    githubToken,
+    githubUrl,
+    githubApiPathPrefix,
+    proxy,
+    successComment,
+  } = resolveConfig(pluginConfig, context);
+  const github = getClient({
+    githubToken,
+    githubUrl,
+    githubApiPathPrefix,
+    proxy,
+  });
+  const [owner, repo] = (
+    await github.repos.get(parseGithubUrl(repositoryUrl))
+  ).data.full_name.split("/");
+
+  if (successComment === false) {
+    logger.log("Skipping old comment deletion.");
+  } else {
+    const parser = issueParser(
+      "github",
+      githubUrl ? { hosts: [githubUrl] } : {}
+    );
+    const shas = commits.map(({ hash }) => hash);
+
+    const searchQueries = getSearchQueries(
+      `repo:${owner}/${repo}+type:pr+is:merged`,
+      shas
+    ).map(
+      async (q) => (await github.search.issuesAndPullRequests({ q })).data.items
+    );
+
+    const prs = await pFilter(
+      uniqBy(flatten(await Promise.all(searchQueries)), "number"),
+      async ({ number }) =>
+        (
+          await github.pulls.listCommits({ owner, repo, pull_number: number })
+        ).data.find(({ sha }) => shas.includes(sha)) ||
+        shas.includes(
+          (await github.pulls.get({ owner, repo, pull_number: number })).data
+            .merge_commit_sha
+        )
+    );
+
+    // Parse the release commits message and PRs body to find resolved issues/PRs via comment keyworkds
+    const issues = [
+      ...prs.map((pr) => pr.body),
+      ...commits.map((commit) => commit.message),
+    ].reduce((issues, message) => {
+      return message
+        ? issues.concat(
+            parser(message)
+              .actions.close.filter(
+                (action) =>
+                  isNil(action.slug) || action.slug === `${owner}/${repo}`
+              )
+              .map((action) => ({ number: Number.parseInt(action.issue, 10) }))
+          )
+        : issues;
+    }, []);
+
+    await Promise.all(
+      uniqBy([...prs, ...issues], "number").map(async (issue) => {
+        try {
+          const comments = { owner, repo, issue_number: issue.number };
+          const foundComments = (
+            await github.issues.listComments(comments)
+          ).filter((comment) => comment.user.login === "im-pipeline-bot");
+
+          for (let c in foundComments) {
+            await github.issues.deleteComment({
+              owner,
+              repo,
+              comment_id: c.id,
+            });
+            logger.log("Removed comment %c from issue #%d", c.id, issue.number);
+          }
+        } catch (error) {
+          if (error.status === 403) {
+            logger.error(
+              "Not allowed to delete a comment to the issue #%d.",
+              issue.number
+            );
+          } else if (error.status === 404) {
+            logger.error(
+              "Failed to delete a comment to the issue #%d as it doesn't exist.",
+              issue.number
+            );
+          } else {
+            logger.error(
+              "Failed to delete a comment to the issue #%d.",
+              issue.number
+            );
+          }
+        }
+      })
+    );
+  }
+
+  await success(pluginConfig, context);
+};