30 lines
958 B
TypeScript
30 lines
958 B
TypeScript
import {db} from "../../../database/dbclient.js";
|
|
import {logs} from "../../../database/schema/logs.js";
|
|
import build from "pino-abstract-transport";
|
|
|
|
type Log = {
|
|
username: string | null;
|
|
service: string;
|
|
level: string;
|
|
msg: string;
|
|
};
|
|
// Create a custom transport function
|
|
export default async function (log: Log) {
|
|
//const {username, service, level, msg, ...extra} = log;
|
|
try {
|
|
return build(async function (source) {
|
|
for await (let obj of source) {
|
|
// Insert log entry into the PostgreSQL database using Drizzle ORM
|
|
await db.insert(logs).values({
|
|
level: obj.level,
|
|
username: obj?.username.toLowerCase(),
|
|
service: obj?.service.toLowerCase(),
|
|
message: obj.msg,
|
|
});
|
|
}
|
|
});
|
|
} catch (err) {
|
|
console.error("Error inserting log into database:", err);
|
|
}
|
|
}
|