Function setupInjectedToolTest

aibridge/internal/integrationtest/setupbridge.go:200–250

setupInjectedToolTest abstracts common setup required for injected-tool integration tests. Extra bridge options (e.g. [withProvider]) are appended after the built-in MCP / tracer / actor options. When no provider option is given the default provider set (all providers) is used.

(
	t *testing.T,
	fixture []byte,
	streaming bool,
	tracer trace.Tracer,
	path string,
	toolRequestValidatorFn func(*http.Request, []byte),
	opts ...bridgeOption,
)

// MCP / tracer / actor options. When no provider option is given the default
// provider set (all providers) is used.
func setupInjectedToolTest(
	t *testing.T,
	fixture []byte,
	streaming bool,
	tracer trace.Tracer,
	path string,
	toolRequestValidatorFn func(*http.Request, []byte),
	opts ...bridgeOption,
) (*bridgeTestServer, *mockMCP, *http.Response) {
	t.Helper()

	ctx, cancel := context.WithTimeout(t.Context(), testutil.WaitLong)
	t.Cleanup(cancel)

	fix := fixtures.Parse(t, fixture)

	// Setup mock server for multi-turn interaction.
	// First request → tool call response
	// Second request → final response.
	firstResp := newFixtureResponse(fix)
	toolResp := newFixtureToolResponse(fix)
	toolResp.OnRequest = toolRequestValidatorFn
	upstream := newMockUpstream(ctx, t, firstResp, toolResp)

	mockMCP := setupMCPForTest(t, tracer)

	allOpts := []bridgeOption{
		withMCP(mockMCP),
		withTracer(tracer),
		withActor(defaultActorID, nil),
	}
	allOpts = append(allOpts, opts...)
	bridgeServer := newBridgeTestServer(ctx, t, upstream.URL, allOpts...)

	// Add the stream param to the request.
	reqBody, err := sjson.SetBytes(fix.Request(), "stream", streaming)
	require.NoError(t, err)

	resp, err := bridgeServer.makeRequest(t, http.MethodPost, path, reqBody)
	require.NoError(t, err)
	require.Equal(t, http.StatusOK, resp.StatusCode)

	// Drain the body so the bridge handler returns and asyncRecorder.Wait()
	// flushes pending recordings (see aibridge/bridge.go:newInterceptionProcessor).
	body, err := io.ReadAll(resp.Body)
	require.NoError(t, err)
	_ = resp.Body.Close()
	resp.Body = io.NopCloser(bytes.NewReader(body))

	return bridgeServer, mockMCP, resp
}

// newDefaultProvider creates a Provider with default test configuration.
func newDefaultProvider(providerType string, addr string) aibridge.Provider {