Debug

midday-ai · Mar 8, 2024 · 022f3e2 · 022f3e2
1 parent f909adc
commit 022f3e2
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 18 deletions.
diff --git a/packages/jobs/src/constants.ts b/packages/jobs/src/constants.ts
@@ -2,7 +2,7 @@ export const Jobs = {
   TRANSACTIONS_EXPORT: "transactions-export",
   TRANSACTIONS_NOTIFICATION: "transactions-notification",
   TRANSACTION_SCHEDULER: "transaction-scheduler",
-  TRANSACTIONS_SYNC: "transactions-sync-v2",
+  TRANSACTIONS_SYNC: "transactions-sync",
   TRANSACTIONS_SETUP: "transactions-setup",
   PROCESS_DOCUMENT: "process-document",
   MATCH_INBOX: "match-inbox",

diff --git a/packages/jobs/src/transactions/notification.ts b/packages/jobs/src/transactions/notification.ts
@@ -66,17 +66,17 @@ client.defineJob({
       }));
     });
 
-    if (notificationPromises) {
-      const notificationEvents = await Promise.all(notificationPromises);
+    const notificationEvents = await Promise.all(notificationPromises);
 
-      if (notificationEvents?.length) {
-        triggerBulk(notificationEvents.flat());
-        await io.logger.log(
-          `Sending notifications: ${notificationEvents.length}`
-        );
-      }
+    if (notificationEvents?.length) {
+      triggerBulk(notificationEvents.flat());
+      await io.logger.log(
+        `Sending notifications: ${notificationEvents.length}`
+      );
     }
 
+    await io.logger.debug("notificationEvents", notificationEvents);
+
     const emailPromises = usersData?.map(async ({ user, team_id }) => {
       const { t } = getI18n({ locale: user.locale });
 
@@ -104,15 +104,15 @@ client.defineJob({
       };
     });
 
-    if (emailPromises) {
-      const emailEvents = await Promise.all(emailPromises);
+    const emailEvents = await Promise.all(emailPromises);
+
+    await io.logger.debug("emailEvents", emailEvents);
 
-      if (emailEvents?.length) {
-        try {
-          triggerBulk(emailEvents.flat());
-        } catch (error) {
-          await io.logger.debug(error);
-        }
+    if (emailEvents?.length) {
+      try {
+        triggerBulk(emailEvents.flat());
+      } catch (error) {
+        await io.logger.debug(error);
       }
     }
   },

diff --git a/packages/jobs/src/transactions/sync.ts b/packages/jobs/src/transactions/sync.ts
@@ -78,7 +78,13 @@ client.defineJob({
             name: Events.TRANSACTIONS_NOTIFICATION,
             payload: {
               teamId,
-              transactions: transactionsData,
+              transactions: transactionsData.map((transaction) => ({
+                id: transaction.id,
+                date: transaction.date,
+                amount: transaction.amount,
+                name: transaction.name,
+                currency: transaction.currency,
+              })),
             },
           });