cowch/lstV2
1
0
Fork 0
Code Issues 37 Pull Requests Actions Packages Projects 1 Releases Wiki Activity

fix(log cleanup): corrected the level look at

Browse Source
This commit is contained in:
cowchmonkey@gmail.com
2025-04-21 07:48:49 -05:00
parent bb6d1c3bff
commit 8240e9c5d3
1 changed files with 32 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
server/services/logger/controller/logCleanup.ts
View File

@@ -1,7 +1,7 @@
import {and, eq, inArray, lte, ne, sql} from "drizzle-orm"; import { and, eq, inArray, lte, ne, sql } from "drizzle-orm";
import {db} from "../../../../database/dbclient.js"; import { db } from "../../../../database/dbclient.js";
import {logs} from "../../../../database/schema/logs.js"; import { logs } from "../../../../database/schema/logs.js";
import {createLog} from "../logger.js"; import { createLog } from "../logger.js";
export const logCleanup = async () => { export const logCleanup = async () => {
/** /**
@@ -16,11 +16,11 @@ export const logCleanup = async () => {
.where( .where(
and( and(
lte(logs.created_at, sql`NOW() - INTERVAL '3 days'`), lte(logs.created_at, sql`NOW() - INTERVAL '3 days'`),
inArray(logs.service, ["server", "tcp", "sqlProd", "globalutils"]), //inArray(logs.service, ["server", "tcp", "sqlProd", "globalutils","notify", "logger", "serverupdater"]),
eq(logs.level, "30") eq(logs.level, "info")
) )
) )
.returning({name: logs.message}); .returning({ name: logs.message });
createLog( createLog(
"info", "info",
"lst", "lst",
@@ -28,7 +28,12 @@ export const logCleanup = async () => {
`${delLogs.length} Server logs were just deleted that were older than 3 days` `${delLogs.length} Server logs were just deleted that were older than 3 days`
); );
} catch (error) { } catch (error) {
createLog("error", "lst", "logger", `There was an error deleteing server logs. ${error}`); createLog(
"error",
"lst",
"logger",
`There was an error deleteing server logs. ${error}`
);
} }
try { try {
@@ -38,11 +43,11 @@ export const logCleanup = async () => {
.where( .where(
and( and(
lte(logs.created_at, sql`NOW() - INTERVAL '7 days'`), lte(logs.created_at, sql`NOW() - INTERVAL '7 days'`),
inArray(logs.service, ["server", "tcp", "sqlProd", "globalutils"]), //inArray(logs.service, ["server", "tcp", "sqlProd", "globalutils", "notify", "logger", "serverupdater"]),
ne(logs.level, "30") ne(logs.level, "info")
) )
) )
.returning({name: logs.message}); .returning({ name: logs.message });
createLog( createLog(
"info", "info",
"lst", "lst",
@@ -50,6 +55,11 @@ export const logCleanup = async () => {
`${delLogs.length} Server logs were just deleted that were older than 7 days` `${delLogs.length} Server logs were just deleted that were older than 7 days`
); );
} catch (error) { } catch (error) {
createLog("error", "lst", "logger", `There was an error deleteing server logs. ${error}`); createLog(
"error",
"lst",
"logger",
`There was an error deleteing server logs. ${error}`
);
} }
}; };