fix: get the correct installation specific octokit instance to remove label

Author: gitcommitshow

app.js

@@ -151,7 +151,7 @@ http
         routes.cla(req, res);
         break;
       case "POST /cla":
-        routes.submitCla(req, res, app.octokit);
+        routes.submitCla(req, res, app);
         break;
       case "POST /api/webhook":
         middleware(req, res);

src/helpers.js

@@ -70,7 +70,20 @@ export async function isOrgMember(octokit, org, username) {
   }
 }
 
-export async function afterCLA(octokit, claSignatureInfo) {
+export async function getOctokitForRepo(app, owner, repo) {
+  for await (const { installation } of app.eachInstallation.iterator()) {
+    for await (const { octokit, repository } of app.eachRepository.iterator({
+      installationId: installation.id,
+    })) {
+      if (repository.owner.login === owner && repository.name === repo) {
+        return octokit;
+      }
+    }
+  }
+  throw new Error(`Installation not found for repository ${owner}/${repo}`);
+}
+
+export async function afterCLA(app, claSignatureInfo) {
   if (!claSignatureInfo || !claSignatureInfo.referrer) return;
   const { org, repo, prNumber } = parseUrlQueryParams(
     claSignatureInfo.referrer,
@@ -83,6 +96,7 @@ export async function afterCLA(octokit, claSignatureInfo) {
     return;
   }
   try {
+    let octokit = await getOctokitForRepo(app, org, repo);
     await octokit.rest.issues.removeLabel({
       owner: org,
       repo: repo,

src/routes.js

@@ -38,7 +38,7 @@ export const routes = {
     });
   },
 
-  submitCla(req, res, octokit) {
+  submitCla(req, res, app) {
     let body = "";
     req.on("data", (chunk) => {
       body += chunk.toString(); // convert Buffer to string
@@ -54,7 +54,7 @@ export const routes = {
       const serverTimestamp = new Date().toISOString();
       bodyJson.serverTimestamp = serverTimestamp;
       storage.save(bodyJson);
-      await afterCLA(octokit, bodyJson);
+      await afterCLA(app, bodyJson);
       // Referrer has information about which PR this CLA flow started from
       const { org, repo, prNumber } = parseUrlQueryParams(bodyJson.referrer);
       if (org && repo && prNumber) {