X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Futils%2FFileUtils.ts;h=543a2b23c2eda50f157680f15377ee335ec697da;hb=8a4f882a2486682b72195ad978ec1d81604b452b;hp=a0d495a6b79104c92fbfd7fae2030fb365288064;hpb=e0a50bcd7ae5a1b4ce22e39935f96a8f7e1222b4;p=e-mobility-charging-stations-simulator.git diff --git a/src/utils/FileUtils.ts b/src/utils/FileUtils.ts index a0d495a6..543a2b23 100644 --- a/src/utils/FileUtils.ts +++ b/src/utils/FileUtils.ts @@ -1,38 +1,38 @@ -import { HandleErrorParams } from '../types/Error'; -import chalk from 'chalk'; -import logger from './Logger'; +import { type FSWatcher, readFileSync, watch, type WatchListener } from 'node:fs' -export default class FileUtils { - static handleFileException(logPrefix: string, fileType: string, filePath: string, error: NodeJS.ErrnoException, - params: HandleErrorParams = { throwError: true, consoleOut: false }): void { - const prefix = logPrefix.length !== 0 ? logPrefix + ' ' : ''; - if (error.code === 'ENOENT') { - if (params?.consoleOut) { - console.warn(chalk.green(prefix) + chalk.yellow(fileType + ' file ' + filePath + ' not found: '), error); - } else { - logger.warn(prefix + fileType + ' file ' + filePath + ' not found: %j', error); - } - } else if (error.code === 'EEXIST') { - if (params?.consoleOut) { - console.warn(chalk.green(prefix) + chalk.yellow(fileType + ' file ' + filePath + ' already exists: '), error); - } else { - logger.warn(prefix + fileType + ' file ' + filePath + ' already exists: %j', error); - } - } else if (error.code === 'EACCES') { - if (params?.consoleOut) { - console.warn(chalk.green(prefix) + chalk.yellow(fileType + ' file ' + filePath + ' access denied: '), error); - } else { - logger.warn(prefix + fileType + ' file ' + filePath + ' access denied: %j', error); - } - } else { - if (params?.consoleOut) { - console.warn(chalk.green(prefix) + chalk.yellow(fileType + ' file ' + filePath + ' error: '), error); - } else { - logger.warn(prefix + fileType + ' file ' + filePath + ' error: %j', error); - } - if (params?.throwError) { - throw error; +import type { FileType, JsonType } from '../types/index.js' +import { handleFileException } from './ErrorUtils.js' +import { logger } from './Logger.js' +import { isNotEmptyString } from './Utils.js' + +export const watchJsonFile = ( + file: string, + fileType: FileType, + logPrefix: string, + refreshedVariable?: T, + listener: WatchListener = (event, filename) => { + if (isNotEmptyString(filename) && event === 'change') { + try { + logger.debug(`${logPrefix} ${fileType} file ${file} have changed, reload`) + refreshedVariable != null && + (refreshedVariable = JSON.parse(readFileSync(file, 'utf8')) as T) + } catch (error) { + handleFileException(file, fileType, error as NodeJS.ErrnoException, logPrefix, { + throwError: false + }) } } } +): FSWatcher | undefined => { + if (isNotEmptyString(file)) { + try { + return watch(file, listener) + } catch (error) { + handleFileException(file, fileType, error as NodeJS.ErrnoException, logPrefix, { + throwError: false + }) + } + } else { + logger.info(`${logPrefix} No ${fileType} file to watch given. Not monitoring its changes`) + } }