lifegpc/eh-downloader
1
0
Fork 0
mirror of https://github.com/lifegpc/eh-downloader.git synced 2026-06-06 05:38:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: Add log entry retrieval and deletion API endpoints

Browse Source
This commit is contained in:
lifegpc
2025-01-01 22:20:46 +08:00
parent 39b974876e
commit da25b2f108
4 changed files with 183 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
utils/logger.ts
View File

@@ -150,6 +150,41 @@ class BaseLogger {
],
);
}
clear(
type?: string | null,
min_level?: number | null,
max_level?: number | null,
deleted_level?: number[],
end_time?: Date | null,
) {
if (!this.db) return;
const where = [];
const args: QueryParameterSet = [];
if (type) {
where.push("type = ?");
args.push(type);
}
if (min_level) {
where.push("level >= ?");
args.push(min_level);
}
if (max_level) {
where.push("level <= ?");
args.push(max_level);
}
if (deleted_level) {
where.push(
"level IN (" + deleted_level.map(() => "?").join(",") + ")",
);
args.push(...deleted_level);
}
if (end_time) {
where.push("time <= ?");
args.push(end_time.getTime());
}
const where_str = where.length ? " WHERE " + where.join(" AND ") : "";
this.db.query(`DELETE FROM log${where_str};`, args);
}
close() {
this.db?.close();
this.db = undefined;
@@ -201,6 +236,10 @@ class BaseLogger {
debug(type: string, ...messages: unknown[]) {
this.add(type, LogLevel.Debug, ...messages);
}
delete_log(id: number | bigint) {
if (!this.db) return;
this.db.query("DELETE FROM log WHERE id = ?;", [id]);
}
error(type: string, ...messages: unknown[]) {
this.add(type, LogLevel.Error, ...messages);
}
@@ -240,6 +279,14 @@ class BaseLogger {
);
}
}
get_log(id: number | bigint) {
if (!this.db) return null;
const cur = this.#convert(this.db.queryEntries<LogEntryRaw>(
"SELECT * FROM log WHERE id = ?;",
[id],
));
return cur.length ? cur[0] : null;
}
get_logger(type: string) {
return new Logger(this, type);
}