import { open, File, Writer } from "deno"; import { getLevelByName } from "./levels.ts"; import { LogRecord } from "./logger.ts"; const DEFAULT_FORMATTER = "{levelName} {msg}"; type FormatterFunction = (logRecord: LogRecord) => string; interface HandlerOptions { formatter?: string | FormatterFunction; } export class BaseHandler { level: number; levelName: string; formatter: string | FormatterFunction; constructor(levelName: string, options: HandlerOptions = {}) { this.level = getLevelByName(levelName); this.levelName = levelName; this.formatter = options.formatter || DEFAULT_FORMATTER; } handle(logRecord: LogRecord) { if (this.level > logRecord.level) return; const msg = this.format(logRecord); return this.log(msg); } format(logRecord: LogRecord): string { if (this.formatter instanceof Function) { return this.formatter(logRecord); } return this.formatter.replace(/{(\S+)}/g, (match, p1) => { const value = logRecord[p1]; // do not interpolate missing values if (!value) { return match; } return value; }); } log(msg: string) {} async setup() {} async destroy() {} } export class ConsoleHandler extends BaseHandler { log(msg: string) { console.log(msg); } } export abstract class WriterHandler extends BaseHandler { protected _writer: Writer; private _encoder = new TextEncoder(); log(msg: string) { this._writer.write(this._encoder.encode(msg + "\n")); } } interface FileHandlerOptions extends HandlerOptions { filename: string; } export class FileHandler extends WriterHandler { private _file: File; private _filename: string; constructor( levelName: string, options: FileHandlerOptions, ) { super(levelName, options); this._filename = options.filename; } async setup() { // open file in append mode - write only this._file = await open(this._filename, "a"); this._writer = this._file; } async destroy() { await this._file.close(); } }