From fa3a70a2adc9f43173ff63f803c8323c6d3a3804 Mon Sep 17 00:00:00 2001 From: Jonathan Jogenfors Date: Fri, 15 Mar 2024 23:33:20 +0100 Subject: [PATCH] rename scan to check --- server/src/domain/library/library.service.ts | 8 ++++---- server/src/microservices/app.service.ts | 2 +- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/server/src/domain/library/library.service.ts b/server/src/domain/library/library.service.ts index 3ccba0d6d..45ae7fa3d 100644 --- a/server/src/domain/library/library.service.ts +++ b/server/src/domain/library/library.service.ts @@ -611,13 +611,13 @@ export class LibraryService extends EventEmitter { return true; } - async handleQueueOfflineScan(job: IEntityJob): Promise { - this.logger.log(`Checking for offline files in library: ${job.id}`); - const assetPagination = usePagination(JOBS_ASSET_PAGINATION_SIZE, (pagination) => + async handleQueueOnlineStatusCheck(job: IEntityJob): Promise { + this.logger.log(`Checking files for online/offline status in library: ${job.id}`); + const onlineAssets = usePagination(JOBS_ASSET_PAGINATION_SIZE, (pagination) => this.assetRepository.getWith(pagination, WithProperty.IS_ONLINE, job.id), ); - for await (const assets of assetPagination) { + for await (const assets of onlineAssets) { this.logger.debug(`Checking if ${assets.length} assets are still online`); await this.jobRepository.queueAll( assets.map((asset) => ({ diff --git a/server/src/microservices/app.service.ts b/server/src/microservices/app.service.ts index 68de5fbcd..75db1045b 100644 --- a/server/src/microservices/app.service.ts +++ b/server/src/microservices/app.service.ts @@ -77,7 +77,7 @@ export class AppService { [JobName.LIBRARY_SCAN_ASSET]: (data) => this.libraryService.handleAssetRefresh(data), [JobName.LIBRARY_SCAN]: (data) => this.libraryService.handleQueueAssetRefresh(data), [JobName.LIBRARY_DELETE]: (data) => this.libraryService.handleDeleteLibrary(data), - [JobName.LIBRARY_SCAN_OFFLINE]: (data) => this.libraryService.handleQueueOfflineScan(data), + [JobName.LIBRARY_SCAN_OFFLINE]: (data) => this.libraryService.handleQueueOnlineStatusCheck(data), [JobName.LIBRARY_CHECK_IF_ASSET_ONLINE]: (data) => this.libraryService.handleAssetOnlineCheck(data), [JobName.LIBRARY_REMOVE_OFFLINE]: (data) => this.libraryService.handleOfflineRemoval(data), [JobName.LIBRARY_QUEUE_SCAN_ALL]: (data) => this.libraryService.handleQueueAllScan(data),