import type { ReportItemWithContext } from '../types';
import { Transport, TransportOptions } from '../Transport';

interface ConsoleTransportOptions extends TransportOptions<any> {
  /** log 前缀
   * @default '[Merlin Log]'
   */
  prefix?: string;
  /** 格式化详情 */
  parser?: (record: ReportItemWithContext<Record<string, any>>) => any;
  /** 输出使用的 Console 方法
   * @default 'log'
   */
  method?: 'log' | 'info';
}

export class ConsoleTransport extends Transport<any, any> {
  private prefix = '[Merlin Log]';
  private parser: ((record: ReportItemWithContext<Record<string, any>>) => any) | null = null;
  private method: 'log' | 'info' = 'log';

  constructor(options?: ConsoleTransportOptions) {
    super({
      // 默认立刻输出
      flushInterval: 0,
      bufferSize: 0,
      ...options,
    });
    if (options?.prefix) {
      this.prefix = options.prefix;
    }
    if (options?.parser) {
      this.parser = options.parser;
    }
    if (options?.method) {
      this.method = options.method;
    }
  }

  print(...args: Parameters<typeof console.log>) {
    if (this.method === 'info') {
      console.info(...args);
    } else {
      console.log(...args);
    }
  }

  send(records: ReportItemWithContext<Record<string, any>>[]) {
    records.forEach((record) => {
      if (this.parser) {
        this.print(`${this.prefix}[${record.type}]${new Date(record.ctime).toLocaleString()}`, this.parser(record));
      } else {
        this.print(
          `${this.prefix}[${record.type}]${new Date(record.ctime).toLocaleString()}`,
          record.context,
          record.data,
        );
      }
    });
  }
}