Function createErrorAggregator

packages/core/src/debug/errorAggregator.ts:138–270

()

 * Create an error aggregator instance.
 */
export function createErrorAggregator(): ErrorAggregator {
  const errors: Map<string, MutableError> = new Map();
  const errorOrder: string[] = [];
  const handlers: Set<ErrorHandler> = new Set();
  let totalOccurrences = 0;

  function notifyHandlers(error: AggregatedError): void {
    for (const handler of handlers) {
      try {
        handler(error);
      } catch {
        // Ignore handler errors
      }
    }
  }

  function toImmutable(error: MutableError): AggregatedError {
    return {
      id: error.id,
      category: error.category,
      severity: error.severity,
      code: error.code,
      message: error.message,
      sourceFile: error.sourceFile,
      sourceLine: error.sourceLine,
      firstOccurrence: error.firstOccurrence,
      lastOccurrence: error.lastOccurrence,
      count: error.count,
      frameIds: [...error.frameIds],
    };
  }

  function addError(
    record: ErrorRecord,
    category: DebugCategory,
    severity: DebugSeverity,
    timestampUs: bigint,
  ): void {
    const timestamp = Number(timestampUs) / 1000;
    const sourceFile = record.sourceFile || undefined;
    const id = createErrorId(record.errorCode, record.message, sourceFile);

    totalOccurrences++;

    const existing = errors.get(id);
    if (existing) {
      // Update existing error
      existing.lastOccurrence = timestamp;
      existing.count++;
      if (existing.frameIds.length < MAX_FRAME_IDS_PER_ERROR) {
        // Only add if not already present
        if (!existing.frameIds.includes(record.frameId)) {
          existing.frameIds.push(record.frameId);
        }
      }
      notifyHandlers(toImmutable(existing));
    } else {
      // Create new error