Big News: Socket raises $60M Series C at a $1B valuation to secure software supply chains for AI-driven development.Announcement
Sign In

@testring/logger

Package Overview
Dependencies
Maintainers
1
Versions
161
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@testring/logger - npm Package Compare versions

Comparing version
0.7.6
to
0.8.0
+54
dist/abstract-logger-client.d.ts
import { Stack } from '@testring/utils';
import { ILogEntity, ILoggerClient, ITransport, LogLevel, LogStepTypes, LogTypes, LogEntityPrefixType, LogEntityMarkerType } from '@testring/types';
type stepEntity = {
stepID: string;
message: string;
};
type LoggerStack = Stack<stepEntity>;
type AbstractLoggerType = ILoggerClient<ITransport, LogEntityPrefixType, LogEntityMarkerType, LoggerStack>;
export declare abstract class AbstractLoggerClient implements AbstractLoggerType {
protected transportInstance: ITransport;
protected prefix: LogEntityPrefixType;
protected marker: LogEntityMarkerType;
protected stepStack: LoggerStack;
constructor(transportInstance?: ITransport, prefix?: LogEntityPrefixType, marker?: LogEntityMarkerType, stepStack?: LoggerStack);
protected abstract broadcast(messageType: string, payload: any): void;
protected getCurrentStep(): stepEntity | null;
protected getPreviousStep(): stepEntity | null;
protected generateStepEntity(message: string): stepEntity;
protected pushStackStep(step: stepEntity): void;
protected popStackStep(): stepEntity | null;
protected buildEntry(logType: LogTypes, content: Array<any>, logLevel: LogLevel, stepGroupType: LogStepTypes): ILogEntity;
protected createLog(type: LogTypes, logLevel: LogLevel, content: Array<any>, stepType?: LogStepTypes): ILogEntity;
log(...args: Array<any>): void;
info(...args: Array<any>): void;
success(...args: Array<any>): void;
warn(...args: Array<any>): void;
error(...args: Array<any>): void;
debug(...args: Array<any>): void;
verbose(...args: Array<any>): void;
screenshot(filename: string, content: Buffer): void;
file(filename: string, meta?: Record<string, any>): void;
media(...args: Array<any>): void;
startStep(message: string, stepType?: LogStepTypes): void;
startStepLog(message: any): void;
startStepInfo(message: any): void;
startStepDebug(message: any): void;
startStepSuccess(message: any): void;
startStepWarning(message: any): void;
startStepError(message: any): void;
endStep(message?: any, ...messageToLog: Array<any>): void;
endAllSteps(): void;
step(message: any, callback: () => any, stepType?: LogStepTypes): Promise<void>;
stepLog(message: any, callback: () => any): Promise<void>;
stepInfo(message: any, callback: () => any): Promise<void>;
stepDebug(message: any, callback: () => any): Promise<void>;
stepSuccess(message: any, callback: () => any): Promise<void>;
stepWarning(message: any, callback: () => any): Promise<void>;
stepError(message: any, callback: () => any): Promise<void>;
withPrefix(prefix: LogEntityPrefixType): this;
withMarker(marker: LogEntityMarkerType): this;
createNewLogger(prefix?: LogEntityPrefixType, marker?: LogEntityMarkerType, stepStack?: LoggerStack): this;
}
export {};
//# sourceMappingURL=abstract-logger-client.d.ts.map
{"version":3,"file":"abstract-logger-client.d.ts","sourceRoot":"","sources":["../src/abstract-logger-client.ts"],"names":[],"mappings":"AAAA,OAAO,EAAC,KAAK,EAAiB,MAAM,iBAAiB,CAAC;AAEtD,OAAO,EACH,UAAU,EACV,aAAa,EACb,UAAU,EAEV,QAAQ,EACR,YAAY,EACZ,QAAQ,EACR,mBAAmB,EACnB,mBAAmB,EACtB,MAAM,iBAAiB,CAAC;AAEzB,KAAK,UAAU,GAAG;IACd,MAAM,EAAE,MAAM,CAAC;IACf,OAAO,EAAE,MAAM,CAAC;CACnB,CAAC;AACF,KAAK,WAAW,GAAG,KAAK,CAAC,UAAU,CAAC,CAAC;AACrC,KAAK,kBAAkB,GAAG,aAAa,CACnC,UAAU,EACV,mBAAmB,EACnB,mBAAmB,EACnB,WAAW,CACd,CAAC;AAEF,8BAAsB,oBAAqB,YAAW,kBAAkB;IAEhE,SAAS,CAAC,iBAAiB,EAAE,UAAU;IACvC,SAAS,CAAC,MAAM,EAAE,mBAAmB;IACrC,SAAS,CAAC,MAAM,EAAE,mBAAmB;IACrC,SAAS,CAAC,SAAS,EAAE,WAAW;gBAHtB,iBAAiB,GAAE,UAAsB,EACzC,MAAM,GAAE,mBAA0B,EAClC,MAAM,GAAE,mBAA0B,EAClC,SAAS,GAAE,WAAyB;IAGlD,SAAS,CAAC,QAAQ,CAAC,SAAS,CAAC,WAAW,EAAE,MAAM,EAAE,OAAO,EAAE,GAAG,GAAG,IAAI;IAErE,SAAS,CAAC,cAAc,IAAI,UAAU,GAAG,IAAI;IAI7C,SAAS,CAAC,eAAe,IAAI,UAAU,GAAG,IAAI;IAI9C,SAAS,CAAC,kBAAkB,CAAC,OAAO,EAAE,MAAM,GAAG,UAAU;IAOzD,SAAS,CAAC,aAAa,CAAC,IAAI,EAAE,UAAU,GAAG,IAAI;IAI/C,SAAS,CAAC,YAAY,IAAI,UAAU,GAAG,IAAI;IAU3C,SAAS,CAAC,UAAU,CAChB,OAAO,EAAE,QAAQ,EACjB,OAAO,EAAE,KAAK,CAAC,GAAG,CAAC,EACnB,QAAQ,EAAE,QAAQ,EAClB,aAAa,EAAE,YAAY,GAC5B,UAAU;IA6Bb,SAAS,CAAC,SAAS,CACf,IAAI,EAAE,QAAQ,EACd,QAAQ,EAAE,QAAQ,EAClB,OAAO,EAAE,KAAK,CAAC,GAAG,CAAC,EACnB,QAAQ,GAAE,YAA+B,GAC1C,UAAU;IAQN,GAAG,CAAC,GAAG,IAAI,EAAE,KAAK,CAAC,GAAG,CAAC,GAAG,IAAI;IAI9B,IAAI,CAAC,GAAG,IAAI,EAAE,KAAK,CAAC,GAAG,CAAC,GAAG,IAAI;IAI/B,OAAO,CAAC,GAAG,IAAI,EAAE,KAAK,CAAC,GAAG,CAAC,GAAG,IAAI;IAIlC,IAAI,CAAC,GAAG,IAAI,EAAE,KAAK,CAAC,GAAG,CAAC,GAAG,IAAI;IAI/B,KAAK,CAAC,GAAG,IAAI,EAAE,KAAK,CAAC,GAAG,CAAC,GAAG,IAAI;IAIhC,KAAK,CAAC,GAAG,IAAI,EAAE,KAAK,CAAC,GAAG,CAAC,GAAG,IAAI;IAIhC,OAAO,CAAC,GAAG,IAAI,EAAE,KAAK,CAAC,GAAG,CAAC,GAAG,IAAI;IAIlC,UAAU,CAAC,QAAQ,EAAE,MAAM,EAAE,OAAO,EAAE,MAAM,GAAG,IAAI;IAInD,IAAI,CAAC,QAAQ,EAAE,MAAM,EAAE,IAAI,GAAE,MAAM,CAAC,MAAM,EAAE,GAAG,CAAM,GAAG,IAAI;IAI5D,KAAK,CAAC,GAAG,IAAI,EAAE,KAAK,CAAC,GAAG,CAAC,GAAG,IAAI;IAIhC,SAAS,CAAC,OAAO,EAAE,MAAM,EAAE,QAAQ,CAAC,EAAE,YAAY,GAAG,IAAI;IAQzD,YAAY,CAAC,OAAO,EAAE,GAAG,GAAG,IAAI;IAIhC,aAAa,CAAC,OAAO,EAAE,GAAG,GAAG,IAAI;IAIjC,cAAc,CAAC,OAAO,EAAE,GAAG,GAAG,IAAI;IAIlC,gBAAgB,CAAC,OAAO,EAAE,GAAG,GAAG,IAAI;IAIpC,gBAAgB,CAAC,OAAO,EAAE,GAAG,GAAG,IAAI;IAIpC,cAAc,CAAC,OAAO,EAAE,GAAG,GAAG,IAAI;IAIlC,OAAO,CAAC,OAAO,CAAC,EAAE,GAAG,EAAE,GAAG,YAAY,EAAE,KAAK,CAAC,GAAG,CAAC,GAAG,IAAI;IAoBzD,WAAW,IAAI,IAAI;IAQb,IAAI,CACb,OAAO,EAAE,GAAG,EACZ,QAAQ,EAAE,MAAM,GAAG,EACnB,QAAQ,CAAC,EAAE,YAAY,GACxB,OAAO,CAAC,IAAI,CAAC;IAkBH,OAAO,CAAC,OAAO,EAAE,GAAG,EAAE,QAAQ,EAAE,MAAM,GAAG,GAAG,OAAO,CAAC,IAAI,CAAC;IAIzD,QAAQ,CAAC,OAAO,EAAE,GAAG,EAAE,QAAQ,EAAE,MAAM,GAAG,GAAG,OAAO,CAAC,IAAI,CAAC;IAI1D,SAAS,CAAC,OAAO,EAAE,GAAG,EAAE,QAAQ,EAAE,MAAM,GAAG,GAAG,OAAO,CAAC,IAAI,CAAC;IAI3D,WAAW,CAAC,OAAO,EAAE,GAAG,EAAE,QAAQ,EAAE,MAAM,GAAG,GAAG,OAAO,CAAC,IAAI,CAAC;IAI7D,WAAW,CAAC,OAAO,EAAE,GAAG,EAAE,QAAQ,EAAE,MAAM,GAAG,GAAG,OAAO,CAAC,IAAI,CAAC;IAI7D,SAAS,CAAC,OAAO,EAAE,GAAG,EAAE,QAAQ,EAAE,MAAM,GAAG,GAAG,OAAO,CAAC,IAAI,CAAC;IAIjE,UAAU,CAAC,MAAM,EAAE,mBAAmB;IAItC,UAAU,CAAC,MAAM,EAAE,mBAAmB;IAItC,eAAe,CAClB,MAAM,GAAE,mBAAiC,EACzC,MAAM,GAAE,mBAAiC,EACzC,SAAS,GAAE,WAA4B,GAOlC,IAAI;CAEhB"}
import { ILogEntity } from '@testring/types';
export declare function formatLog(logEntity: ILogEntity, processID?: string, emojiSupport?: boolean): string;
//# sourceMappingURL=format-log.d.ts.map
{"version":3,"file":"format-log.d.ts","sourceRoot":"","sources":["../src/format-log.ts"],"names":[],"mappings":"AAGA,OAAO,EAAC,UAAU,EAAqB,MAAM,iBAAiB,CAAC;AA6D/D,wBAAgB,SAAS,CACrB,SAAS,EAAE,UAAU,EACrB,SAAS,CAAC,EAAE,MAAM,EAClB,YAAY,GAAE,OAA2B,GAC1C,MAAM,CAqCR"}
export * from './logger-server';
export * from './logger-client';
//# sourceMappingURL=index.d.ts.map
{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,cAAc,iBAAiB,CAAC;AAChC,cAAc,iBAAiB,CAAC"}
import { AbstractLoggerClient } from './abstract-logger-client';
export declare class LoggerClient extends AbstractLoggerClient {
protected broadcast(messageType: string, payload: any): void;
}
export declare const loggerClient: LoggerClient;
//# sourceMappingURL=logger-client.d.ts.map
{"version":3,"file":"logger-client.d.ts","sourceRoot":"","sources":["../src/logger-client.ts"],"names":[],"mappings":"AAAA,OAAO,EAAC,oBAAoB,EAAC,MAAM,0BAA0B,CAAC;AAE9D,qBAAa,YAAa,SAAQ,oBAAoB;IAClD,SAAS,CAAC,SAAS,CAAC,WAAW,EAAE,MAAM,EAAE,OAAO,EAAE,GAAG;CAGxD;AAED,eAAO,MAAM,YAAY,cAAqB,CAAC"}
import { PluggableModule } from '@testring/pluggable-module';
import { IConfigLogger, ILoggerServer, ITransport, LogQueueStatus } from '@testring/types';
export declare enum LogLevelNumeric {
verbose = 0,
debug = 1,
info = 2,
warning = 3,
error = 4,
silent = 5
}
export declare class LoggerServer extends PluggableModule implements ILoggerServer {
private config;
private transportInstance;
private stdout;
private numberOfRetries;
private shouldSkip;
private queue;
private status;
constructor(config: IConfigLogger, transportInstance: ITransport, stdout: NodeJS.WritableStream, numberOfRetries?: number, shouldSkip?: boolean);
private registerTransportListeners;
private runQueue;
private log;
getQueueStatus(): LogQueueStatus;
}
//# sourceMappingURL=logger-server.d.ts.map
{"version":3,"file":"logger-server.d.ts","sourceRoot":"","sources":["../src/logger-server.ts"],"names":[],"mappings":"AAAA,OAAO,EAAC,eAAe,EAAC,MAAM,4BAA4B,CAAC;AAE3D,OAAO,EACH,aAAa,EAEb,aAAa,EAEb,UAAU,EAGV,cAAc,EACjB,MAAM,iBAAiB,CAAC;AAGzB,oBAAY,eAAe;IACvB,OAAO,IAAA;IACP,KAAK,IAAA;IACL,IAAI,IAAA;IACJ,OAAO,IAAA;IACP,KAAK,IAAA;IACL,MAAM,IAAA;CACT;AAED,qBAAa,YAAa,SAAQ,eAAgB,YAAW,aAAa;IAMlE,OAAO,CAAC,MAAM;IACd,OAAO,CAAC,iBAAiB;IACzB,OAAO,CAAC,MAAM;IACd,OAAO,CAAC,eAAe;IACvB,OAAO,CAAC,UAAU;IATtB,OAAO,CAAC,KAAK,CAAiC;IAE9C,OAAO,CAAC,MAAM,CAAwC;gBAG1C,MAAM,EAAE,aAAa,EACrB,iBAAiB,EAAE,UAAU,EAC7B,MAAM,EAAE,MAAM,CAAC,cAAc,EAC7B,eAAe,GAAE,MAAU,EAC3B,UAAU,GAAE,OAAe;IAWvC,OAAO,CAAC,0BAA0B;YASpB,QAAQ;IA2CtB,OAAO,CAAC,GAAG;IA2BJ,cAAc,IAAI,cAAc;CAG1C"}
{
"extends": "./tsconfig.json",
"compilerOptions": {
"outDir": "dist",
"rootDir": "src",
"noEmit": false,
"composite": true
},
"exclude": ["test"]
}
+25
-48
"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
Object.defineProperty(exports, "__esModule", { value: true });

@@ -149,47 +140,33 @@ exports.AbstractLoggerClient = void 0;

}
step(message, callback, stepType) {
return __awaiter(this, void 0, void 0, function* () {
this.startStep(message, stepType);
let caughtError;
try {
yield callback();
}
catch (err) {
caughtError = err;
}
this.endStep(message);
if (caughtError) {
throw caughtError;
}
});
async step(message, callback, stepType) {
this.startStep(message, stepType);
let caughtError;
try {
await callback();
}
catch (err) {
caughtError = err;
}
this.endStep(message);
if (caughtError) {
throw caughtError;
}
}
stepLog(message, callback) {
return __awaiter(this, void 0, void 0, function* () {
return this.step(message, callback, "log" /* LogStepTypes.log */);
});
async stepLog(message, callback) {
return this.step(message, callback, "log" /* LogStepTypes.log */);
}
stepInfo(message, callback) {
return __awaiter(this, void 0, void 0, function* () {
return this.step(message, callback, "info" /* LogStepTypes.info */);
});
async stepInfo(message, callback) {
return this.step(message, callback, "info" /* LogStepTypes.info */);
}
stepDebug(message, callback) {
return __awaiter(this, void 0, void 0, function* () {
return this.step(message, callback, "debug" /* LogStepTypes.debug */);
});
async stepDebug(message, callback) {
return this.step(message, callback, "debug" /* LogStepTypes.debug */);
}
stepSuccess(message, callback) {
return __awaiter(this, void 0, void 0, function* () {
return this.step(message, callback, "success" /* LogStepTypes.success */);
});
async stepSuccess(message, callback) {
return this.step(message, callback, "success" /* LogStepTypes.success */);
}
stepWarning(message, callback) {
return __awaiter(this, void 0, void 0, function* () {
return this.step(message, callback, "warning" /* LogStepTypes.warning */);
});
async stepWarning(message, callback) {
return this.step(message, callback, "warning" /* LogStepTypes.warning */);
}
stepError(message, callback) {
return __awaiter(this, void 0, void 0, function* () {
return this.step(message, callback, "error" /* LogStepTypes.error */);
});
async stepError(message, callback) {
return this.step(message, callback, "error" /* LogStepTypes.error */);
}

@@ -196,0 +173,0 @@ withPrefix(prefix) {

@@ -1,1 +0,1 @@

{"version":3,"file":"abstract-logger-client.js","sourceRoot":"","sources":["../src/abstract-logger-client.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,2CAAsD;AACtD,mDAA8C;AAyB9C,MAAsB,oBAAoB;IACtC,YACc,oBAAgC,qBAAS,EACzC,SAA8B,IAAI,EAClC,SAA8B,IAAI,EAClC,YAAyB,IAAI,aAAK,EAAE;QAHpC,sBAAiB,GAAjB,iBAAiB,CAAwB;QACzC,WAAM,GAAN,MAAM,CAA4B;QAClC,WAAM,GAAN,MAAM,CAA4B;QAClC,cAAS,GAAT,SAAS,CAA2B;IAC/C,CAAC;IAIM,cAAc;QACpB,OAAO,IAAI,CAAC,SAAS,CAAC,cAAc,EAAE,CAAC;IAC3C,CAAC;IAES,eAAe;QACrB,OAAO,IAAI,CAAC,SAAS,CAAC,cAAc,CAAC,CAAC,CAAC,CAAC;IAC5C,CAAC;IAES,kBAAkB,CAAC,OAAe;QACxC,OAAO;YACH,MAAM,EAAE,IAAA,sBAAc,GAAE;YACxB,OAAO;SACV,CAAC;IACN,CAAC;IAES,aAAa,CAAC,IAAgB;QACpC,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;IAC9B,CAAC;IAES,YAAY;QAClB,MAAM,IAAI,GAAG,IAAI,CAAC,SAAS,CAAC,GAAG,EAAE,CAAC;QAElC,IAAI,IAAI,EAAE,CAAC;YACP,OAAO,IAAI,CAAC;QAChB,CAAC;QAED,OAAO,IAAI,CAAC;IAChB,CAAC;IAES,UAAU,CAChB,OAAiB,EACjB,OAAmB,EACnB,QAAkB,EAClB,aAA2B;QAE3B,MAAM,MAAM,GAAG,IAAI,CAAC,MAAM,CAAC;QAC3B,MAAM,MAAM,GAAG,IAAI,CAAC,MAAM,CAAC;QAE3B,MAAM,IAAI,GAAG,IAAI,IAAI,EAAE,CAAC;QACxB,MAAM,UAAU,GAAG,OAAO,+BAAkB,CAAC;QAC7C,MAAM,WAAW,GAAG,IAAI,CAAC,cAAc,EAAE,CAAC;QAC1C,MAAM,YAAY,GAAG,IAAI,CAAC,eAAe,EAAE,CAAC;QAE5C,MAAM,aAAa,GAAG,WAAW,CAAC,CAAC,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC,CAAC,IAAI,CAAC;QAC9D,MAAM,cAAc,GAAG,YAAY,CAAC,CAAC,CAAC,YAAY,CAAC,MAAM,CAAC,CAAC,CAAC,IAAI,CAAC;QAEjE,MAAM,OAAO,GAAG,UAAU,IAAI,aAAa,CAAC,CAAC,CAAC,aAAa,CAAC,CAAC,CAAC,IAAI,CAAC;QACnE,MAAM,UAAU,GAAG,UAAU,CAAC,CAAC,CAAC,cAAc,CAAC,CAAC,CAAC,aAAa,CAAC;QAC/D,MAAM,QAAQ,GAAG,UAAU,CAAC,CAAC,CAAC,aAAa,CAAC,CAAC,CAAC,IAAI,CAAC;QAEnD,OAAO;YACH,IAAI;YACJ,IAAI,EAAE,OAAO;YACb,QAAQ;YACR,OAAO;YACP,OAAO;YACP,QAAQ;YACR,UAAU;YACV,MAAM;YACN,MAAM;SACT,CAAC;IACN,CAAC;IAES,SAAS,CACf,IAAc,EACd,QAAkB,EAClB,OAAmB,EACnB,uCAAyC;QAEzC,MAAM,QAAQ,GAAG,IAAI,CAAC,UAAU,CAAC,IAAI,EAAE,OAAO,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAC;QAEpE,IAAI,CAAC,SAAS,kDAA4B,QAAQ,CAAC,CAAC;QAEpD,OAAO,QAAQ,CAAC;IACpB,CAAC;IAEM,GAAG,CAAC,GAAG,IAAI;QACd,IAAI,CAAC,SAAS,uDAA8B,IAAI,CAAC,CAAC;IACtD,CAAC;IAEM,IAAI,CAAC,GAAG,IAAI;QACf,IAAI,CAAC,SAAS,yDAA+B,IAAI,CAAC,CAAC;IACvD,CAAC;IAEM,OAAO,CAAC,GAAG,IAAI;QAClB,IAAI,CAAC,SAAS,+DAAkC,IAAI,CAAC,CAAC;IAC1D,CAAC;IAEM,IAAI,CAAC,GAAG,IAAI;QACf,IAAI,CAAC,SAAS,qEAAqC,IAAI,CAAC,CAAC;IAC7D,CAAC;IAEM,KAAK,CAAC,GAAG,IAAI;QAChB,IAAI,CAAC,SAAS,6DAAiC,IAAI,CAAC,CAAC;IACzD,CAAC;IAEM,KAAK,CAAC,GAAG,IAAI;QAChB,IAAI,CAAC,SAAS,6DAAiC,IAAI,CAAC,CAAC;IACzD,CAAC;IAEM,OAAO,CAAC,GAAG,IAAI;QAClB,IAAI,CAAC,SAAS,iEAAmC,IAAI,CAAC,CAAC;IAC3D,CAAC;IAEM,UAAU,CAAC,QAAgB,EAAE,OAAe;QAC/C,IAAI,CAAC,SAAS,qEAAqC,CAAC,QAAQ,EAAE,OAAO,CAAC,CAAC,CAAC;IAC5E,CAAC;IAEM,IAAI,CAAC,QAAgB,EAAE,OAA4B,EAAE;QACxD,IAAI,CAAC,SAAS,yDAA+B,CAAC,QAAQ,EAAE,IAAI,CAAC,CAAC,CAAC;IACnE,CAAC;IAEM,KAAK,CAAC,GAAG,IAAI;QAChB,IAAI,CAAC,SAAS,2DAAgC,IAAI,CAAC,CAAC;IACxD,CAAC;IAEM,SAAS,CAAC,OAAe,EAAE,QAAuB;QACrD,MAAM,IAAI,GAAG,IAAI,CAAC,kBAAkB,CAAC,OAAO,CAAC,CAAC;QAE9C,IAAI,CAAC,aAAa,CAAC,IAAI,CAAC,CAAC;QAEzB,IAAI,CAAC,SAAS,yDAA+B,CAAC,OAAO,CAAC,EAAE,QAAQ,CAAC,CAAC;IACtE,CAAC;IAEM,YAAY,CAAC,OAAY;QAC5B,IAAI,CAAC,SAAS,CAAC,OAAO,+BAAmB,CAAC;IAC9C,CAAC;IAEM,aAAa,CAAC,OAAY;QAC7B,IAAI,CAAC,SAAS,CAAC,OAAO,iCAAoB,CAAC;IAC/C,CAAC;IAEM,cAAc,CAAC,OAAY;QAC9B,IAAI,CAAC,SAAS,CAAC,OAAO,mCAAqB,CAAC;IAChD,CAAC;IAEM,gBAAgB,CAAC,OAAY;QAChC,IAAI,CAAC,SAAS,CAAC,OAAO,uCAAuB,CAAC;IAClD,CAAC;IAEM,gBAAgB,CAAC,OAAY;QAChC,IAAI,CAAC,SAAS,CAAC,OAAO,uCAAuB,CAAC;IAClD,CAAC;IAEM,cAAc,CAAC,OAAY;QAC9B,IAAI,CAAC,SAAS,CAAC,OAAO,mCAAqB,CAAC;IAChD,CAAC;IAEM,OAAO,CAAC,OAAa,EAAE,GAAG,YAAwB;QACrD,IAAI,YAAY,CAAC,MAAM,EAAE,CAAC;YACtB,IAAI,CAAC,IAAI,CAAC,YAAY,EAAE,GAAG,YAAY,CAAC,CAAC;QAC7C,CAAC;QAED,IAAI,IAAI,GAAG,IAAI,CAAC,YAAY,EAAE,CAAC;QAE/B,IAAI,IAAI,EAAE,CAAC;YACP,OAAO,IAAI,EAAE,CAAC;gBACV,MAAM,WAAW,GAAG,IAAI,CAAC,OAAO,CAAC;gBAEjC,IAAI,OAAO,KAAK,WAAW,EAAE,CAAC;oBAC1B,MAAM;gBACV,CAAC;qBAAM,CAAC;oBACJ,IAAI,GAAG,IAAI,CAAC,YAAY,EAAE,CAAC;gBAC/B,CAAC;YACL,CAAC;QACL,CAAC;IACL,CAAC;IAEM,WAAW;QACd,IAAI,IAAI,GAAG,IAAI,CAAC,YAAY,EAAE,CAAC;QAE/B,OAAO,IAAI,EAAE,CAAC;YACV,IAAI,GAAG,IAAI,CAAC,YAAY,EAAE,CAAC;QAC/B,CAAC;IACL,CAAC;IAEY,IAAI,CACb,OAAY,EACZ,QAAmB,EACnB,QAAuB;;YAEvB,IAAI,CAAC,SAAS,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAC;YAElC,IAAI,WAAW,CAAC;YAEhB,IAAI,CAAC;gBACD,MAAM,QAAQ,EAAE,CAAC;YACrB,CAAC;YAAC,OAAO,GAAG,EAAE,CAAC;gBACX,WAAW,GAAG,GAAG,CAAC;YACtB,CAAC;YAED,IAAI,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC;YAEtB,IAAI,WAAW,EAAE,CAAC;gBACd,MAAM,WAAW,CAAC;YACtB,CAAC;QACL,CAAC;KAAA;IAEY,OAAO,CAAC,OAAY,EAAE,QAAmB;;YAClD,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,+BAAmB,CAAC;QAC1D,CAAC;KAAA;IAEY,QAAQ,CAAC,OAAY,EAAE,QAAmB;;YACnD,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,iCAAoB,CAAC;QAC3D,CAAC;KAAA;IAEY,SAAS,CAAC,OAAY,EAAE,QAAmB;;YACpD,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,mCAAqB,CAAC;QAC5D,CAAC;KAAA;IAEY,WAAW,CAAC,OAAY,EAAE,QAAmB;;YACtD,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,uCAAuB,CAAC;QAC9D,CAAC;KAAA;IAEY,WAAW,CAAC,OAAY,EAAE,QAAmB;;YACtD,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,uCAAuB,CAAC;QAC9D,CAAC;KAAA;IAEY,SAAS,CAAC,OAAY,EAAE,QAAmB;;YACpD,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,mCAAqB,CAAC;QAC5D,CAAC;KAAA;IAEM,UAAU,CAAC,MAA2B;QACzC,OAAO,IAAI,CAAC,eAAe,CAAC,MAAM,EAAE,IAAI,CAAC,MAAM,EAAE,IAAI,CAAC,SAAS,CAAC,CAAC;IACrE,CAAC;IAEM,UAAU,CAAC,MAA2B;QACzC,OAAO,IAAI,CAAC,eAAe,CAAC,IAAI,CAAC,MAAM,EAAE,MAAM,EAAE,IAAI,CAAC,SAAS,CAAC,CAAC;IACrE,CAAC;IAEM,eAAe,CAClB,SAA8B,IAAI,CAAC,MAAM,EACzC,SAA8B,IAAI,CAAC,MAAM,EACzC,YAAyB,IAAI,CAAC,SAAS;QAEvC,OAAO,IAAK,IAAI,CAAC,WAAmB,CAChC,IAAI,CAAC,iBAAiB,EACtB,MAAM,EACN,MAAM,EACN,SAAS,CACJ,CAAC;IACd,CAAC;CACJ;AA5PD,oDA4PC"}
{"version":3,"file":"abstract-logger-client.js","sourceRoot":"","sources":["../src/abstract-logger-client.ts"],"names":[],"mappings":";;;AAAA,2CAAsD;AACtD,mDAA8C;AAyB9C,MAAsB,oBAAoB;IACtC,YACc,oBAAgC,qBAAS,EACzC,SAA8B,IAAI,EAClC,SAA8B,IAAI,EAClC,YAAyB,IAAI,aAAK,EAAE;QAHpC,sBAAiB,GAAjB,iBAAiB,CAAwB;QACzC,WAAM,GAAN,MAAM,CAA4B;QAClC,WAAM,GAAN,MAAM,CAA4B;QAClC,cAAS,GAAT,SAAS,CAA2B;IAC/C,CAAC;IAIM,cAAc;QACpB,OAAO,IAAI,CAAC,SAAS,CAAC,cAAc,EAAE,CAAC;IAC3C,CAAC;IAES,eAAe;QACrB,OAAO,IAAI,CAAC,SAAS,CAAC,cAAc,CAAC,CAAC,CAAC,CAAC;IAC5C,CAAC;IAES,kBAAkB,CAAC,OAAe;QACxC,OAAO;YACH,MAAM,EAAE,IAAA,sBAAc,GAAE;YACxB,OAAO;SACV,CAAC;IACN,CAAC;IAES,aAAa,CAAC,IAAgB;QACpC,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;IAC9B,CAAC;IAES,YAAY;QAClB,MAAM,IAAI,GAAG,IAAI,CAAC,SAAS,CAAC,GAAG,EAAE,CAAC;QAElC,IAAI,IAAI,EAAE,CAAC;YACP,OAAO,IAAI,CAAC;QAChB,CAAC;QAED,OAAO,IAAI,CAAC;IAChB,CAAC;IAES,UAAU,CAChB,OAAiB,EACjB,OAAmB,EACnB,QAAkB,EAClB,aAA2B;QAE3B,MAAM,MAAM,GAAG,IAAI,CAAC,MAAM,CAAC;QAC3B,MAAM,MAAM,GAAG,IAAI,CAAC,MAAM,CAAC;QAE3B,MAAM,IAAI,GAAG,IAAI,IAAI,EAAE,CAAC;QACxB,MAAM,UAAU,GAAG,OAAO,+BAAkB,CAAC;QAC7C,MAAM,WAAW,GAAG,IAAI,CAAC,cAAc,EAAE,CAAC;QAC1C,MAAM,YAAY,GAAG,IAAI,CAAC,eAAe,EAAE,CAAC;QAE5C,MAAM,aAAa,GAAG,WAAW,CAAC,CAAC,CAAC,WAAW,CAAC,MAAM,CAAC,CAAC,CAAC,IAAI,CAAC;QAC9D,MAAM,cAAc,GAAG,YAAY,CAAC,CAAC,CAAC,YAAY,CAAC,MAAM,CAAC,CAAC,CAAC,IAAI,CAAC;QAEjE,MAAM,OAAO,GAAG,UAAU,IAAI,aAAa,CAAC,CAAC,CAAC,aAAa,CAAC,CAAC,CAAC,IAAI,CAAC;QACnE,MAAM,UAAU,GAAG,UAAU,CAAC,CAAC,CAAC,cAAc,CAAC,CAAC,CAAC,aAAa,CAAC;QAC/D,MAAM,QAAQ,GAAG,UAAU,CAAC,CAAC,CAAC,aAAa,CAAC,CAAC,CAAC,IAAI,CAAC;QAEnD,OAAO;YACH,IAAI;YACJ,IAAI,EAAE,OAAO;YACb,QAAQ;YACR,OAAO;YACP,OAAO;YACP,QAAQ;YACR,UAAU;YACV,MAAM;YACN,MAAM;SACT,CAAC;IACN,CAAC;IAES,SAAS,CACf,IAAc,EACd,QAAkB,EAClB,OAAmB,EACnB,uCAAyC;QAEzC,MAAM,QAAQ,GAAG,IAAI,CAAC,UAAU,CAAC,IAAI,EAAE,OAAO,EAAE,QAAQ,EAAE,QAAQ,CAAC,CAAC;QAEpE,IAAI,CAAC,SAAS,kDAA4B,QAAQ,CAAC,CAAC;QAEpD,OAAO,QAAQ,CAAC;IACpB,CAAC;IAEM,GAAG,CAAC,GAAG,IAAgB;QAC1B,IAAI,CAAC,SAAS,uDAA8B,IAAI,CAAC,CAAC;IACtD,CAAC;IAEM,IAAI,CAAC,GAAG,IAAgB;QAC3B,IAAI,CAAC,SAAS,yDAA+B,IAAI,CAAC,CAAC;IACvD,CAAC;IAEM,OAAO,CAAC,GAAG,IAAgB;QAC9B,IAAI,CAAC,SAAS,+DAAkC,IAAI,CAAC,CAAC;IAC1D,CAAC;IAEM,IAAI,CAAC,GAAG,IAAgB;QAC3B,IAAI,CAAC,SAAS,qEAAqC,IAAI,CAAC,CAAC;IAC7D,CAAC;IAEM,KAAK,CAAC,GAAG,IAAgB;QAC5B,IAAI,CAAC,SAAS,6DAAiC,IAAI,CAAC,CAAC;IACzD,CAAC;IAEM,KAAK,CAAC,GAAG,IAAgB;QAC5B,IAAI,CAAC,SAAS,6DAAiC,IAAI,CAAC,CAAC;IACzD,CAAC;IAEM,OAAO,CAAC,GAAG,IAAgB;QAC9B,IAAI,CAAC,SAAS,iEAAmC,IAAI,CAAC,CAAC;IAC3D,CAAC;IAEM,UAAU,CAAC,QAAgB,EAAE,OAAe;QAC/C,IAAI,CAAC,SAAS,qEAAqC,CAAC,QAAQ,EAAE,OAAO,CAAC,CAAC,CAAC;IAC5E,CAAC;IAEM,IAAI,CAAC,QAAgB,EAAE,OAA4B,EAAE;QACxD,IAAI,CAAC,SAAS,yDAA+B,CAAC,QAAQ,EAAE,IAAI,CAAC,CAAC,CAAC;IACnE,CAAC;IAEM,KAAK,CAAC,GAAG,IAAgB;QAC5B,IAAI,CAAC,SAAS,2DAAgC,IAAI,CAAC,CAAC;IACxD,CAAC;IAEM,SAAS,CAAC,OAAe,EAAE,QAAuB;QACrD,MAAM,IAAI,GAAG,IAAI,CAAC,kBAAkB,CAAC,OAAO,CAAC,CAAC;QAE9C,IAAI,CAAC,aAAa,CAAC,IAAI,CAAC,CAAC;QAEzB,IAAI,CAAC,SAAS,yDAA+B,CAAC,OAAO,CAAC,EAAE,QAAQ,CAAC,CAAC;IACtE,CAAC;IAEM,YAAY,CAAC,OAAY;QAC5B,IAAI,CAAC,SAAS,CAAC,OAAO,+BAAmB,CAAC;IAC9C,CAAC;IAEM,aAAa,CAAC,OAAY;QAC7B,IAAI,CAAC,SAAS,CAAC,OAAO,iCAAoB,CAAC;IAC/C,CAAC;IAEM,cAAc,CAAC,OAAY;QAC9B,IAAI,CAAC,SAAS,CAAC,OAAO,mCAAqB,CAAC;IAChD,CAAC;IAEM,gBAAgB,CAAC,OAAY;QAChC,IAAI,CAAC,SAAS,CAAC,OAAO,uCAAuB,CAAC;IAClD,CAAC;IAEM,gBAAgB,CAAC,OAAY;QAChC,IAAI,CAAC,SAAS,CAAC,OAAO,uCAAuB,CAAC;IAClD,CAAC;IAEM,cAAc,CAAC,OAAY;QAC9B,IAAI,CAAC,SAAS,CAAC,OAAO,mCAAqB,CAAC;IAChD,CAAC;IAEM,OAAO,CAAC,OAAa,EAAE,GAAG,YAAwB;QACrD,IAAI,YAAY,CAAC,MAAM,EAAE,CAAC;YACtB,IAAI,CAAC,IAAI,CAAC,YAAY,EAAE,GAAG,YAAY,CAAC,CAAC;QAC7C,CAAC;QAED,IAAI,IAAI,GAAG,IAAI,CAAC,YAAY,EAAE,CAAC;QAE/B,IAAI,IAAI,EAAE,CAAC;YACP,OAAO,IAAI,EAAE,CAAC;gBACV,MAAM,WAAW,GAAG,IAAI,CAAC,OAAO,CAAC;gBAEjC,IAAI,OAAO,KAAK,WAAW,EAAE,CAAC;oBAC1B,MAAM;gBACV,CAAC;qBAAM,CAAC;oBACJ,IAAI,GAAG,IAAI,CAAC,YAAY,EAAE,CAAC;gBAC/B,CAAC;YACL,CAAC;QACL,CAAC;IACL,CAAC;IAEM,WAAW;QACd,IAAI,IAAI,GAAG,IAAI,CAAC,YAAY,EAAE,CAAC;QAE/B,OAAO,IAAI,EAAE,CAAC;YACV,IAAI,GAAG,IAAI,CAAC,YAAY,EAAE,CAAC;QAC/B,CAAC;IACL,CAAC;IAEM,KAAK,CAAC,IAAI,CACb,OAAY,EACZ,QAAmB,EACnB,QAAuB;QAEvB,IAAI,CAAC,SAAS,CAAC,OAAO,EAAE,QAAQ,CAAC,CAAC;QAElC,IAAI,WAAW,CAAC;QAEhB,IAAI,CAAC;YACD,MAAM,QAAQ,EAAE,CAAC;QACrB,CAAC;QAAC,OAAO,GAAG,EAAE,CAAC;YACX,WAAW,GAAG,GAAG,CAAC;QACtB,CAAC;QAED,IAAI,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC;QAEtB,IAAI,WAAW,EAAE,CAAC;YACd,MAAM,WAAW,CAAC;QACtB,CAAC;IACL,CAAC;IAEM,KAAK,CAAC,OAAO,CAAC,OAAY,EAAE,QAAmB;QAClD,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,+BAAmB,CAAC;IAC1D,CAAC;IAEM,KAAK,CAAC,QAAQ,CAAC,OAAY,EAAE,QAAmB;QACnD,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,iCAAoB,CAAC;IAC3D,CAAC;IAEM,KAAK,CAAC,SAAS,CAAC,OAAY,EAAE,QAAmB;QACpD,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,mCAAqB,CAAC;IAC5D,CAAC;IAEM,KAAK,CAAC,WAAW,CAAC,OAAY,EAAE,QAAmB;QACtD,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,uCAAuB,CAAC;IAC9D,CAAC;IAEM,KAAK,CAAC,WAAW,CAAC,OAAY,EAAE,QAAmB;QACtD,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,uCAAuB,CAAC;IAC9D,CAAC;IAEM,KAAK,CAAC,SAAS,CAAC,OAAY,EAAE,QAAmB;QACpD,OAAO,IAAI,CAAC,IAAI,CAAC,OAAO,EAAE,QAAQ,mCAAqB,CAAC;IAC5D,CAAC;IAEM,UAAU,CAAC,MAA2B;QACzC,OAAO,IAAI,CAAC,eAAe,CAAC,MAAM,EAAE,IAAI,CAAC,MAAM,EAAE,IAAI,CAAC,SAAS,CAAC,CAAC;IACrE,CAAC;IAEM,UAAU,CAAC,MAA2B;QACzC,OAAO,IAAI,CAAC,eAAe,CAAC,IAAI,CAAC,MAAM,EAAE,MAAM,EAAE,IAAI,CAAC,SAAS,CAAC,CAAC;IACrE,CAAC;IAEM,eAAe,CAClB,SAA8B,IAAI,CAAC,MAAM,EACzC,SAA8B,IAAI,CAAC,MAAM,EACzC,YAAyB,IAAI,CAAC,SAAS;QAEvC,OAAO,IAAK,IAAI,CAAC,WAAmB,CAChC,IAAI,CAAC,iBAAiB,EACtB,MAAM,EACN,MAAM,EACN,SAAS,CACJ,CAAC;IACd,CAAC;CACJ;AA5PD,oDA4PC"}
"use strict";
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
__setModuleDefault(result, mod);
return result;
};
var __importDefault = (this && this.__importDefault) || function (mod) {
return (mod && mod.__esModule) ? mod : { "default": mod };
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.formatLog = formatLog;
const process = require("process");
const util = require("util");
const chalk = require("chalk");
const HAS_EMOJI_SUPPORT = !!(process.stdout.isTTY && process.platform === 'darwin');
const node_process_1 = __importDefault(require("node:process"));
const util = __importStar(require("util"));
const chalk_1 = __importDefault(require("chalk"));
const HAS_EMOJI_SUPPORT = !!(node_process_1.default.stdout.isTTY && node_process_1.default.platform === 'darwin');
const textTemplate = (logLevel) => logLevel.padEnd(9);

@@ -31,16 +57,16 @@ function emojiTemplate(logLevel) {

case "info" /* LogLevel.info */:
return chalk.blue(template);
return chalk_1.default.blue(template);
case "debug" /* LogLevel.debug */:
return chalk.bold(template);
return chalk_1.default.bold(template);
case "warning" /* LogLevel.warning */:
return chalk.yellow(template);
return chalk_1.default.yellow(template);
case "error" /* LogLevel.error */:
return chalk.red(template);
return chalk_1.default.red(template);
case "verbose" /* LogLevel.verbose */:
return chalk.gray(template);
return chalk_1.default.gray(template);
case "silent" /* LogLevel.silent */:
return chalk.white(template);
return chalk_1.default.white(template);
}
}
const formatTime = (time) => chalk.grey(`${time.toLocaleTimeString()}`);
const formatTime = (time) => chalk_1.default.grey(`${time.toLocaleTimeString()}`);
const formatProcessID = (processID) => typeof processID === 'string' ? processID.padEnd(10) : 'main';

@@ -47,0 +73,0 @@ function formatLog(logEntity, processID, emojiSupport = HAS_EMOJI_SUPPORT) {

@@ -1,1 +0,1 @@

{"version":3,"file":"format-log.js","sourceRoot":"","sources":["../src/format-log.ts"],"names":[],"mappings":";;AAgEA,8BAyCC;AAzGD,mCAAmC;AACnC,6BAA6B;AAC7B,+BAA+B;AAG/B,MAAM,iBAAiB,GAAG,CAAC,CAAC,CACxB,OAAO,CAAC,MAAM,CAAC,KAAK,IAAI,OAAO,CAAC,QAAQ,KAAK,QAAQ,CACxD,CAAC;AAEF,MAAM,YAAY,GAAG,CAAC,QAAkB,EAAE,EAAE,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC;AAEhE,SAAS,aAAa,CAAC,QAAkB;IACrC,QAAQ,QAAQ,EAAE,CAAC;QACf;YACI,OAAO,GAAG,CAAC;QAEf;YACI,OAAO,IAAI,CAAC;QAEhB;YACI,OAAO,GAAG,CAAC;QAEf;YACI,OAAO,GAAG,CAAC;QAEf;YACI,OAAO,IAAI,CAAC;QAEhB;YACI,OAAO,EAAE,CAAC;IAClB,CAAC;AACL,CAAC;AAED,SAAS,cAAc,CAAC,QAAkB,EAAE,YAAqB;IAC7D,MAAM,QAAQ,GAAG,YAAY;QACzB,CAAC,CAAC,aAAa,CAAC,QAAQ,CAAC;QACzB,CAAC,CAAC,YAAY,CAAC,QAAQ,CAAC,CAAC;IAE7B,QAAQ,QAAQ,EAAE,CAAC;QACf;YACI,OAAO,KAAK,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;QAEhC;YACI,OAAO,KAAK,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;QAEhC;YACI,OAAO,KAAK,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC;QAElC;YACI,OAAO,KAAK,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QAE/B;YACI,OAAO,KAAK,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;QAEhC;YACI,OAAO,KAAK,CAAC,KAAK,CAAC,QAAQ,CAAC,CAAC;IACrC,CAAC;AACL,CAAC;AAED,MAAM,UAAU,GAAG,CAAC,IAAU,EAAE,EAAE,CAAC,KAAK,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC,kBAAkB,EAAE,EAAE,CAAC,CAAC;AAE9E,MAAM,eAAe,GAAG,CAAC,SAAkB,EAAE,EAAE,CAC3C,OAAO,SAAS,KAAK,QAAQ,CAAC,CAAC,CAAC,SAAS,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC,CAAC,CAAC,MAAM,CAAC;AAElE,SAAgB,SAAS,CACrB,SAAqB,EACrB,SAAkB,EAClB,eAAwB,iBAAiB;IAEzC,MAAM,eAAe;IACjB,mCAAmC;IACnC,GAAG,UAAU,CAAC,SAAS,CAAC,IAAI,CAAC,MAAM,cAAc,CAC7C,SAAS,CAAC,QAAQ,EAClB,YAAY,CACf,MAAM,eAAe,CAAC,SAAS,CAAC,IAAI,CAAC;IAC1C,MAAM,QAAQ,GAAG,SAAS,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;IAE5D,QAAQ,SAAS,CAAC,IAAI,EAAE,CAAC;QACrB,2CAAwB,CAAC,CAAC,CAAC;YACvB,MAAM,QAAQ,GAAG,SAAS,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC;YACtC,QAAQ,CAAC,IAAI,CAAC,cAAc,CAAC,CAAC;YAE9B,OAAO,IAAI,CAAC,MAAM,CACd,eAAe,EACf,GAAG,QAAQ,EACX,aAAa,QAAQ,GAAG,CAC3B,CAAC;QACN,CAAC;QAED,+BAAkB,CAAC,CAAC,CAAC;YACjB,QAAQ,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;YACxB,OAAO,IAAI,CAAC,MAAM,CACd,eAAe,EACf,GAAG,QAAQ,EACX,GAAG,SAAS,CAAC,OAAO,CACvB,CAAC;QACN,CAAC;QAED;YACI,OAAO,IAAI,CAAC,MAAM,CACd,eAAe,EACf,GAAG,QAAQ,EACX,GAAG,SAAS,CAAC,OAAO,CACvB,CAAC;IACV,CAAC;AACL,CAAC"}
{"version":3,"file":"format-log.js","sourceRoot":"","sources":["../src/format-log.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;AAgEA,8BAyCC;AAzGD,gEAAmC;AACnC,2CAA6B;AAC7B,kDAA0B;AAG1B,MAAM,iBAAiB,GAAG,CAAC,CAAC,CACxB,sBAAO,CAAC,MAAM,CAAC,KAAK,IAAI,sBAAO,CAAC,QAAQ,KAAK,QAAQ,CACxD,CAAC;AAEF,MAAM,YAAY,GAAG,CAAC,QAAkB,EAAE,EAAE,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC;AAEhE,SAAS,aAAa,CAAC,QAAkB;IACrC,QAAQ,QAAQ,EAAE,CAAC;QACf;YACI,OAAO,GAAG,CAAC;QAEf;YACI,OAAO,IAAI,CAAC;QAEhB;YACI,OAAO,GAAG,CAAC;QAEf;YACI,OAAO,GAAG,CAAC;QAEf;YACI,OAAO,IAAI,CAAC;QAEhB;YACI,OAAO,EAAE,CAAC;IAClB,CAAC;AACL,CAAC;AAED,SAAS,cAAc,CAAC,QAAkB,EAAE,YAAqB;IAC7D,MAAM,QAAQ,GAAG,YAAY;QACzB,CAAC,CAAC,aAAa,CAAC,QAAQ,CAAC;QACzB,CAAC,CAAC,YAAY,CAAC,QAAQ,CAAC,CAAC;IAE7B,QAAQ,QAAQ,EAAE,CAAC;QACf;YACI,OAAO,eAAK,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;QAEhC;YACI,OAAO,eAAK,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;QAEhC;YACI,OAAO,eAAK,CAAC,MAAM,CAAC,QAAQ,CAAC,CAAC;QAElC;YACI,OAAO,eAAK,CAAC,GAAG,CAAC,QAAQ,CAAC,CAAC;QAE/B;YACI,OAAO,eAAK,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;QAEhC;YACI,OAAO,eAAK,CAAC,KAAK,CAAC,QAAQ,CAAC,CAAC;IACrC,CAAC;AACL,CAAC;AAED,MAAM,UAAU,GAAG,CAAC,IAAU,EAAE,EAAE,CAAC,eAAK,CAAC,IAAI,CAAC,GAAG,IAAI,CAAC,kBAAkB,EAAE,EAAE,CAAC,CAAC;AAE9E,MAAM,eAAe,GAAG,CAAC,SAAkB,EAAE,EAAE,CAC3C,OAAO,SAAS,KAAK,QAAQ,CAAC,CAAC,CAAC,SAAS,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC,CAAC,CAAC,MAAM,CAAC;AAElE,SAAgB,SAAS,CACrB,SAAqB,EACrB,SAAkB,EAClB,eAAwB,iBAAiB;IAEzC,MAAM,eAAe;IACjB,mCAAmC;IACnC,GAAG,UAAU,CAAC,SAAS,CAAC,IAAI,CAAC,MAAM,cAAc,CAC7C,SAAS,CAAC,QAAQ,EAClB,YAAY,CACf,MAAM,eAAe,CAAC,SAAS,CAAC,IAAI,CAAC;IAC1C,MAAM,QAAQ,GAAG,SAAS,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,CAAC,CAAC,EAAE,CAAC;IAE5D,QAAQ,SAAS,CAAC,IAAI,EAAE,CAAC;QACrB,2CAAwB,CAAC,CAAC,CAAC;YACvB,MAAM,QAAQ,GAAG,SAAS,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC;YACtC,QAAQ,CAAC,IAAI,CAAC,cAAc,CAAC,CAAC;YAE9B,OAAO,IAAI,CAAC,MAAM,CACd,eAAe,EACf,GAAG,QAAQ,EACX,aAAa,QAAQ,GAAG,CAC3B,CAAC;QACN,CAAC;QAED,+BAAkB,CAAC,CAAC,CAAC;YACjB,QAAQ,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;YACxB,OAAO,IAAI,CAAC,MAAM,CACd,eAAe,EACf,GAAG,QAAQ,EACX,GAAG,SAAS,CAAC,OAAO,CACvB,CAAC;QACN,CAAC;QAED;YACI,OAAO,IAAI,CAAC,MAAM,CACd,eAAe,EACf,GAAG,QAAQ,EACX,GAAG,SAAS,CAAC,OAAO,CACvB,CAAC;IACV,CAAC;AACL,CAAC"}
"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
Object.defineProperty(exports, "__esModule", { value: true });

@@ -46,34 +37,32 @@ exports.LoggerServer = exports.LogLevelNumeric = void 0;

}
runQueue() {
return __awaiter(this, arguments, void 0, function* (retry = this.numberOfRetries) {
const queueItem = this.queue.shift();
if (queueItem === undefined) {
this.status = "EMPTY" /* LogQueueStatus.EMPTY */;
return;
async runQueue(retry = this.numberOfRetries) {
const queueItem = this.queue.shift();
if (queueItem === undefined) {
this.status = "EMPTY" /* LogQueueStatus.EMPTY */;
return;
}
const { logEntity, meta } = queueItem;
this.status = "RUNNING" /* LogQueueStatus.RUNNING */;
try {
const entryAfterPlugin = await this.callHook("beforeLog" /* LoggerPlugins.beforeLog */, logEntity, meta);
if (!entryAfterPlugin.muteStdout) {
const formattedMessage = (0, format_log_1.formatLog)(logEntity, meta.processID);
this.stdout.write(`${formattedMessage}\n`);
}
const { logEntity, meta } = queueItem;
this.status = "RUNNING" /* LogQueueStatus.RUNNING */;
try {
const entryAfterPlugin = yield this.callHook("beforeLog" /* LoggerPlugins.beforeLog */, logEntity, meta);
if (!entryAfterPlugin.muteStdout) {
const formattedMessage = (0, format_log_1.formatLog)(logEntity, meta.processID);
this.stdout.write(`${formattedMessage}\n`);
}
yield this.callHook("onLog" /* LoggerPlugins.onLog */, entryAfterPlugin, meta);
await this.callHook("onLog" /* LoggerPlugins.onLog */, entryAfterPlugin, meta);
this.runQueue();
}
catch (error) {
await this.callHook("onError" /* LoggerPlugins.onError */, error, meta);
if (retry > 0) {
this.queue.push({ logEntity, meta });
this.runQueue(retry - 1);
}
else if (this.shouldSkip) {
this.runQueue();
}
catch (error) {
yield this.callHook("onError" /* LoggerPlugins.onError */, error, meta);
if (retry > 0) {
this.queue.push({ logEntity, meta });
this.runQueue(retry - 1);
}
else if (this.shouldSkip) {
this.runQueue();
}
else {
throw error;
}
else {
throw error;
}
});
}
}

@@ -80,0 +69,0 @@ log(logEntity, processID) {

@@ -1,1 +0,1 @@

{"version":3,"file":"logger-server.js","sourceRoot":"","sources":["../src/logger-server.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,iEAA2D;AAC3D,2CAAsC;AAWtC,6CAAuC;AAEvC,IAAY,eAOX;AAPD,WAAY,eAAe;IACvB,2DAAO,CAAA;IACP,uDAAK,CAAA;IACL,qDAAI,CAAA;IACJ,2DAAO,CAAA;IACP,uDAAK,CAAA;IACL,yDAAM,CAAA;AACV,CAAC,EAPW,eAAe,+BAAf,eAAe,QAO1B;AAED,MAAa,YAAa,SAAQ,kCAAe;IAK7C,YACY,MAAqB,EACrB,iBAA6B,EAC7B,MAA6B,EAC7B,kBAA0B,CAAC,EAC3B,aAAsB,KAAK;QAEnC,KAAK,CAAC;;;;SAIL,CAAC,CAAC;QAVK,WAAM,GAAN,MAAM,CAAe;QACrB,sBAAiB,GAAjB,iBAAiB,CAAY;QAC7B,WAAM,GAAN,MAAM,CAAuB;QAC7B,oBAAe,GAAf,eAAe,CAAY;QAC3B,eAAU,GAAV,UAAU,CAAiB;QAT/B,UAAK,GAAqB,IAAI,aAAK,EAAE,CAAC;QAEtC,WAAM,sCAAwC;QAelD,IAAI,CAAC,0BAA0B,EAAE,CAAC;IACtC,CAAC;IAEO,0BAA0B;QAC9B,IAAI,CAAC,iBAAiB,CAAC,EAAE,kDAErB,CAAC,KAAiB,EAAE,SAAkB,EAAE,EAAE;YACtC,IAAI,CAAC,GAAG,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;QAC/B,CAAC,CACJ,CAAC;IACN,CAAC;IAEa,QAAQ;6DAClB,QAAgB,IAAI,CAAC,eAAe;YAEpC,MAAM,SAAS,GAAG,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;YAErC,IAAI,SAAS,KAAK,SAAS,EAAE,CAAC;gBAC1B,IAAI,CAAC,MAAM,qCAAuB,CAAC;gBACnC,OAAO;YACX,CAAC;YAED,MAAM,EAAC,SAAS,EAAE,IAAI,EAAC,GAAG,SAAS,CAAC;YAEpC,IAAI,CAAC,MAAM,yCAAyB,CAAC;YAErC,IAAI,CAAC;gBACD,MAAM,gBAAgB,GAAG,MAAM,IAAI,CAAC,QAAQ,4CAExC,SAAS,EACT,IAAI,CACP,CAAC;gBAEF,IAAI,CAAC,gBAAgB,CAAC,UAAU,EAAE,CAAC;oBAC/B,MAAM,gBAAgB,GAAG,IAAA,sBAAS,EAAC,SAAS,EAAE,IAAI,CAAC,SAAS,CAAC,CAAC;oBAC9D,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,GAAG,gBAAgB,IAAI,CAAC,CAAC;gBAC/C,CAAC;gBAED,MAAM,IAAI,CAAC,QAAQ,oCAAsB,gBAAgB,EAAE,IAAI,CAAC,CAAC;gBAEjE,IAAI,CAAC,QAAQ,EAAE,CAAC;YACpB,CAAC;YAAC,OAAO,KAAK,EAAE,CAAC;gBACb,MAAM,IAAI,CAAC,QAAQ,wCAAwB,KAAK,EAAE,IAAI,CAAC,CAAC;gBAExD,IAAI,KAAK,GAAG,CAAC,EAAE,CAAC;oBACZ,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,EAAC,SAAS,EAAE,IAAI,EAAC,CAAC,CAAC;oBACnC,IAAI,CAAC,QAAQ,CAAC,KAAK,GAAG,CAAC,CAAC,CAAC;gBAC7B,CAAC;qBAAM,IAAI,IAAI,CAAC,UAAU,EAAE,CAAC;oBACzB,IAAI,CAAC,QAAQ,EAAE,CAAC;gBACpB,CAAC;qBAAM,CAAC;oBACJ,MAAM,KAAK,CAAC;gBAChB,CAAC;YACL,CAAC;QACL,CAAC;KAAA;IAEO,GAAG,CAAC,SAAqB,EAAE,SAAkB;QACjD,wBAAwB;QACxB,IAAI,IAAI,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC;YACrB,OAAO;QACX,CAAC;QAED,yBAAyB;QACzB,IACI,eAAe,CAAC,SAAS,CAAC,QAAQ,CAAC;YACnC,eAAe,CAAC,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,EACvC,CAAC;YACC,OAAO;QACX,CAAC;QAED,MAAM,SAAS,GAAG,IAAI,CAAC,MAAM,2CAA2B,CAAC;QACzD,MAAM,IAAI,GAAG,SAAS,CAAC,CAAC,CAAC,EAAC,SAAS,EAAC,CAAC,CAAC,CAAC,EAAE,CAAC;QAE1C,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC;YACZ,SAAS;YACT,IAAI;SACP,CAAC,CAAC;QAEH,IAAI,SAAS,EAAE,CAAC;YACZ,IAAI,CAAC,QAAQ,EAAE,CAAC;QACpB,CAAC;IACL,CAAC;IAEM,cAAc;QACjB,OAAO,IAAI,CAAC,MAAM,CAAC;IACvB,CAAC;CACJ;AAvGD,oCAuGC"}
{"version":3,"file":"logger-server.js","sourceRoot":"","sources":["../src/logger-server.ts"],"names":[],"mappings":";;;AAAA,iEAA2D;AAC3D,2CAAsC;AAWtC,6CAAuC;AAEvC,IAAY,eAOX;AAPD,WAAY,eAAe;IACvB,2DAAO,CAAA;IACP,uDAAK,CAAA;IACL,qDAAI,CAAA;IACJ,2DAAO,CAAA;IACP,uDAAK,CAAA;IACL,yDAAM,CAAA;AACV,CAAC,EAPW,eAAe,+BAAf,eAAe,QAO1B;AAED,MAAa,YAAa,SAAQ,kCAAe;IAK7C,YACY,MAAqB,EACrB,iBAA6B,EAC7B,MAA6B,EAC7B,kBAA0B,CAAC,EAC3B,aAAsB,KAAK;QAEnC,KAAK,CAAC;;;;SAIL,CAAC,CAAC;QAVK,WAAM,GAAN,MAAM,CAAe;QACrB,sBAAiB,GAAjB,iBAAiB,CAAY;QAC7B,WAAM,GAAN,MAAM,CAAuB;QAC7B,oBAAe,GAAf,eAAe,CAAY;QAC3B,eAAU,GAAV,UAAU,CAAiB;QAT/B,UAAK,GAAqB,IAAI,aAAK,EAAE,CAAC;QAEtC,WAAM,sCAAwC;QAelD,IAAI,CAAC,0BAA0B,EAAE,CAAC;IACtC,CAAC;IAEO,0BAA0B;QAC9B,IAAI,CAAC,iBAAiB,CAAC,EAAE,kDAErB,CAAC,KAAiB,EAAE,SAAkB,EAAE,EAAE;YACtC,IAAI,CAAC,GAAG,CAAC,KAAK,EAAE,SAAS,CAAC,CAAC;QAC/B,CAAC,CACJ,CAAC;IACN,CAAC;IAEO,KAAK,CAAC,QAAQ,CAClB,QAAgB,IAAI,CAAC,eAAe;QAEpC,MAAM,SAAS,GAAG,IAAI,CAAC,KAAK,CAAC,KAAK,EAAE,CAAC;QAErC,IAAI,SAAS,KAAK,SAAS,EAAE,CAAC;YAC1B,IAAI,CAAC,MAAM,qCAAuB,CAAC;YACnC,OAAO;QACX,CAAC;QAED,MAAM,EAAC,SAAS,EAAE,IAAI,EAAC,GAAG,SAAS,CAAC;QAEpC,IAAI,CAAC,MAAM,yCAAyB,CAAC;QAErC,IAAI,CAAC;YACD,MAAM,gBAAgB,GAAG,MAAM,IAAI,CAAC,QAAQ,4CAExC,SAAS,EACT,IAAI,CACP,CAAC;YAEF,IAAI,CAAC,gBAAgB,CAAC,UAAU,EAAE,CAAC;gBAC/B,MAAM,gBAAgB,GAAG,IAAA,sBAAS,EAAC,SAAS,EAAE,IAAI,CAAC,SAAS,CAAC,CAAC;gBAC9D,IAAI,CAAC,MAAM,CAAC,KAAK,CAAC,GAAG,gBAAgB,IAAI,CAAC,CAAC;YAC/C,CAAC;YAED,MAAM,IAAI,CAAC,QAAQ,oCAAsB,gBAAgB,EAAE,IAAI,CAAC,CAAC;YAEjE,IAAI,CAAC,QAAQ,EAAE,CAAC;QACpB,CAAC;QAAC,OAAO,KAAK,EAAE,CAAC;YACb,MAAM,IAAI,CAAC,QAAQ,wCAAwB,KAAK,EAAE,IAAI,CAAC,CAAC;YAExD,IAAI,KAAK,GAAG,CAAC,EAAE,CAAC;gBACZ,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,EAAC,SAAS,EAAE,IAAI,EAAC,CAAC,CAAC;gBACnC,IAAI,CAAC,QAAQ,CAAC,KAAK,GAAG,CAAC,CAAC,CAAC;YAC7B,CAAC;iBAAM,IAAI,IAAI,CAAC,UAAU,EAAE,CAAC;gBACzB,IAAI,CAAC,QAAQ,EAAE,CAAC;YACpB,CAAC;iBAAM,CAAC;gBACJ,MAAM,KAAK,CAAC;YAChB,CAAC;QACL,CAAC;IACL,CAAC;IAEO,GAAG,CAAC,SAAqB,EAAE,SAAkB;QACjD,wBAAwB;QACxB,IAAI,IAAI,CAAC,MAAM,CAAC,MAAM,EAAE,CAAC;YACrB,OAAO;QACX,CAAC;QAED,yBAAyB;QACzB,IACI,eAAe,CAAC,SAAS,CAAC,QAAQ,CAAC;YACnC,eAAe,CAAC,IAAI,CAAC,MAAM,CAAC,QAAQ,CAAC,EACvC,CAAC;YACC,OAAO;QACX,CAAC;QAED,MAAM,SAAS,GAAG,IAAI,CAAC,MAAM,2CAA2B,CAAC;QACzD,MAAM,IAAI,GAAG,SAAS,CAAC,CAAC,CAAC,EAAC,SAAS,EAAC,CAAC,CAAC,CAAC,EAAE,CAAC;QAE1C,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC;YACZ,SAAS;YACT,IAAI;SACP,CAAC,CAAC;QAEH,IAAI,SAAS,EAAE,CAAC;YACZ,IAAI,CAAC,QAAQ,EAAE,CAAC;QACpB,CAAC;IACL,CAAC;IAEM,cAAc;QACjB,OAAO,IAAI,CAAC,MAAM,CAAC;IACvB,CAAC;CACJ;AAvGD,oCAuGC"}
{
"name": "@testring/logger",
"version": "0.7.6",
"version": "0.8.0",
"main": "./dist/index.js",

@@ -13,6 +13,6 @@ "types": "./src/index.ts",

"dependencies": {
"@testring/pluggable-module": "0.7.6",
"@testring/transport": "0.7.6",
"@testring/types": "0.7.6",
"@testring/utils": "0.7.6",
"@testring/pluggable-module": "0.8.0",
"@testring/transport": "0.8.0",
"@testring/types": "0.8.0",
"@testring/utils": "0.8.0",
"@types/bytes": "3.1.4",

@@ -24,4 +24,4 @@ "@types/node": "22.8.5",

"devDependencies": {
"@testring/test-utils": "0.7.6"
"@testring/test-utils": "0.8.0"
}
}

@@ -113,27 +113,27 @@ import {Stack, generateUniqId} from '@testring/utils';

public log(...args): void {
public log(...args: Array<any>): void {
this.createLog(LogTypes.log, LogLevel.info, args);
}
public info(...args): void {
public info(...args: Array<any>): void {
this.createLog(LogTypes.info, LogLevel.info, args);
}
public success(...args): void {
public success(...args: Array<any>): void {
this.createLog(LogTypes.success, LogLevel.info, args);
}
public warn(...args): void {
public warn(...args: Array<any>): void {
this.createLog(LogTypes.warning, LogLevel.warning, args);
}
public error(...args): void {
public error(...args: Array<any>): void {
this.createLog(LogTypes.error, LogLevel.error, args);
}
public debug(...args): void {
public debug(...args: Array<any>): void {
this.createLog(LogTypes.debug, LogLevel.debug, args);
}
public verbose(...args): void {
public verbose(...args: Array<any>): void {
this.createLog(LogTypes.debug, LogLevel.verbose, args);

@@ -150,3 +150,3 @@ }

public media(...args): void {
public media(...args: Array<any>): void {
this.createLog(LogTypes.media, LogLevel.info, args);

@@ -153,0 +153,0 @@ }

@@ -1,4 +0,4 @@

import * as process from 'process';
import process from 'node:process';
import * as util from 'util';
import * as chalk from 'chalk';
import chalk from 'chalk';
import {ILogEntity, LogLevel, LogTypes} from '@testring/types';

@@ -5,0 +5,0 @@