Class ConsoleSink

packages/query-plan-executor/src/log/sink.ts:15–50

 * A log sink that writes log events to the console.
 */
export class ConsoleSink implements LogSink {
  readonly #formatter: ConsoleFormatter

  constructor(formatter: ConsoleFormatter) {
    this.#formatter = formatter
  }

  write(event: LogEvent): void {
    const parts = this.#formatter.format(event)

    switch (event.level) {
      case 'debug':
        console.debug(...parts)
        break

      case 'query':
        console.log(...parts)
        break

      case 'info':
        console.info(...parts)
        break

      case 'warn':
        console.warn(...parts)
        break

      case 'error':
        console.error(...parts)
        break

      default:
        throw new Error(`Invalid log level: ${event.level satisfies never}`)
    }
  }
}

/**
 * A log sink that captures log events in memory.