Class DatabaseLogManager

packages/core/src/logger.ts:132–175

}

class DatabaseLogManager {
  constructor(private readonly db: Kysely<LogDatabaseSchema>) {}

  async get() {
    const logs = await this.db
      .selectFrom("logs")
      .select([
        "timestamp",
        "message",
        "level",
        "scope",
        "extras",
        "elapsed",
        "date"
      ])
      .execute();
    const groupedLogs: Record<string, LogMessage[]> = {};

    for (const log of logs) {
      const key = log.date!;
      if (!groupedLogs[key]) groupedLogs[key] = [];
      groupedLogs[key].push(log as LogMessage);
    }

    return Object.keys(groupedLogs)
      .sort((a, b) => b.localeCompare(a, undefined, { numeric: true }))
      .map((key) => ({
        key,
        logs: groupedLogs[key]?.sort((a, b) => a.timestamp - b.timestamp)
      }));
  }

  async clear() {
    await this.db.deleteFrom("logs").execute();
  }

  async delete(key: string) {
    await this.db.deleteFrom("logs").where("date", "==", key).execute();
  }

  close() {
    return this.db.destroy();
  }
}

async function initialize(
  options: SQLiteOptions,