Files
2026-07-26 18:25:37 +09:00

96 lines
4.1 KiB
JavaScript

import cluster from "node:cluster";
import chalk from "chalk";
import { default as convertColor } from "color-convert";
import { format as dateFormat } from "date-fns";
import { envOption } from "../env.js";
import config from "../config/index.js";
import * as SyslogPro from "syslog-pro";
export default class Logger {
domain;
parentLogger = null;
store;
syslogClient = null;
constructor(domain, color, store = true){
this.domain = {
name: domain,
color: color
};
this.store = store;
if (config.syslog) {
this.syslogClient = new SyslogPro.RFC5424({
applacationName: "FrozenFriendsYume",
timestamp: true,
encludeStructuredData: true,
color: true,
extendedColor: true,
server: {
target: config.syslog.host,
port: config.syslog.port
}
});
}
}
createSubLogger(domain, color, store = true) {
const logger = new Logger(domain, color, store);
logger.parentLogger = this;
return logger;
}
log(level, message, data, important = false, subDomains = [], store = true) {
if (envOption.quiet) return;
if (!this.store) store = false;
if (level === "debug") store = false;
if (this.parentLogger) {
this.parentLogger.log(level, message, data, important, [
this.domain
].concat(subDomains), store);
return;
}
const time = dateFormat(new Date(), "HH:mm:ss");
const worker = cluster.isPrimary ? "*" : cluster.worker.id;
const l = level === "error" ? important ? chalk.bgRed.white("ERR ") : chalk.red("ERR ") : level === "warning" ? chalk.yellow("WARN") : level === "success" ? important ? chalk.bgGreen.white("DONE") : chalk.green("DONE") : level === "debug" ? chalk.gray("VERB") : level === "info" ? chalk.blue("INFO") : null;
const domains = [
this.domain
].concat(subDomains).map((d)=>d.color ? chalk.rgb(...convertColor.keyword.rgb(d.color))(d.name) : chalk.white(d.name));
const m = level === "error" ? chalk.red(message) : level === "warning" ? chalk.yellow(message) : level === "success" ? chalk.green(message) : level === "debug" ? chalk.gray(message) : level === "info" ? message : null;
let log = `${l} ${worker}\t[${domains.join(" ")}]\t${m}`;
if (envOption.withLogTime) log = `${chalk.gray(time)} ${log}`;
console.log(important ? chalk.bold(log) : log);
if (store) {
if (this.syslogClient) {
const send = level === "error" ? this.syslogClient.error : level === "warning" ? this.syslogClient.warning : level === "success" ? this.syslogClient.info : level === "debug" ? this.syslogClient.info : level === "info" ? this.syslogClient.info : null;
send.bind(this.syslogClient)(message).catch(()=>{});
}
}
}
error(x, data, important = false) {
// 実行を継続できない状況で使う
if (x instanceof Error) {
data = data || {};
data.e = x;
this.log("error", x.toString(), data, important);
} else if (typeof x === "object") {
this.log("error", `${x.message || x.name || x}`, data, important);
} else {
this.log("error", `${x}`, data, important);
}
}
warn(message, data, important = false) {
// 実行を継続できるが改善すべき状況で使う
this.log("warning", message, data, important);
}
succ(message, data, important = false) {
// 何かに成功した状況で使う
this.log("success", message, data, important);
}
debug(message, data, important = false) {
// デバッグ用に使う(開発者に必要だが利用者に不要な情報)
if (process.env.NODE_ENV !== "production" || envOption.verbose) {
this.log("debug", message, data, important);
}
}
info(message, data, important = false) {
// それ以外
this.log("info", message, data, important);
}
}