Upsert in sync

midday-ai · Jun 28, 2024 · 7af81ba · 7af81ba
1 parent cc0bc98
commit 7af81ba
Showing 1 changed file with 15 additions and 9 deletions.
diff --git a/packages/jobs/src/transactions/sync.ts b/packages/jobs/src/transactions/sync.ts
@@ -76,20 +76,26 @@ client.defineJob({
           return null;
         }
 
-        const { error: transactionsError, data: transactionsData } =
-          await supabase
-            .from("transactions")
-            .upsert(transactions, {
-              onConflict: "internal_id",
-              ignoreDuplicates: true,
-            })
-            .select("*");
+        const {
+          error: transactionsError,
+          data: transactionsData,
+          statusText,
+        } = await supabase
+          .from("transactions")
+          .upsert(transactions, {
+            onConflict: "internal_id",
+          })
+          .select("*");
 
         if (transactionsError) {
           await io.logger.error("Transactions error", transactionsError);
         }
 
-        if (transactionsData && transactionsData?.length > 0) {
+        if (
+          statusText === "Created" &&
+          transactionsData &&
+          transactionsData?.length > 0
+        ) {
           await io.sendEvent("🔔 Send notifications", {
             name: Events.TRANSACTIONS_NOTIFICATION,
             payload: {