deepseek-harness/packages/session/session-format/src/context.ts

import type {
  SessionFormatEvent,
  SessionFormatEventRun,
  SessionFormatMigrationContext,
} from './types.ts'

/** Migration output context that expands compact runs into retained events. */
export class SessionFormatEventCollector implements SessionFormatMigrationContext {
  /** Events retained by this collector in source order. */
  readonly values: SessionFormatEvent[] = []

  /**
   * Retain one settled event.
   * @param event - settled event emitted by the upstream stage.
   */
  emitEvent(event: SessionFormatEvent): void {
    this.values.push(event)
  }

  /**
   * Expand one compact run directly into retained events.
   * @param run - compact event run emitted by the upstream stage.
   */
  emitRun(run: SessionFormatEventRun): void {
    for (const event of run.expand()) this.values.push(event)
  }
}