Function entryToFixture

src/fixture-loader.ts:71–120

(entry: FixtureFileEntry, logger?: Logger)

}

export function entryToFixture(entry: FixtureFileEntry, logger?: Logger): Fixture {
  const fixture: Fixture = {
    match: {
      userMessage: entry.match.userMessage,
      systemMessage: entry.match.systemMessage,
      inputText: entry.match.inputText,
      toolCallId: entry.match.toolCallId,
      toolName: entry.match.toolName,
      model: entry.match.model,
      responseFormat: entry.match.responseFormat,
      endpoint: entry.match.endpoint,
      ...(entry.match.sequenceIndex !== undefined && { sequenceIndex: entry.match.sequenceIndex }),
      ...(entry.match.turnIndex !== undefined && {
        turnIndex: entry.match.turnIndex,
      }),
      ...(entry.match.hasToolResult !== undefined && {
        hasToolResult: entry.match.hasToolResult,
      }),
      ...(entry.match.context !== undefined && { context: entry.match.context }),
    },
    response: normalizeResponse(entry.response),
    ...(entry.latency !== undefined && { latency: entry.latency }),
    ...(entry.chunkSize !== undefined && { chunkSize: entry.chunkSize }),
    ...(entry.truncateAfterChunks !== undefined && {
      truncateAfterChunks: entry.truncateAfterChunks,
    }),
    ...(entry.disconnectAfterMs !== undefined && { disconnectAfterMs: entry.disconnectAfterMs }),
    ...(entry.streamingProfile !== undefined && { streamingProfile: entry.streamingProfile }),
    ...(entry.recordedTimings !== undefined && { recordedTimings: entry.recordedTimings }),
    ...(entry.replaySpeed != null && { replaySpeed: entry.replaySpeed }),
    ...(entry.chaos !== undefined && { chaos: entry.chaos }),
    ...(entry.metadata !== undefined && { metadata: entry.metadata }),
  };

  // Sanitize recordedTimings to guard against NaN or negative values that
  // would silently degrade replay timing calculations.
  if (fixture.recordedTimings) {
    const rt = fixture.recordedTimings;
    if (!Number.isFinite(rt.ttftMs) || rt.ttftMs < 0) rt.ttftMs = 0;
    rt.interChunkDelaysMs = rt.interChunkDelaysMs.filter((d) => Number.isFinite(d) && d >= 0);
    if (!Number.isFinite(rt.totalDurationMs) || rt.totalDurationMs < 0) rt.totalDurationMs = 0;
  }

  if (fixture.replaySpeed != null && fixture.replaySpeed <= 0) {
    logger?.warn(`Fixture replaySpeed must be positive, got ${fixture.replaySpeed}. Ignoring.`);
    delete fixture.replaySpeed;
  }

  return fixture;
}

// Logging helper — uses logger if provided, falls back to console.warn.
function warn(logger: Logger | undefined, msg: string, ...rest: unknown[]): void {