dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-26 17:55:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

logger refactor

Browse Source
This commit is contained in:
Jan Prochazka
2023-01-28 09:17:57 +01:00
parent dbcc732688
commit a43522752c
3 changed files with 129 additions and 132 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/tools/src/getLogger.ts
View File

@@ -3,7 +3,7 @@ import { createPinoLikeLogger, ILogger } from './pinomin';
let _logger: ILogger;
let _name: string = null;
const defaultLogger: ILogger = createPinoLikeLogger({
pid: global?.process?.pid,
base: { pid: global?.process?.pid },
targets: [{ type: 'console', level: 'info' }],
});

257
packages/tools/src/pinomin.ts
View File

@@ -1,141 +1,138 @@
export interface ILogger {
trace(msg: string);
trace(data: {} | Error, msg: string);
debug(msg: string);
debug(data: {} | Error, msg: string);
info(msg: string);
info(data: {} | Error, msg: string);
warn(msg: string);
warn(data: {} | Error, msg: string);
error(msg: string);
error(data: {} | Error, msg: string);
fatal(msg: string);
fatal(data: {} | Error, msg: string);
child(childProps: {}): ILogger;
log(record: ILogRecord);
trace(msg: string);
trace(data: {} | Error, msg: string);
debug(msg: string);
debug(data: {} | Error, msg: string);
info(msg: string);
info(data: {} | Error, msg: string);
warn(msg: string);
warn(data: {} | Error, msg: string);
error(msg: string);
error(data: {} | Error, msg: string);
fatal(msg: string);
fatal(data: {} | Error, msg: string);
child(childProps: {}): ILogger;
log(record: ILogRecord);
}
export interface ILogRecord {
time: number;
level: number;
msg: string;
pid?: number;
}
class PinoLikeLogger implements ILogger {
constructor(public config: ILogConfig) {}
trace(msg: string);
trace(data: {} | Error, msg: string);
trace(data, msg?) {
this.log(this.packRecord(logLevelNumbers.trace, data, msg));
}
export interface ILogRecord {
level: number;
msg: string;
pid: number;
time: number;
debug(msg: string);
debug(data: {} | Error, msg: string);
debug(data, msg?) {
this.log(this.packRecord(logLevelNumbers.debug, data, msg));
}
class PinoLikeLogger implements ILogger {
constructor(public config: ILogConfig, public baseProps: {} = {}) {}
trace(msg: string);
trace(data: {} | Error, msg: string);
trace(data, msg?) {
this.log(this.packRecord(logLevelNumbers.trace, data, msg));
}
debug(msg: string);
debug(data: {} | Error, msg: string);
debug(data, msg?) {
this.log(this.packRecord(logLevelNumbers.debug, data, msg));
}
info(msg: string);
info(data: {} | Error, msg: string);
info(data, msg?) {
this.log(this.packRecord(logLevelNumbers.info, data, msg));
}
warn(msg: string);
warn(data: {} | Error, msg: string);
warn(data, msg?) {
this.log(this.packRecord(logLevelNumbers.warn, data, msg));
}
error(msg: string);
error(data: {} | Error, msg: string);
error(data, msg?) {
this.log(this.packRecord(logLevelNumbers.error, data, msg));
}
fatal(msg: string);
fatal(data: {} | Error, msg: string);
fatal(data, msg?) {
this.log(this.packRecord(logLevelNumbers.fatal, data, msg));
}
packRecord(level: number, data, msg?): ILogRecord {
if (msg) {
return {
...this.baseProps,
...data,
level,
msg,
pid: this.config.pid,
time: new Date().getTime(),
};
}
info(msg: string);
info(data: {} | Error, msg: string);
info(data, msg?) {
this.log(this.packRecord(logLevelNumbers.info, data, msg));
}
warn(msg: string);
warn(data: {} | Error, msg: string);
warn(data, msg?) {
this.log(this.packRecord(logLevelNumbers.warn, data, msg));
}
error(msg: string);
error(data: {} | Error, msg: string);
error(data, msg?) {
this.log(this.packRecord(logLevelNumbers.error, data, msg));
}
fatal(msg: string);
fatal(data: {} | Error, msg: string);
fatal(data, msg?) {
this.log(this.packRecord(logLevelNumbers.fatal, data, msg));
}
packRecord(level: number, data, msg?): ILogRecord {
if (msg) {
return {
...this.baseProps,
...this.config.base,
...data,
level,
msg: data,
pid: this.config.pid,
msg,
time: new Date().getTime(),
};
};
}
log(record: ILogRecord) {
for (const target of this.config.targets) {
if (record.level < logLevelNames[target.level]) {
continue;
}
switch (target.type) {
case 'console':
console.log(JSON.stringify(record));
break;
case 'stream':
target.stream.write(JSON.stringify(record) + '\n');
break;
}
return {
...this.config.base,
level,
msg: data,
time: new Date().getTime(),
};
}
log(record: ILogRecord) {
for (const target of this.config.targets) {
if (record.level < logLevelNames[target.level]) {
continue;
}
switch (target.type) {
case 'console':
console.log(JSON.stringify(record));
break;
case 'stream':
target.stream.write(JSON.stringify(record) + '\n');
break;
}
}
child(childProps: {}): ILogger {
return new PinoLikeLogger(this.config, {
...this.baseProps,
...childProps,
});
}
}
export const logLevelNames = {
10: 'trace',
20: 'debug',
30: 'info',
40: 'warn',
50: 'error',
60: 'fatal',
};
export const logLevelNumbers = {
trace: 10,
debug: 20,
info: 30,
warn: 40,
error: 50,
fatal: 60,
};
interface ILogTargetConfig {
level: keyof typeof logLevelNumbers;
type: 'console' | 'stream';
stream?: any;
child(childProps: {}): ILogger {
return new PinoLikeLogger({
...this.config,
base: { ...this.config.base, ...childProps },
});
}
interface ILogConfig {
pid?: number;
targets: ILogTargetConfig[];
}
export function createPinoLikeLogger(config: ILogConfig): ILogger {
return new PinoLikeLogger(config);
}
}
export const logLevelNames = {
10: 'trace',
20: 'debug',
30: 'info',
40: 'warn',
50: 'error',
60: 'fatal',
};
export const logLevelNumbers = {
trace: 10,
debug: 20,
info: 30,
warn: 40,
error: 50,
fatal: 60,
};
interface ILogTargetConfig {
level: keyof typeof logLevelNumbers;
type: 'console' | 'stream';
stream?: any;
}
interface ILogConfig {
base: {};
targets: ILogTargetConfig[];
}
export function createPinoLikeLogger(config: ILogConfig): ILogger {
return new PinoLikeLogger(config);
}