From 7af81bae6c43c8e6cade64de5a484c17d3084a3f Mon Sep 17 00:00:00 2001
From: Pontus Abrahamsson <pontus@lostisland.co>
Date: Fri, 28 Jun 2024 09:48:17 +0200
Subject: [PATCH] Upsert in sync

---
 packages/jobs/src/transactions/sync.ts | 24 +++++++++++++++---------
 1 file changed, 15 insertions(+), 9 deletions(-)

diff --git a/packages/jobs/src/transactions/sync.ts b/packages/jobs/src/transactions/sync.ts
index c232ea94ef..8e3d1fd582 100644
--- 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: {