Class RootLoggerImpl

packages/agent-core/src/logging/logger.ts:34–224

}

class RootLoggerImpl implements RootLogger {
  private config: LoggingConfig | undefined;
  private globalSink: RotatingFileSink | undefined;
  private readonly sessions = new Map<string, SessionEntry>();
  private readonly sessionsById = new Map<string, Set<string>>();

  isConfigured(): boolean {
    return this.config !== undefined;
  }

  getConfig(): LoggingConfig | undefined {
    return this.config;
  }

  configure(config: LoggingConfig): Promise<void> {
    if (this.config !== undefined && sameLoggingConfig(this.config, config)) {
      return Promise.resolve();
    }
    const oldGlobalSink = this.globalSink;
    this.config = config;
    this.globalSink = makeGlobalSink(config);
    return oldGlobalSink?.close() ?? Promise.resolve();
  }

  attachSession(input: SessionAttachInput): SessionLogHandle {
    const existing = this.findOpenSession(input.sessionId, input.sessionDir);
    if (existing !== undefined) {
      existing.refCount += 1;
      return makeHandle(existing);
    }
    const config = this.config;
    if (config === undefined || config.level === 'off') {
      return makeNoopHandle(input.sessionId);
    }
    const sink = new RotatingFileSink({
      path: join(input.sessionDir, 'logs', 'kimi-code.log'),
      maxBytes: config.sessionMaxBytes,
      files: config.sessionFiles,
    });
    const entry: SessionEntry = {
      logId: `session-log-${String(++nextSessionLogId)}`,
      sessionId: input.sessionId,
      sessionDir: input.sessionDir,
      sink,
      state: 'open',
      closePromise: undefined,
      refCount: 1,
    };
    this.sessions.set(entry.logId, entry);
    this.trackSessionId(entry);
    return makeHandle(entry);
  }

  async flush(): Promise<boolean> {
    const tasks: Promise<boolean>[] = [];
    if (this.globalSink !== undefined) tasks.push(this.globalSink.flush());
    for (const entry of this.sessions.values()) {
      tasks.push(this.flushEntry(entry));