tbelway/immich-quadlet
1
0
Fork 0
forked from Cutlery/immich
Code Pull Requests Activity

also check offline status

Browse Source
This commit is contained in:
Jonathan Jogenfors 2024-03-14 12:17:28 +01:00
parent 4ba95bb0a6
commit 95b57f082e
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
server/src/domain/library/library.service.ts
View File

@ -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++;