Feat: Handle duplicate PR titles (#150)

* feat: added duplicate pr increment with number

* feat: added duplicate pr titlke based on number of existing session

* chore: remove title from graphql query

Author: srijitcoder

src/api/session.js

@@ -121,6 +121,25 @@ export async function numberOfOpenClosedSessions(
   }
 }
 
+async function numberOfSessionBasedOnTitle(octokit, githubConfig, prName) {
+  try {
+    const query = `
+    query($queryString: String!) {
+      search(query: $queryString, type: ISSUE, last: 1) {
+        issueCount
+      }
+    }
+  `;
+
+    const response = await octokit.graphql(query, {
+      queryString: `repo:${githubConfig.username}/${githubConfig.repo} in:title '${prName}' is:pr`,
+    });
+    return response.search.issueCount;
+  } catch (error) {
+    return error;
+  }
+}
+
 export async function createSession(octokit, githubConfig, prName) {
   const { username: owner, repo } = githubConfig;
   const username = (await octokit.rest.users.getAuthenticated()).data.login;
@@ -238,10 +257,28 @@ export async function createSession(octokit, githubConfig, prName) {
       number: res.data.number,
     };
   } catch (error) {
-    return {
-      text: error.message.replaceAll("Reference", "Session"),
-      status: "error",
-    };
+    if (error.status === 422 && error.response?.url?.includes("/refs")) {
+      const numberOfSession = await numberOfSessionBasedOnTitle(
+        octokit,
+        githubConfig,
+        `${prName} (`,
+      );
+
+      if (numberOfSession.message) {
+        return {
+          text: numberOfSession.message,
+          status: "error",
+        };
+      } else {
+        const newSessionName = `${prName} (${numberOfSession + 1})`;
+        return createSession(octokit, githubConfig, newSessionName);
+      }
+    } else {
+      return {
+        text: error.message,
+        status: "error",
+      };
+    }
   }
 }