Fix category mapping

midday-ai · May 13, 2024 · cc8ef06 · cc8ef06
1 parent 8f815a8
commit cc8ef06
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 9 deletions.
diff --git a/packages/jobs/src/transactions/initial-sync.ts b/packages/jobs/src/transactions/initial-sync.ts
@@ -69,9 +69,9 @@ client.defineJob({
       // NOTE: We will get all the transactions at once for each account so
       // we need to guard against massive payloads
       await processPromisesBatch(transactions, BATCH_LIMIT, async (batch) => {
-        const formatted = batch.map((transaction) => ({
-          ...transaction,
-          category_slug: transaction.category,
+        const formatted = batch.map(({ category, ...rest }) => ({
+          ...rest,
+          category_slug: category,
         }));
 
         await supabase.from("transactions").upsert(formatted, {

diff --git a/packages/jobs/src/transactions/manual-sync.ts b/packages/jobs/src/transactions/manual-sync.ts
@@ -49,9 +49,9 @@ client.defineJob({
       bankAccountId: account.id,
     });
 
-    const formatted = transactions.map((transaction) => ({
-      ...transaction,
-      category_slug: transaction.category,
+    const formatted = transactions.map(({ category, ...rest }) => ({
+      ...rest,
+      category_slug: category,
     }));
 
     // NOTE: We will get all the transactions at once for each account so

diff --git a/packages/jobs/src/transactions/sync.ts b/packages/jobs/src/transactions/sync.ts
@@ -62,9 +62,9 @@ client.defineJob({
     try {
       if (promises) {
         const result = await Promise.all(promises);
-        const transactions = result.flat()?.map((transaction) => ({
-          ...transaction,
-          category_slug: transaction.category,
+        const transactions = result.flat()?.map(({ category, ...rest }) => ({
+          ...rest,
+          category_slug: category,
         }));
 
         await io.logger.debug("Transactions", transactions);