Function assertStreamSuccess

tests/ipc/streamCollector.ts:496–536

(collector: StreamCollector)

 * Provides helpful error messages when assertions fail.
 */
export function assertStreamSuccess(collector: StreamCollector): void {
  const allEvents = collector.getEvents();

  // Check for stream-end
  if (!collector.hasStreamEnd()) {
    const errorEvent = allEvents.find((e) => "type" in e && e.type === "stream-error");
    if (errorEvent && "error" in errorEvent) {
      collector.logEventDiagnostics(
        `Stream did not complete successfully. Got stream-error: ${errorEvent.error}`
      );
      throw new Error(
        `Stream did not complete successfully. Got stream-error: ${errorEvent.error}\n` +
          `See detailed event diagnostics above.`
      );
    }
    collector.logEventDiagnostics("Stream did not emit stream-end event");
    throw new Error(
      `Stream did not emit stream-end event.\n` + `See detailed event diagnostics above.`
    );
  }

  // Check for errors
  if (collector.hasError()) {
    const errorEvent = allEvents.find((e) => "type" in e && e.type === "stream-error");
    const errorMsg = errorEvent && "error" in errorEvent ? errorEvent.error : "unknown";
    collector.logEventDiagnostics(`Stream completed but also has error event: ${errorMsg}`);
    throw new Error(
      `Stream completed but also has error event: ${errorMsg}\n` +
        `See detailed event diagnostics above.`
    );
  }

  // Check for final message
  const finalMessage = collector.getFinalMessage();
  if (!finalMessage) {
    collector.logEventDiagnostics("Stream completed but final message is missing");
    throw new Error(
      `Stream completed but final message is missing.\n` + `See detailed event diagnostics above.`
    );
  }
}

/**
 * RAII-style helper that starts a collector, runs a function, and stops the collector.