Function TestTracePassthrough

internal/integrationtest/trace_test.go:752–782

(t *testing.T)

}

func TestTracePassthrough(t *testing.T) {
	t.Parallel()

	fix := fixtures.Parse(t, fixtures.OaiChatFallthrough)

	upstream := newMockUpstream(t.Context(), t, newFixtureResponse(fix))

	sr, tracer := setupTracer(t)

	bridgeServer := newBridgeTestServer(t.Context(), t, upstream.URL,
		withTracer(tracer),
	)

	resp, err := bridgeServer.makeRequest(t, http.MethodGet, "/openai/v1/models", nil)
	require.NoError(t, err)
	defer resp.Body.Close()
	require.Equal(t, http.StatusOK, resp.StatusCode)
	bridgeServer.Close()

	spans := sr.Ended()
	require.Len(t, spans, 1)

	assert.Equal(t, spans[0].Name(), "Passthrough")
	want := []attribute.KeyValue{
		attribute.String(tracing.PassthroughMethod, "GET"),
		attribute.String(tracing.PassthroughUpstreamURL, upstream.URL+"/models"),
		attribute.String(tracing.PassthroughURL, "/models"),
	}
	got := slices.SortedFunc(slices.Values(spans[0].Attributes()), cmpAttrKeyVal)
	require.Equal(t, want, got)
}

func TestNewServerProxyManagerTraces(t *testing.T) {
	t.Parallel()