diff --git a/src/service/cache/archive.service.js b/src/service/cache/archive.service.js index f6d829a80c..49e460afd2 100644 --- a/src/service/cache/archive.service.js +++ b/src/service/cache/archive.service.js @@ -14,7 +14,7 @@ const ARCHIVE_FOLDER = 'archive' class ArchiveService { /** * @param {String} northId - The North ID connector - * @param {LoggerService} loggerService - The logger + * @param {Object} logger - The logger * @param {String} baseFolder - The North cache folder generated as north-connectorId. This base folder can * be in data-stream or history-query folder depending on the connector use case * @param {Boolean} enabled - If the archive mode for this North connector is enabled @@ -23,13 +23,13 @@ class ArchiveService { */ constructor( northId, - loggerService, + logger, baseFolder, enabled, retentionDuration, ) { this.northId = northId - this.loggerService = loggerService + this.logger = logger this.baseFolder = baseFolder this.enabled = enabled // Convert from hours to ms to compare with mtimeMs (file modified time in ms) @@ -72,17 +72,17 @@ class ArchiveService { // Move cache file into the archive folder try { await fs.rename(filePathInCache, archivePath) - this.loggerService.debug(`File "${filePathInCache}" moved to "${archivePath}".`) + this.logger.debug(`File "${filePathInCache}" moved to "${archivePath}".`) } catch (renameError) { - this.loggerService.error(renameError) + this.logger.error(renameError) } } else { // Delete original file try { await fs.unlink(filePathInCache) - this.loggerService.debug(`File "${filePathInCache}" removed from disk.`) + this.logger.debug(`File "${filePathInCache}" removed from disk.`) } catch (unlinkError) { - this.loggerService.error(unlinkError) + this.logger.error(unlinkError) } } } @@ -92,7 +92,7 @@ class ArchiveService { * @return {void} */ async refreshArchiveFolder() { - this.loggerService.debug('Parse archive folder to remove old files.') + this.logger.debug('Parse archive folder to remove old files.') // If a timeout already runs, clear it if (this.archiveTimeout) { clearTimeout(this.archiveTimeout) @@ -103,7 +103,7 @@ class ArchiveService { files = await fs.readdir(this.archiveFolder) } catch (error) { // If the archive folder doest not exist (removed by the user for example), an error is logged - this.loggerService.error(error) + this.logger.error(error) } if (files.length > 0) { const referenceDate = new Date().getTime() @@ -113,7 +113,7 @@ class ArchiveService { async () => this.removeFileIfTooOld(file, referenceDate, this.archiveFolder), ), Promise.resolve()) } else { - this.loggerService.debug(`The archive folder "${this.archiveFolder}" is empty. Nothing to delete.`) + this.logger.debug(`The archive folder "${this.archiveFolder}" is empty. Nothing to delete.`) } this.archiveTimeout = setTimeout(this.refreshArchiveFolder.bind(this), ARCHIVE_TIMEOUT) } @@ -131,14 +131,14 @@ class ArchiveService { // If a file is being written or corrupted, the stat method can fail an error is logged stats = await fs.stat(path.join(archiveFolder, filename)) } catch (error) { - this.loggerService.error(error) + this.logger.error(error) } if (stats && stats.mtimeMs + this.retentionDuration < referenceDate) { try { await fs.unlink(path.join(archiveFolder, filename)) - this.loggerService.debug(`File "${path.join(archiveFolder, filename)}" removed from archive.`) + this.logger.debug(`File "${path.join(archiveFolder, filename)}" removed from archive.`) } catch (unlinkError) { - this.loggerService.error(unlinkError) + this.logger.error(unlinkError) } } } diff --git a/src/service/cache/file-cache.service.js b/src/service/cache/file-cache.service.js index 82bf84b22f..cd4ebd7364 100644 --- a/src/service/cache/file-cache.service.js +++ b/src/service/cache/file-cache.service.js @@ -17,7 +17,7 @@ const ERROR_FOLDER = 'files-errors' class FileCacheService { /** * @param {String} northId - The North ID connector - * @param {Logger} logger - The logger + * @param {Object} logger - The logger * @param {String} baseFolder - The North cache folder generated as north-connectorId. This base folder can * be in data-stream or history-query folder depending on the connector use case @param {Function} northSendFilesCallback - Method used by the North to handle values @@ -361,7 +361,7 @@ class FileCacheService { if (filenames.length > 0) { await this.removeErrorFiles(filenames) } else { - this.logger.debug(`The archive folder "${this.archiveFolder}" is empty. Nothing to delete.`) + this.logger.debug(`The error folder "${this.errorFolder}" is empty. Nothing to delete.`) } } @@ -374,7 +374,7 @@ class FileCacheService { if (filenames.length > 0) { await this.retryErrorFiles(filenames) } else { - this.logger.debug(`The archive folder "${this.archiveFolder}" is empty. Nothing to delete.`) + this.logger.debug(`The error folder "${this.errorFolder}" is empty. Nothing to delete.`) } } diff --git a/src/service/cache/value-cache.service.js b/src/service/cache/value-cache.service.js index 2a7cdcf0c5..04811a4cdd 100644 --- a/src/service/cache/value-cache.service.js +++ b/src/service/cache/value-cache.service.js @@ -19,7 +19,7 @@ const ERROR_FOLDER = 'values-errors' class ValueCacheService { /** * @param {String} northId - The North ID connector - * @param {LoggerService} logger - The logger + * @param {Object} logger - The logger * @param {String} baseFolder - The North cache folder generated as north-connectorId. This base folder can * be in data-stream or history-query folder depending on the connector use case * @param {Function} northSendValuesCallback - Method used by the North to handle values