refactor: update page token variable names and adjust batch size for …

…OneDrive services
panoratech · Dec 21, 2024 · 1f0ac35 · 1f0ac35
1 parent 6d13386
commit 1f0ac35
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/packages/api/src/filestorage/file/services/googledrive/index.ts b/packages/api/src/filestorage/file/services/googledrive/index.ts
@@ -270,7 +270,7 @@ export class GoogleDriveService implements IFileService {
     const {
       linkedUserId,
       query,
-      pageTokenFiles,
+      pageToken,
       pageTokenFolders,
       connectionId,
       custom_field_mappings,
@@ -284,7 +284,7 @@ export class GoogleDriveService implements IFileService {
         custom_field_mappings,
         ingestParams,
       },
-      pageTokenFiles,
+      pageToken,
     );
   }
 

diff --git a/packages/api/src/filestorage/file/services/onedrive/index.ts b/packages/api/src/filestorage/file/services/onedrive/index.ts
@@ -281,7 +281,7 @@ export class OnedriveService implements IFileService {
   ): Promise<OnedriveFileOutput[]> {
     const allPermissions: OnedrivePermissionOutput[] = [];
     const fileIdToRemotePermissionIdMap: Map<string, string[]> = new Map();
-    const batchSize = 10; // simultaneous requests
+    const batchSize = 4; // simultaneous requests
 
     const files = allFiles.filter((f) => !f.deleted);
 

diff --git a/packages/api/src/filestorage/folder/services/googledrive/index.ts b/packages/api/src/filestorage/folder/services/googledrive/index.ts
@@ -130,7 +130,7 @@ export class GoogleDriveFolderService implements IFolderService {
 
       const lastSyncTime = await this.getLastSyncTime(connection.id_connection);
       const isFirstSync = !lastSyncTime;
-      const folders = isFirstSync
+      const folders = !isFirstSync
         ? await this.getFoldersIncremental(
             auth,
             connection.id_connection,

diff --git a/packages/api/src/filestorage/folder/services/onedrive/index.ts b/packages/api/src/filestorage/folder/services/onedrive/index.ts
@@ -352,7 +352,7 @@ export class OnedriveService implements IFolderService {
   ): Promise<OnedriveFolderOutput[]> {
     const allPermissions: OnedrivePermissionOutput[] = [];
     const folderIdToRemotePermissionIdMap: Map<string, string[]> = new Map();
-    const batchSize = 10; // simultaneous requests
+    const batchSize = 4; // simultaneous requests
 
     const folders = allFolders.filter((f) => !f.deleted);