From 42a36f1820c6119921c62a44a9f062bc2caa9e22 Mon Sep 17 00:00:00 2001
From: Hongbo Wu <hongbo@omnivore.app>
Date: Mon, 8 Jan 2024 12:20:31 +0800
Subject: [PATCH] log when retrieved 0 items

---
 packages/integration-handler/src/index.ts | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

diff --git a/packages/integration-handler/src/index.ts b/packages/integration-handler/src/index.ts
index f9d657297..0aebced4d 100644
--- a/packages/integration-handler/src/index.ts
+++ b/packages/integration-handler/src/index.ts
@@ -127,15 +127,16 @@ export const exporter = Sentry.GCPFunction.wrapHttpFunction(
         hasMore = response.data.search.pageInfo.hasNextPage
         after = response.data.search.pageInfo.endCursor
         const items = response.data.search.edges.map((edge) => edge.node)
-        if (items.length === 0) {
-          break
-        }
-
+        const size = items.length
         console.log('exporting items...', {
           userId: claims.uid,
-          total: items.length,
+          size,
           hasMore,
         })
+
+        if (size === 0) {
+          break
+        }
         const synced = await client.export(claims.token, items)
         if (!synced) {
           console.error('failed to export item', {
@@ -144,16 +145,17 @@ export const exporter = Sentry.GCPFunction.wrapHttpFunction(
           return res.status(400).send('Failed to sync')
         }
 
+        const lastItemUpdatedAt = items[size - 1].updatedAt
         console.log('updating integration...', {
           userId: claims.uid,
           integrationId,
-          syncedAt: items[items.length - 1].updatedAt,
+          syncedAt: lastItemUpdatedAt,
         })
         // update integration syncedAt if successful
         const updated = await updateIntegration(
           REST_BACKEND_ENDPOINT,
           integrationId,
-          items[items.length - 1].updatedAt,
+          lastItemUpdatedAt,
           integrationName,
           claims.token,
           systemToken,