enh(connectors): use upsert for github issues (#2306)

dust-tt · Oct 30, 2023 · fc59d50 · fc59d50
1 parent 85ec50a
commit fc59d50
Showing 1 changed file with 5 additions and 15 deletions.
diff --git a/connectors/src/connectors/github/temporal/activities.ts b/connectors/src/connectors/github/temporal/activities.ts
@@ -183,22 +183,12 @@ export async function githubUpsertIssueActivity(
     throw new Error(`Connector not found (installationId: ${installationId})`);
   }
 
-  const existingIssueInDb = await GithubIssue.findOne({
-    where: {
-      repoId: repoId.toString(),
-      issueNumber,
-      connectorId: connector.id,
-    },
+  localLogger.info("Upserting GitHub issue in DB.");
+  await GithubIssue.upsert({
+    repoId: repoId.toString(),
+    issueNumber,
+    connectorId: connector.id,
   });
-
-  if (!existingIssueInDb) {
-    localLogger.info("Creating new GitHub issue in DB.");
-    await GithubIssue.create({
-      repoId: repoId.toString(),
-      issueNumber,
-      connectorId: connector.id,
-    });
-  }
 }
 
 export async function githubUpsertDiscussionActivity(