X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Futils%2FFileUtils.ts;h=87a8733b08f7e9108eb39f81b4d809200fb016d6;hb=6d8b0b0e25a198e2328d165b9413f6f4d13db2e7;hp=0e8efc61e38cf593143a085631adb5f2b8db2efe;hpb=e7aeea18e189dd087c8f951cf77a253e2818ae90;p=e-mobility-charging-stations-simulator.git diff --git a/src/utils/FileUtils.ts b/src/utils/FileUtils.ts index 0e8efc61..87a8733b 100644 --- a/src/utils/FileUtils.ts +++ b/src/utils/FileUtils.ts @@ -1,56 +1,80 @@ -import { EmptyObject } from '../types/EmptyObject'; -import { HandleErrorParams } from '../types/Error'; +import fs from 'fs'; + import chalk from 'chalk'; + import logger from './Logger'; +import Utils from './Utils'; +import type { EmptyObject } from '../types/EmptyObject'; +import type { HandleErrorParams } from '../types/Error'; +import type { FileType } from '../types/FileType'; +import type { JsonType } from '../types/JsonType'; export default class FileUtils { - static handleFileException( + private constructor() { + // This is intentional + } + + public static watchJsonFile( logPrefix: string, - fileType: string, - filePath: string, + fileType: FileType, + file: string, + refreshedVariable?: T, + listener: fs.WatchListener = (event, filename) => { + if (filename && event === 'change') { + try { + logger.debug(`${logPrefix} ${fileType} file ${file} + ' have changed, reload'`); + refreshedVariable && (refreshedVariable = JSON.parse(fs.readFileSync(file, 'utf8')) as T); + } catch (error) { + FileUtils.handleFileException(logPrefix, fileType, file, error as NodeJS.ErrnoException, { + throwError: false, + }); + } + } + } + ): fs.FSWatcher { + if (file) { + try { + return fs.watch(file, listener); + } catch (error) { + FileUtils.handleFileException(logPrefix, fileType, file, error as NodeJS.ErrnoException, { + throwError: false, + }); + } + } else { + logger.info(`${logPrefix} No ${fileType} file to watch given. Not monitoring its changes`); + } + } + + public static handleFileException( + logPrefix: string, + fileType: FileType, + file: 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); - } + const prefix = !Utils.isEmptyString(logPrefix) ? logPrefix + ' ' : ''; + let logMsg: string; + switch (error.code) { + case 'ENOENT': + logMsg = `${fileType} file ${file} not found:`; + break; + case 'EEXIST': + logMsg = `${fileType} file ${file} already exists:`; + break; + case 'EACCES': + logMsg = `${fileType} file ${file} access denied:`; + break; + default: + logMsg = `${fileType} file ${file} error:`; + } + if (params?.consoleOut) { + logMsg = `${logMsg} `; + console.warn(`${chalk.green(prefix)}${chalk.yellow(logMsg)}`, 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; - } + logger.warn(`${prefix}${logMsg}`, error); + } + if (params?.throwError) { + throw error; } } }