Update tests

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

Hide file tree

Showing 4 changed files with 16 additions and 22 deletions.
diff --git a/packages/jobs/src/transactions/initial-sync.ts b/packages/jobs/src/transactions/initial-sync.ts
@@ -47,7 +47,7 @@ client.defineJob({
     const { data: accountsData } = await supabase
       .from("bank_accounts")
       .select(
-        "id, team_id, account_id, bank_connection:bank_connection_id(provider, access_token, enrollment_id)"
+        "id, team_id, account_id, bank_connection:bank_connection_id(provider, access_token)"
       )
       .eq("team_id", teamId)
       .eq("enabled", true)

diff --git a/packages/jobs/src/transactions/manual-sync.ts b/packages/jobs/src/transactions/manual-sync.ts
@@ -25,7 +25,7 @@ client.defineJob({
     const { data: account } = await supabase
       .from("bank_accounts")
       .select(
-        "id, team_id, account_id, bank_connection:bank_connection_id(provider, access_token, enrollment_id)"
+        "id, team_id, account_id, bank_connection:bank_connection_id(provider, access_token)"
       )
       .eq("id", payload.accountId)
       .eq("enabled", true)

diff --git a/packages/jobs/src/transactions/notification.ts b/packages/jobs/src/transactions/notification.ts
@@ -69,12 +69,12 @@ client.defineJob({
     if (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}`
+        );
+      }
     }
 
     const emailPromises = usersData?.map(async ({ user, team_id }) => {
@@ -107,13 +107,13 @@ client.defineJob({
     if (emailPromises) {
       const emailEvents = await Promise.all(emailPromises);
 
-      // 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
@@ -18,17 +18,11 @@ client.defineJob({
     const { data: accountsData, error: accountsError } = await supabase
       .from("bank_accounts")
       .select(
-        "id, team_id, account_id, bank_connection:bank_connection_id(provider, access_token, enrollment_id)"
+        "id, team_id, account_id, bank_connection:bank_connection_id(provider, access_token)"
       )
       .eq("team_id", teamId)
       .eq("enabled", true);
 
-    if (!accountsData?.length) {
-      // NOTE: Remove all old schedulers
-      const event = await scheduler.unregister(ctx.source.id);
-      await io.logger.debug("Unregister", event);
-    }
-
     if (accountsError) {
       await io.logger.error("Accounts Error", accountsError);
     }