import * as plugins from './smartlog.plugins'; import { LogRouter } from './smartlog.classes.logrouter'; import { LogGroup } from '.'; export interface ISmartlogContructorOptions { logContext: plugins.smartlogInterfaces.ILogContext; minimumLogLevel?: plugins.smartlogInterfaces.TLogLevel; } export class Smartlog implements plugins.smartlogInterfaces.ILogDestination { private logContext: plugins.smartlogInterfaces.ILogContext; private minimumLogLevel: plugins.smartlogInterfaces.TLogLevel; public uniInstanceId: string = plugins.isounique.uni(); private consoleEnabled: boolean; private logRouter = new LogRouter(); public addLogDestination(logDestinationArg: plugins.smartlogInterfaces.ILogDestination) { this.logRouter.addLogDestination(logDestinationArg); } constructor(optionsArg: ISmartlogContructorOptions) { this.logContext = optionsArg.logContext; this.minimumLogLevel = optionsArg.minimumLogLevel; } // ============ // Logger Setup // ============ /** * enables console logging */ public enableConsole(optionsArg?: { captureAll: boolean }) { if (globalThis.process && optionsArg && optionsArg.captureAll) { const process = globalThis.process; const write = process.stdout.write; process.stdout.write = (...args: any) => { const logString: string = args[0]; if (!logString) { return; } if (!logString.startsWith('LOG') && typeof logString === 'string') { switch (true) { case logString.substr(0, 20).includes('Error:'): this.log('error', logString); break; default: this.log('info', logString); } return; } // fileStream.write(args[0]); write.apply(process.stdout, args); return true; }; process.stderr.write = (...args: any) => { if (!args[0].startsWith('LOG')) { this.log('error', args[0]); return; } // fileStream.write(args[0]); write.apply(process.stderr, args); return true; }; } this.consoleEnabled = true; } // ============= // log functions // ============= /** * main log method * @param logLevelArg - the log level * @param logMessageArg - the log message * @param logDataArg - any additional log data * @param correlationArg - info about corrleations */ public async log( logLevelArg: plugins.smartlogInterfaces.TLogLevel, logMessageArg: string, logDataArg?: any, correlationArg?: plugins.smartlogInterfaces.ILogCorrelation ) { correlationArg = { ...{ id: plugins.isounique.uni(), type: 'none', instance: this.uniInstanceId, }, ...correlationArg, }; if (this.consoleEnabled) { this.safeConsoleLog(`${logLevelArg}: ${logMessageArg}`); } const logPackage: plugins.smartlogInterfaces.ILogPackage = { timestamp: Date.now(), type: 'log', context: this.logContext, level: logLevelArg, correlation: correlationArg, message: logMessageArg, }; if (logDataArg) { logPackage.data = logDataArg; } await this.logRouter.routeLog(logPackage); } public increment( logLevelArg: plugins.smartlogInterfaces.TLogLevel, logMessageArg: string, logDataArg?: any, correlationArg: plugins.smartlogInterfaces.ILogCorrelation = { id: plugins.isounique.uni(), type: 'none', } ) { if (this.consoleEnabled) { this.safeConsoleLog(`INCREMENT: ${logLevelArg}: ${logMessageArg}`); } this.logRouter.routeLog({ timestamp: Date.now(), type: 'increment', context: this.logContext, level: logLevelArg, message: logMessageArg, correlation: correlationArg, }); } public async handleLog(logPackageArg: plugins.smartlogInterfaces.ILogPackage) { await this.logRouter.routeLog(logPackageArg); } private safeConsoleLog(logLine: string) { console.log( `LOG => ${new Date().getHours()}:${new Date().getMinutes()}:${new Date().getSeconds()} => ${logLine}` ); } public createLogGroup(transactionId: string = 'none') { return new LogGroup(this, transactionId); } }