From 3f56cbeddf4adaa1f24af518afe8c6c97e85db5b Mon Sep 17 00:00:00 2001
From: Jonathan Jogenfors <jonathan@jogenfors.se>
Date: Sun, 17 Mar 2024 00:30:13 +0100
Subject: [PATCH] don't double batch

---
 server/src/domain/library/library.service.ts | 28 +++++++++-----------
 1 file changed, 12 insertions(+), 16 deletions(-)

diff --git a/server/src/domain/library/library.service.ts b/server/src/domain/library/library.service.ts
index 4f0a61c5b..54dc98f18 100644
--- a/server/src/domain/library/library.service.ts
+++ b/server/src/domain/library/library.service.ts
@@ -303,23 +303,19 @@ export class LibraryService extends EventEmitter {
   private async scanAssets(libraryId: string, assetPaths: string[], ownerId: string, force = false) {
     this.logger.verbose(`Queuing refresh of ${assetPaths.length} asset(s)`);
 
-    // We perform this in batches to save on memory when performing large refreshes (greater than 1M assets)
-    for (let i = 0; i < assetPaths.length; i += LIBRARY_SCAN_BATCH_SIZE) {
-      const batch = assetPaths.slice(i, i + LIBRARY_SCAN_BATCH_SIZE);
-      await this.jobRepository.queueAll(
-        batch.map((assetPath) => ({
-          name: JobName.LIBRARY_SCAN_ASSET,
-          data: {
-            id: libraryId,
-            assetPath: assetPath,
-            ownerId,
-            force,
-          },
-        })),
-      );
-    }
+    await this.jobRepository.queueAll(
+      assetPaths.map((assetPath) => ({
+        name: JobName.LIBRARY_SCAN_ASSET,
+        data: {
+          id: libraryId,
+          assetPath: assetPath,
+          ownerId,
+          force,
+        },
+      })),
+    );
 
-    this.logger.debug('Asset refresh queue completed');
+    this.logger.verbose('Asset refresh queued');
   }
 
   private async validateImportPath(importPath: string): Promise<ValidateLibraryImportPathResponseDto> {