Function newFixtureResponse

aibridge/internal/integrationtest/mockupstream.go:43–52

newFixtureResponse creates an upstreamResponse from a parsed fixture archive. It reads whichever of 'streaming' and 'non-streaming' sections exist; not every fixture has both (e.g. error fixtures may only define one).

(fix fixtures.Fixture)

// It reads whichever of 'streaming' and 'non-streaming' sections exist;
// not every fixture has both (e.g. error fixtures may only define one).
func newFixtureResponse(fix fixtures.Fixture) upstreamResponse {
	var resp upstreamResponse
	if fix.Has(fixtures.SectionStreaming) {
		resp.Streaming = fix.Streaming()
	}
	if fix.Has(fixtures.SectionNonStreaming) {
		resp.Blocking = fix.NonStreaming()
	}
	return resp
}

// newFixtureToolResponse creates an upstreamResponse from the tool-call fixture files.
// It reads whichever of 'streaming/tool-call' and 'non-streaming/tool-call'