44 lines
1.2 KiB
TypeScript
44 lines
1.2 KiB
TypeScript
import superjson from "superjson";
|
|
import Transport from "winston-transport";
|
|
|
|
import type { RedisClient } from "@homarr/core/infrastructure/redis";
|
|
import { createRedisClient } from "@homarr/core/infrastructure/redis";
|
|
|
|
const messageSymbol = Symbol.for("message");
|
|
const levelSymbol = Symbol.for("level");
|
|
|
|
//
|
|
// Inherit from `winston-transport` so you can take advantage
|
|
// of the base functionality and `.exceptions.handle()`.
|
|
//
|
|
export class RedisTransport extends Transport {
|
|
private redis: RedisClient | null = null;
|
|
|
|
/**
|
|
* Log the info to the Redis channel
|
|
*/
|
|
log(info: { [messageSymbol]: string; [levelSymbol]: string }, callback: () => void) {
|
|
setImmediate(() => {
|
|
this.emit("logged", info);
|
|
});
|
|
|
|
// Is only initialized here because it did not work when initialized in the constructor or outside the class
|
|
this.redis ??= createRedisClient();
|
|
|
|
this.redis
|
|
.publish(
|
|
"pubSub:logging",
|
|
superjson.stringify({
|
|
message: info[messageSymbol],
|
|
level: info[levelSymbol],
|
|
}),
|
|
)
|
|
.then(() => {
|
|
callback();
|
|
})
|
|
.catch(() => {
|
|
// Ignore errors
|
|
});
|
|
}
|
|
}
|