tachybase_todo/packages/core/logger/src/system-logger.ts
YANG QIA 318b433482
chore(logger): improve format (#3290)
* chore(logger): improve format

* fix: build

* feat: develop format

* chore: develop -> console
2023-12-30 23:34:40 +08:00

73 lines
2.0 KiB
TypeScript

import winston, { Logger, format } from 'winston';
import { LoggerOptions, createLogger } from './logger';
import Transport from 'winston-transport';
import { SPLAT } from 'triple-beam';
import { getFormat } from './format';
export interface SystemLoggerOptions extends LoggerOptions {
seperateError?: boolean; // print error seperately, default true
}
export type logMethod = (
message: string,
meta?: {
module?: string;
submodule?: string;
method?: string;
[key: string]: any;
},
) => SystemLogger;
export interface SystemLogger extends Omit<Logger, 'info' | 'warn' | 'error' | 'debug'> {
info: logMethod;
warn: logMethod;
error: logMethod;
debug: logMethod;
}
class SystemLoggerTransport extends Transport {
private logger: winston.Logger;
private errorLogger: winston.Logger;
constructor({ seperateError, filename, ...options }: SystemLoggerOptions) {
super({ ...options, format: null });
this.logger = createLogger({
...options,
filename,
format: winston.format.combine(
format((info) => (seperateError && info.level === 'error' ? false : info))(),
getFormat(options.format),
),
});
if (seperateError) {
this.errorLogger = createLogger({
...options,
filename: `${filename}_error`,
level: 'error',
});
}
}
log(info: any, callback: any) {
const { level, message, reqId, app, [SPLAT]: args } = info;
const logger = level === 'error' && this.errorLogger ? this.errorLogger : this.logger;
const { module, submodule, method, ...meta } = args?.[0] || {};
logger.log({
level,
message,
meta,
module: module || info['module'] || '',
submodule: submodule || info['submodule'] || '',
method: method || '',
app,
reqId,
});
callback(null, true);
}
}
export const createSystemLogger = (options: SystemLoggerOptions): SystemLogger =>
winston.createLogger({
transports: [new SystemLoggerTransport(options)],
});