Class LoggerContextImpl

observability/mastra/src/context/logger.ts:42–110

};

export class LoggerContextImpl implements LoggerContext {
  private config: LoggerContextConfig;

  /**
   * Create a logger context. Context and metadata are defensively copied so
   * mutations after construction do not affect emitted logs.
   */
  constructor(config: LoggerContextConfig) {
    const correlationContext = config.correlationContext ? { ...config.correlationContext } : undefined;

    this.config = {
      ...config,
      traceId: config.traceId ?? correlationContext?.traceId,
      spanId: config.spanId ?? correlationContext?.spanId,
      correlationContext,
      metadata: config.metadata ? structuredClone(config.metadata) : undefined,
    };
  }

  /** Log at DEBUG level. */
  debug(message: string, data?: Record<string, unknown>): void {
    this.log('debug', message, data);
  }

  /** Log at INFO level. */
  info(message: string, data?: Record<string, unknown>): void {
    this.log('info', message, data);
  }

  /** Log at WARN level. */
  warn(message: string, data?: Record<string, unknown>): void {
    this.log('warn', message, data);
  }

  /** Log at ERROR level. */
  error(message: string, data?: Record<string, unknown>): void {
    this.log('error', message, data);
  }

  /** Log at FATAL level. */
  fatal(message: string, data?: Record<string, unknown>): void {
    this.log('fatal', message, data);
  }

  /**
   * Build an ExportedLog, check against the minimum level, and emit it through the bus.
   */
  private log(level: LogLevel, message: string, data?: Record<string, unknown>): void {
    const minLevel = this.config.minLevel ?? 'warn';
    if (LOG_LEVEL_PRIORITY[level] < LOG_LEVEL_PRIORITY[minLevel]) {
      return;
    }

    const exportedLog: ExportedLog = {
      logId: generateSignalId(),
      timestamp: new Date(),
      level,
      message,