X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Futils%2FFileUtils.ts;h=bc8dd07c24725d990ae282056fc5ab8d4243b942;hb=4ccf551d961ef001acef6fafe1165ad9b6dac4e3;hp=e36e85f73f5b11393899e4f8f9d83cf36dd346e5;hpb=d5bd1c008c3b2fbe6426ae12e1e12afe97807c57;p=e-mobility-charging-stations-simulator.git diff --git a/src/utils/FileUtils.ts b/src/utils/FileUtils.ts index e36e85f7..bc8dd07c 100644 --- a/src/utils/FileUtils.ts +++ b/src/utils/FileUtils.ts @@ -1,95 +1,38 @@ -import { EmptyObject } from '../types/EmptyObject'; -import { FileType } from '../types/FileType'; -import { HandleErrorParams } from '../types/Error'; -import { JsonType } from '../types/JsonType'; -import Utils from './Utils'; -import chalk from 'chalk'; -import fs from 'fs'; -import logger from './Logger'; +import { type FSWatcher, type WatchListener, readFileSync, watch } from 'node:fs' -export default class FileUtils { - private constructor() { - // This is intentional - } +import { handleFileException } from './ErrorUtils.js' +import { logger } from './Logger.js' +import { isNotEmptyString } from './Utils.js' +import type { FileType, JsonType } from '../types/index.js' - public static watchJsonFile( - logPrefix: 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) { +export const watchJsonFile = ( + file: string, + fileType: FileType, + logPrefix: string, + refreshedVariable?: T, + listener: WatchListener = (event, filename) => { + if (isNotEmptyString(filename) && event === 'change') { try { - return fs.watch(file, listener); + logger.debug(`${logPrefix} ${fileType} file ${file} have changed, reload`) + refreshedVariable != null && + (refreshedVariable = JSON.parse(readFileSync(file, 'utf8')) as T) } catch (error) { - FileUtils.handleFileException(logPrefix, fileType, file, error as NodeJS.ErrnoException, { - throwError: false, - }); + handleFileException(file, fileType, error as NodeJS.ErrnoException, logPrefix, { + 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 = !Utils.isEmptyString(logPrefix) ? logPrefix + ' ' : ''; - if (error.code === 'ENOENT') { - if (params?.consoleOut) { - console.warn( - chalk.green(prefix) + chalk.yellow(fileType + ' file ' + file + ' not found: '), - error - ); - } else { - logger.warn(prefix + fileType + ' file ' + file + ' not found: %j', error); - } - } else if (error.code === 'EEXIST') { - if (params?.consoleOut) { - console.warn( - chalk.green(prefix) + chalk.yellow(fileType + ' file ' + file + ' already exists: '), - error - ); - } else { - logger.warn(prefix + fileType + ' file ' + file + ' already exists: %j', error); - } - } else if (error.code === 'EACCES') { - if (params?.consoleOut) { - console.warn( - chalk.green(prefix) + chalk.yellow(fileType + ' file ' + file + ' access denied: '), - error - ); - } else { - logger.warn(prefix + fileType + ' file ' + file + ' access denied: %j', error); - } - } else { - if (params?.consoleOut) { - console.warn( - chalk.green(prefix) + chalk.yellow(fileType + ' file ' + file + ' error: '), - error - ); - } else { - logger.warn(prefix + fileType + ' file ' + file + ' error: %j', error); - } - if (params?.throwError) { - throw error; - } +): 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`) } }