From 95b57f082ed13cd6a23541a47c76c741d1c38e83 Mon Sep 17 00:00:00 2001
From: Jonathan Jogenfors <jonathan@jogenfors.se>
Date: Thu, 14 Mar 2024 12:17:28 +0100
Subject: [PATCH] also check offline status

---
 server/src/domain/library/library.service.ts | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git a/server/src/domain/library/library.service.ts b/server/src/domain/library/library.service.ts
index 8968a5bc9..2699f996a 100644
--- a/server/src/domain/library/library.service.ts
+++ b/server/src/domain/library/library.service.ts
@@ -680,13 +680,13 @@ export class LibraryService extends EventEmitter {
       .filter((validation) => validation.isValid)
       .map((validation) => validation.importPath);
 
+    await this.handleQueueOfflineScan(job);
+
     const generator = this.storageRepository.walk({
       pathsToCrawl: validImportPaths,
       exclusionPatterns: library.exclusionPatterns,
     });
 
-    const shouldScanAll = job.refreshAllFiles || job.refreshModifiedFiles;
-
     let crawledAssetPaths: string[] = [];
     let assetIdsToMarkOnline: string[] = [];
 
@@ -698,15 +698,12 @@ export class LibraryService extends EventEmitter {
         await this.assetRepository.updateAll(assetIdsToMarkOnline, { isOffline: false });
       }
 
+      this.logger.log(`Queuing refresh for ${crawledAssetPaths.length} asset(s) in library ${job.id}`);
+
       await this.scanAssets(job.id, crawledAssetPaths, library.ownerId, job.refreshAllFiles ?? false);
     };
 
     for await (const filePath of generator) {
-      const asset = await this.assetRepository.getByLibraryIdAndOriginalPath(job.id, filePath);
-      if (asset && asset.isOffline) {
-        // Mark this asset as online
-        assetIdsToMarkOnline.push(asset.id);
-      }
       crawledAssetPaths.push(filePath);
       pathCounter++;