server_validate

type MockResponseBuilder ¶

type MockResponseBuilder struct {
	// NonStream returns the HTTP status code and response body bytes.
	NonStream func() (statusCode int, body []byte)
	// Stream returns the SSE event lines (each line is "data: ..." or "event: ...").
	Stream func() []string
}

MockResponseBuilder defines how a virtual server should respond for one response format.

type ParsedResponse ¶

type ParsedResponse struct {
	HTTPStatus   int
	IsStreaming  bool
	StreamEvents []string
	RawBody      []byte

	// Parsed semantics (populated from RawBody or StreamEvents)
	sse.ParsedResult
}

ParsedResponse is the result of a request sent to a virtual server. It wraps sse.ParsedResult with HTTP-layer fields.

type ResponseFormat ¶ added in v0.260430.1

type ResponseFormat string

ResponseFormat represents the format of the mock response for different endpoints.

const (
	FormatOpenAIChat      ResponseFormat = "openai_chat"      // /v1/chat/completions
	FormatOpenAIResponses ResponseFormat = "openai_responses" // /v1/responses
	FormatAnthropic       ResponseFormat = "anthropic"        // /v1/messages
	FormatGoogle          ResponseFormat = "google"           // /v1beta/models/.../generateContent
)

type Scenario ¶

type Scenario struct {
	Name        string
	Description string
	Tags        []string

	// MockResponses keyed by response format (openai_chat, openai_responses, anthropic, google).
	// Each endpoint (/v1/chat/completions, /v1/responses, /v1/messages, /v1beta/models/.../generateContent)
	// returns the corresponding format.
	MockResponses map[ResponseFormat]MockResponseBuilder
}

Scenario is a named test scenario describing what the mock provider returns.

Scenario also satisfies virtualmodel.VirtualModel via stub identity methods so that scenario storage can reuse virtualmodel.GenericRegistry, the same thread-safe registry primitive used by the production virtualmodel sub- packages. The byte-replay handlers in this file are intentionally NOT wired through virtualserver/handler.go — that handler operates on structured request/response shapes, while protocol_validate scenarios are pre-rendered byte / SSE-line payloads. Sharing the registry primitive is the cleanest reuse available without losing wire-format control.

func (s Scenario) GetDescription() string

func (s Scenario) GetID() string

func (s Scenario) GetName() string

func (s Scenario) GetType() virtualmodel.VirtualModelType

func (s Scenario) SimulatedDelay() time.Duration

func (s Scenario) ToModel() virtualmodel.Model

type VirtualClient ¶

type VirtualClient struct {
	// contains filtered or unexported fields
}

VirtualClient sends provider-native HTTP requests for testing. It can operate standalone (pointed at any URL) or bound to a VirtualServer (which auto-registers scenarios before each request).

func NewVirtualClient(baseURL string) *VirtualClient

func (vc *VirtualClient) SendAnthropicBetaModel(t *testing.T, modelID string, streaming bool) *ParsedResponse

func (vc *VirtualClient) SendAnthropicV1(t *testing.T, s Scenario, streaming bool) *ParsedResponse

func (vc *VirtualClient) SendAnthropicV1Model(t *testing.T, modelID string, streaming bool) *ParsedResponse

func (vc *VirtualClient) SendGoogle(t *testing.T, s Scenario, streaming bool) *ParsedResponse

func (vc *VirtualClient) SendOpenAIChat(t *testing.T, s Scenario, streaming bool) *ParsedResponse

func (vc *VirtualClient) SendOpenAIChatModel(t *testing.T, modelID string, streaming bool) *ParsedResponse

func (vc *VirtualClient) SendOpenAIResponses(t *testing.T, s Scenario, streaming bool) *ParsedResponse

func (vc *VirtualClient) WithServer(vs *VirtualServer) *VirtualClient

type VirtualServer ¶

type VirtualServer struct {
	// contains filtered or unexported fields
}

VirtualServer is a mock provider server backed by httptest.Server. It speaks OpenAI, Anthropic, and Google response formats and returns pre-configured scenario responses.

**Provider Routes**: This server handles provider-native routes (/v1/chat/completions, /v1/messages, /v1beta/models/...), NOT gateway routes (/tingly/{scenario}/v1/...). The gateway transforms requests to provider format before forwarding to this server.

func NewVirtualServer(t *testing.T) *VirtualServer

func NewVirtualServerForCLI() *VirtualServer

func (vs *VirtualServer) CallCount() int

func (vs *VirtualServer) Client() *VirtualClient

func (vs *VirtualServer) Close()

func (vs *VirtualServer) RegisterScenario(s Scenario)

func (vs *VirtualServer) URL() string