add simplefin batch sync to api

packages/loot-core/src/server/api.ts

@@ -248,13 +248,41 @@ handlers['api/sync'] = async function () {
 };
 
 handlers['api/bank-sync'] = async function (args) {
-  const { errors } = await handlers['accounts-bank-sync']({
-    id: args?.accountId,
-  });
+  const batchSync = args?.accountId == null;
+  const allErrors = [];
+
+  if (!batchSync) {
+    const { errors } = await handlers['accounts-bank-sync']({
+      id: args?.accountId,
+    });
+
+    allErrors.push(errors);
+  } else {
+    const accountsData = await handlers['accounts-get']();
+    const accountIdsToSync = accountsData.map(a => a.id);
+    const simpleFinAccounts = accountsData.filter(
+      a => a.account_sync_source === 'simpleFin',
+    );
+    const simpleFinAccountIds = simpleFinAccounts.map(a => a.id);
+
+    if (simpleFinAccounts.length > 1) {
+      const res = await handlers['simplefin-batch-sync']({
+        ids: simpleFinAccountIds,
+      });
+
+      res.forEach(a => allErrors.push(...a.res.errors));
+    }
+
+    const { errors } = await handlers['accounts-bank-sync']({
+      ids: accountIdsToSync.filter(a => !simpleFinAccountIds.includes(a)),
+    });
+
+    allErrors.push(...errors);
+  }
 
-  const [firstError] = errors;
-  if (firstError) {
-    throw new Error(getBankSyncError(firstError));
+  const errors = allErrors.filter(e => e != null);
+  if (errors.length > 0) {
+    throw new Error(getBankSyncError(errors[0]));
   }
 };
 

packages/loot-core/src/server/main.ts

@@ -1099,17 +1099,25 @@ function handleSyncError(err, acct) {
   };
 }
 
-handlers['accounts-bank-sync'] = async function ({ id }) {
+handlers['accounts-bank-sync'] = async function ({ id, ids }) {
   const [[, userId], [, userKey]] = await asyncStorage.multiGet([
     'user-id',
     'user-key',
   ]);
+
+  if ((id && ids) || (!id && !ids)) {
+    throw new Error('Specify either id or ids, but not both');
+  }
+
   const accounts = await db.runQuery(
-    `SELECT a.*, b.bank_id as bankId FROM accounts a
-         LEFT JOIN banks b ON a.bank = b.id
-         WHERE a.tombstone = 0 AND a.closed = 0 ${id ? 'AND a.id = ?' : ''}
-         ORDER BY a.offbudget, a.sort_order`,
-    id ? [id] : [],
+    `  SELECT a.*, b.bank_id as bankId 
+  FROM accounts a
+  LEFT JOIN banks b ON a.bank = b.id
+  WHERE a.tombstone = 0 AND a.closed = 0 
+  ${id ? 'AND a.id = ?' : ''} 
+  ${ids ? `AND a.id IN (${ids.map(() => '?').join(', ')})` : ''}
+  ORDER BY a.offbudget, a.sort_order`,
+    id ? [id] : ids || [],
     true,
   );
 
@@ -1162,7 +1170,11 @@ handlers['simplefin-batch-sync'] = async function ({ ids = [] }) {
   const accounts = await db.runQuery(
     `SELECT a.*, b.bank_id as bankId FROM accounts a
          LEFT JOIN banks b ON a.bank = b.id
-         WHERE a.tombstone = 0 AND a.closed = 0 ${ids.length ? `AND a.id IN (${ids.map(() => '?').join(', ')})` : ''}
+         WHERE
+          a.tombstone = 0
+          AND a.closed = 0
+          AND a.account_sync_source = 'simpleFin'
+          ${ids.length ? `AND a.id IN (${ids.map(() => '?').join(', ')})` : ''}
          ORDER BY a.offbudget, a.sort_order`,
     ids.length ? ids : [],
     true,

packages/loot-core/src/types/server-handlers.d.ts

@@ -196,10 +196,12 @@ export interface ServerHandlers {
   'simplefin-batch-sync': ({ ids }: { ids: string[] }) => Promise<
     {
       accountId: string;
-      errors;
-      newTransactions;
-      matchedTransactions;
-      updatedAccounts;
+      res: {
+        errors;
+        newTransactions;
+        matchedTransactions;
+        updatedAccounts;
+      };
     }[]
   >;
 
@@ -223,7 +225,7 @@ export interface ServerHandlers {
     | { error: 'failed' }
   >;
 
-  'accounts-bank-sync': (arg: { id?: string }) => Promise<{
+  'accounts-bank-sync': (arg: { id?: string; ids?: string[] }) => Promise<{
     errors;
     newTransactions;
     matchedTransactions;

upcoming-release-notes/3821.md

@@ -0,0 +1,6 @@
+---
+category: Enhancements
+authors: [matt-fidd]
+---
+
+Implement SimpleFin batch sync in the API