Function newBridgeTestServer

internal/integrationtest/setupbridge.go:133–193

newBridgeTestServer creates a fully configured test server running a RequestBridge with sensible defaults: - All standard providers (unless withProvider / withCustomProvider) - NoopMCPManager (unless withMCP) - slogtest debug logger - defaultTracer (unless withTracer) - defaultActorID (unless withAc

(
	ctx context.Context,
	t *testing.T,
	upstreamURL string,
	opts ...bridgeOption,
)

//   - defaultTracer (unless withTracer)
//   - defaultActorID (unless withActor)
func newBridgeTestServer(
	ctx context.Context,
	t *testing.T,
	upstreamURL string,
	opts ...bridgeOption,
) *bridgeTestServer {
	t.Helper()

	cfg := &bridgeConfig{
		userID: defaultActorID,
	}
	for _, o := range opts {
		o(cfg)
	}
	if cfg.tracer == nil {
		cfg.tracer = defaultTracer
	}
	cfg.logger = newLogger(t)
	if cfg.mcpProxy == nil {
		cfg.mcpProxy = newNoopMCPManager()
	}

	// Resolve providers: use explicit builders when provided, otherwise
	// create default providers for every supported type.
	var providers []aibridge.Provider
	if len(cfg.providerBuilders) > 0 {
		for _, b := range cfg.providerBuilders {
			providers = append(providers, b(upstreamURL))
		}
	} else {
		providers = []aibridge.Provider{
			newDefaultProvider(config.ProviderAnthropic, upstreamURL),
			newDefaultProvider(config.ProviderOpenAI, upstreamURL),
		}
	}

	mockRec := &testutil.MockRecorder{}
	rec := aibridge.NewRecorder(cfg.logger, cfg.tracer, func() (aibridge.Recorder, error) {
		return mockRec, nil
	})

	bridge, err := aibridge.NewRequestBridge(
		ctx, providers, rec, cfg.mcpProxy,
		cfg.logger, cfg.metrics, cfg.tracer,
	)
	require.NoError(t, err)

	actorID, md := cfg.userID, cfg.metadata
	srv := httptest.NewUnstartedServer(bridge)
	srv.Config.BaseContext = func(_ net.Listener) context.Context {
		return aibcontext.AsActor(ctx, actorID, md)
	}
	srv.Start()
	t.Cleanup(srv.Close)

	return &bridgeTestServer{
		Server:   srv,
		Recorder: mockRec,