fix: parse JSON response from cloudsync_network_sync

Author: damlayildiz

src/core/sync/executeSync.ts

@@ -2,12 +2,30 @@ import type { DB, QueryResult } from '@op-engineering/op-sqlite';
 import type { Logger } from '../common/logger';
 
 /**
- * Extracts the number of changes from a CloudSync query result
+ * Extracts the number of received rows from a CloudSync query result.
+ *
+ * The result row contains a JSON string:
+ * {"status":"synced|syncing|out-of-sync","localVersion":N,"serverVersion":N,"rowsReceived":N}
+ *
+ * We only use rowsReceived since polling is for downloading remote changes.
+ * The status field relates to upload state and is not relevant here.
  */
 const extractChangesFromResult = (result: QueryResult | undefined): number => {
   const firstRow = result?.rows?.[0];
-  const value = firstRow ? Object.values(firstRow)[0] : 0;
-  return typeof value === 'number' ? value : 0;
+  if (!firstRow) return 0;
+
+  const raw = Object.values(firstRow)[0];
+
+  if (typeof raw === 'string') {
+    try {
+      const parsed = JSON.parse(raw);
+      return typeof parsed.rowsReceived === 'number' ? parsed.rowsReceived : 0;
+    } catch {
+      return 0;
+    }
+  }
+
+  return 0;
 };
 
 /**
@@ -95,14 +113,14 @@ export async function executeSync(
 
       // Wait before next attempt (except on last attempt)
       if (attempt < maxAttempts - 1) {
-        await new Promise((resolve) => setTimeout(resolve, attemptDelay));
+        await new Promise<void>((resolve) => setTimeout(resolve, attemptDelay));
       }
     }
   }
 
   /** LOG RESULT */
   if (changes > 0) {
-    logger.info(`✅ Sync completed: ${changes} changes synced`);
+    logger.info(`✅ Sync completed: ${changes} changes downloaded`);
   } else {
     logger.info('✅ Sync completed: no changes');
   }