X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Futils%2FUtils.ts;h=83c1e3f7490a4dd9fff5976c2367a5eb548e7dfa;hb=361c98f57255e5b91d123d5f2ba43ab533134b1a;hp=607843cd380e6932dcdbdc58e65e3564ae4b6b2b;hpb=45999aab924e2662784f4c7b0fbf5d4622a18d92;p=e-mobility-charging-stations-simulator.git diff --git a/src/utils/Utils.ts b/src/utils/Utils.ts index 607843cd..83c1e3f7 100644 --- a/src/utils/Utils.ts +++ b/src/utils/Utils.ts @@ -1,15 +1,19 @@ -import crypto from 'crypto'; +import crypto from 'node:crypto'; +import util from 'node:util'; -import { WebSocketCloseEventStatusString } from '../types/WebSocket'; +import clone from 'just-clone'; -export default class Utils { +import { Constants } from './Constants'; +import { WebSocketCloseEventStatusString } from '../types'; + +export class Utils { private constructor() { // This is intentional } - public static logPrefix(prefixString = ''): string { - return new Date().toLocaleString() + prefixString; - } + public static logPrefix = (prefixString = ''): string => { + return `${new Date().toLocaleString()}${prefixString}`; + }; public static generateUUID(): string { return crypto.randomUUID(); @@ -35,107 +39,118 @@ export default class Utils { let secondsStr = seconds.toString(); if (hours < 10) { - hoursStr = '0' + hours.toString(); + hoursStr = `0${hours.toString()}`; } if (minutes < 10) { - minutesStr = '0' + minutes.toString(); + minutesStr = `0${minutes.toString()}`; } if (seconds < 10) { - secondsStr = '0' + seconds.toString(); + secondsStr = `0${seconds.toString()}`; } - return hoursStr + ':' + minutesStr + ':' + secondsStr.substring(0, 6); + return `${hoursStr}:${minutesStr}:${secondsStr.substring(0, 6)}`; } public static formatDurationSeconds(duration: number): string { return Utils.formatDurationMilliSeconds(duration * 1000); } - public static convertToDate(value: unknown): Date { - // Check - if (!value) { - return value as Date; + public static convertToDate( + value: Date | string | number | null | undefined + ): Date | null | undefined { + if (Utils.isNullOrUndefined(value)) { + return value as null | undefined; } - // Check Type - if (!(value instanceof Date)) { - return new Date(value as string); + if (value instanceof Date) { + return value; } - return value; + if (Utils.isString(value) || typeof value === 'number') { + return new Date(value); + } + return null; } public static convertToInt(value: unknown): number { - let changedValue: number = value as number; if (!value) { return 0; } + let changedValue: number = value as number; if (Number.isSafeInteger(value)) { return value as number; } - // Check + if (typeof value === 'number') { + return Math.trunc(value); + } if (Utils.isString(value)) { - // Create Object changedValue = parseInt(value as string); } + if (isNaN(changedValue)) { + throw new Error(`Cannot convert to integer: ${value.toString()}`); + } return changedValue; } public static convertToFloat(value: unknown): number { - let changedValue: number = value as number; if (!value) { return 0; } - // Check + let changedValue: number = value as number; if (Utils.isString(value)) { - // Create Object changedValue = parseFloat(value as string); } + if (isNaN(changedValue)) { + throw new Error(`Cannot convert to float: ${value.toString()}`); + } return changedValue; } public static convertToBoolean(value: unknown): boolean { let result = false; - // Check boolean if (value) { // Check the type if (typeof value === 'boolean') { - // Already a boolean - result = value; - } else { - // Convert - result = value === 'true'; + return value; + } else if ( + Utils.isString(value) && + ((value as string).toLowerCase() === 'true' || value === '1') + ) { + result = true; + } else if (typeof value === 'number' && value === 1) { + result = true; } } return result; } - public static getRandomFloat(max = Number.MAX_VALUE, min = 0, negative = false): number { - if (max < min || max < 0 || min < 0) { + public static getRandomFloat(max = Number.MAX_VALUE, min = 0): number { + if (max < min) { throw new RangeError('Invalid interval'); } - const randomPositiveFloat = crypto.randomBytes(4).readUInt32LE() / 0xffffffff; - const sign = negative && randomPositiveFloat < 0.5 ? -1 : 1; - return sign * (randomPositiveFloat * (max - min) + min); - } - - public static getRandomInteger(max = Number.MAX_SAFE_INTEGER, min = 0): number { - if (max < min || max < 0 || min < 0) { + if (max - min === Infinity) { throw new RangeError('Invalid interval'); } + return (crypto.randomBytes(4).readUInt32LE() / 0xffffffff) * (max - min) + min; + } + + public static getRandomInteger(max = Constants.MAX_RANDOM_INTEGER, min = 0): number { max = Math.floor(max); if (!Utils.isNullOrUndefined(min) && min !== 0) { min = Math.ceil(min); - return Math.floor(Utils.secureRandom() * (max - min + 1)) + min; + return Math.floor(crypto.randomInt(min, max + 1)); } - return Math.floor(Utils.secureRandom() * (max + 1)); + return Math.floor(crypto.randomInt(max + 1)); } + /** + * Rounds the given number to the given scale. + * The rounding is done using the "round half away from zero" method. + * + * @param numberValue - The number to round. + * @param scale - The scale to round to. + * @returns The rounded number. + */ public static roundTo(numberValue: number, scale: number): number { const roundPower = Math.pow(10, scale); - return Math.round(numberValue * roundPower) / roundPower; - } - - public static truncTo(numberValue: number, scale: number): number { - const truncPower = Math.pow(10, scale); - return Math.trunc(numberValue * truncPower) / truncPower; + return Math.round(numberValue * roundPower * (1 + Number.EPSILON)) / roundPower; } public static getRandomFloatRounded(max = Number.MAX_VALUE, min = 0, scale = 2): number { @@ -161,12 +176,28 @@ export default class Utils { ); } - public static cloneObject(object: T): T { - return JSON.parse(JSON.stringify(object)) as T; + public static isObject(item: unknown): boolean { + return ( + Utils.isNullOrUndefined(item) === false && + typeof item === 'object' && + Array.isArray(item) === false + ); + } + + public static cloneObject(object: T): T { + return clone(object); + } + + public static hasOwnProp(object: unknown, property: PropertyKey): boolean { + return Utils.isObject(object) && Object.hasOwn(object as object, property); + } + + public static isCFEnvironment(): boolean { + return !Utils.isNullOrUndefined(process.env.VCAP_APPLICATION); } public static isIterable(obj: T): boolean { - return obj ? typeof obj[Symbol.iterator] === 'function' : false; + return !Utils.isNullOrUndefined(obj) ? typeof obj[Symbol.iterator] === 'function' : false; } public static isString(value: unknown): boolean { @@ -174,26 +205,31 @@ export default class Utils { } public static isEmptyString(value: unknown): boolean { - return Utils.isString(value) && (value as string).trim().length === 0; + return ( + Utils.isNullOrUndefined(value) || + (Utils.isString(value) && (value as string).trim().length === 0) + ); + } + + public static isNotEmptyString(value: unknown): boolean { + return Utils.isString(value) && (value as string).trim().length > 0; } public static isUndefined(value: unknown): boolean { - return typeof value === 'undefined'; + return value === undefined; } public static isNullOrUndefined(value: unknown): boolean { // eslint-disable-next-line eqeqeq, no-eq-null - return value == null ? true : false; + return value == null; } - public static isEmptyArray(object: unknown | unknown[]): boolean { - if (!Array.isArray(object)) { - return false; - } - if (object.length > 0) { - return false; - } - return true; + public static isEmptyArray(object: unknown): boolean { + return Array.isArray(object) && object.length === 0; + } + + public static isNotEmptyArray(object: unknown): boolean { + return Array.isArray(object) && object.length > 0; } public static isEmptyObject(obj: object): boolean { @@ -212,15 +248,21 @@ export default class Utils { `${str.slice(0, pos)}${subStr}${str.slice(pos)}`; /** - * @param [retryNumber=0] + * Computes the retry delay in milliseconds using an exponential backoff algorithm. + * + * @param retryNumber - the number of retries that have already been attempted * @returns delay in milliseconds */ - public static exponentialDelay(retryNumber = 0): number { + public static exponentialDelay(retryNumber = 0, maxDelayRatio = 0.2): number { const delay = Math.pow(2, retryNumber) * 100; - const randomSum = delay * 0.2 * Utils.secureRandom(); // 0-20% of the delay + const randomSum = delay * maxDelayRatio * Utils.secureRandom(); // 0-20% of the delay return delay + randomSum; } + public static isPromisePending(promise: Promise): boolean { + return util.inspect(promise).includes('pending'); + } + public static async promiseWithTimeout( promise: Promise, timeoutMs: number, @@ -232,7 +274,10 @@ export default class Utils { // Create a timeout promise that rejects in timeout milliseconds const timeoutPromise = new Promise((_, reject) => { setTimeout(() => { - timeoutCallback(); + if (Utils.isPromisePending(promise)) { + timeoutCallback(); + // FIXME: The original promise shall be canceled + } reject(timeoutError); }, timeoutMs); }); @@ -242,7 +287,7 @@ export default class Utils { } /** - * Generate a cryptographically secure random number in the [0,1[ range + * Generates a cryptographically secure random number in the [0,1[ range * * @returns */ @@ -251,7 +296,7 @@ export default class Utils { } public static JSONStringifyWithMapSupport( - obj: Record | Record[], + obj: Record | Record[] | Map, space?: number ): string { return JSON.stringify( @@ -270,9 +315,9 @@ export default class Utils { } /** - * Convert websocket error code to human readable string message + * Converts websocket error code to human readable string message * - * @param code websocket error code + * @param code - websocket error code * @returns human readable string message */ public static getWebSocketCloseEventStatusString(code: number): string {