fix: replace github search api with graphql in success lifecycle method

lib/success.js

@@ -1,4 +1,4 @@
-import { isNil, uniqBy, template, flatten, isEmpty } from "lodash-es";
+import { isNil, uniqBy, template, flatten, isEmpty, toArray } from "lodash-es";
 import pFilter from "p-filter";
 import AggregateError from "aggregate-error";
 import issueParser from "issue-parser";
@@ -65,21 +65,81 @@ export default async function success(pluginConfig, context, { Octokit }) {
     const releaseInfos = releases.filter((release) => Boolean(release.name));
     const shas = commits.map(({ hash }) => hash);
 
-    const searchQueries = getSearchQueries(
-      `repo:${owner}/${repo}+type:pr+is:merged`,
-      shas,
-    ).map(
-      async (q) =>
-        (await octokit.request("GET /search/issues", { q })).data.items,
-    );
+    const loadAssociatedPRsQuery = (shas) => `#graphql
+      query getAssociatedPRs($owner: String!, $repo: String!) {
+        repository(owner: $owner, name: $repo) {
+          ${shas.map((sha) => {
+            return `"${sha.slice(0, 6)}": object(oid: ${sha}) {
+              ...on Commit {
+                associatedPullRequests(first: 100) {
+                  nodes {
+                    url
+                    number
+                  }
+                }
+              }
+            }`
+          }).join("")}
+        }
+      }
+    `;
+
+    // MOCK ONLY
+    // const mockReponse = {
+    //   "data": {
+    //     "repository": {
+    //       "com1": {
+    //         "associatedPullRequests": {
+    //           "nodes": [
+    //             {
+    //               "number": 2
+    //             }
+    //           ]
+    //         }
+    //       },
+    //       "com2": {
+    //         "associatedPullRequests": {
+    //           "nodes": [
+    //             {
+    //               "number": 1
+    //             }
+    //           ]
+    //         }
+    //       }
+    //     }
+    //   }
+    // };
+    // console.log(somedata)
 
-    const searchQueriesResults = await Promise.all(searchQueries);
-    const uniqueSearchQueriesResults = uniqBy(
-      flatten(searchQueriesResults),
+    const { data } = await octokit.graphql(loadAssociatedPRsQuery(shas), { owner, repo });
+
+    const associatedPRs = toArray(mockReponse.data.repository).map((item) => item.associatedPullRequests.nodes);
+    // console.log("norm: ", mockPRNodes);
+
+    // const searchQueries = getSearchQueries(
+    //   `repo:${owner}/${repo}+type:pr+is:merged`,
+    //   shas,
+    // ).map(
+    //   async (q) =>
+    //     (await octokit.request("GET /search/issues", { q })).data.items,
+    // );
+
+    // const searchQueriesResults = await Promise.all(searchQueries);
+    // console.log("searchQueriesResults: ", searchQueriesResults);
+    // const uniqueSearchQueriesResults = uniqBy(
+    //   flatten(searchQueriesResults),
+    //   "number",
+    // );
+    // console.log("uniqueSearchQueriesResults: ", uniqueSearchQueriesResults);
+
+    const uniqueAssociatedPRs = uniqBy(
+      flatten(associatedPRs),
       "number",
     );
+    // console.log(uniquePRs);
+
     const prs = await pFilter(
-      uniqueSearchQueriesResults,
+      uniqueAssociatedPRs,
       async ({ number }) => {
         const commits = await octokit.paginate(
           "GET /repos/{owner}/{repo}/pulls/{pull_number}/commits",
@@ -249,4 +309,4 @@ export default async function success(pluginConfig, context, { Octokit }) {
   if (errors.length > 0) {
     throw new AggregateError(errors);
   }
-}
+}