Press n or j to go to the next uncovered block, b, p or k for the previous block.
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 | 1x 1x 1x 1x 1x 1x 1x 1x | import { KafkaJS } from '@confluentinc/kafka-javascript';
import { EventSdk, IKafka } from 'src/packages/event-sdk';
import { Logger } from 'src/packages/logger';
import { LoggerType } from 'src/packages/logger/shared/const';
import ENV from './env';
export const logger = new Logger(LoggerType.Pino, {
enabled: ENV.LOGGER.ENABLED,
colorEnabled: ENV.LOGGER.COLOR_ENABLED,
prettyEnabled: ENV.LOGGER.PRETTY_ENABLED,
redact: {
enabled: ENV.LOGGER.REDACT.ENABLED,
paths: ENV.LOGGER.REDACT.PATHS,
censor: ENV.LOGGER.REDACT.CENSOR,
},
});
class EventSdkLogger implements IKafka.Logger {
private currentLogLevel: KafkaJS.logLevel;
private ns: string;
constructor(namespace = 'root', level = EventSdk.LogLevel.INFO) {
this.ns = namespace;
this.currentLogLevel = level;
}
private shouldLog(level: KafkaJS.logLevel): boolean {
return level <= this.currentLogLevel;
}
private log(
method: 'info' | 'warn' | 'error' | 'debug',
level: KafkaJS.logLevel,
message: string,
extra?: object,
) {
Iif (!this.shouldLog(level)) return;
logger[method](`[${this.ns}] ${message}`, extra);
}
info(message: string, extra?: object) {
this.log('info', EventSdk.LogLevel.INFO, message, extra);
}
error(message: string, extra?: object) {
this.log('error', EventSdk.LogLevel.ERROR, message, extra);
}
warn(message: string, extra?: object) {
this.log('warn', EventSdk.LogLevel.WARN, message, extra);
}
debug(message: string, extra?: object) {
this.log('debug', EventSdk.LogLevel.DEBUG, message, extra);
}
namespace(namespace: string, logLevel?: KafkaJS.logLevel): IKafka.Logger {
return new EventSdkLogger(namespace, logLevel ?? this.currentLogLevel);
}
setLogLevel(level: KafkaJS.logLevel) {
this.currentLogLevel = level;
}
}
export const eventSdkLogger = new EventSdkLogger();
|