Method executeSSESequence

jsonrpc/integration_tests/framework/executor.go:313–365

executeSSESequence handles SSE streaming sequences

(ctx context.Context, t *testing.T, scenario Scenario)

// executeSSESequence handles SSE streaming sequences
func (e *executor) executeSSESequence(ctx context.Context, t *testing.T, scenario Scenario) {
	t.Helper()

	// SSE only supports server-to-client streaming
	require.True(t, scenario.Request.Params != nil || scenario.Request.ID != nil, "SSE requires an initial request")

	client, err := harness.NewClient(e.serverURL, nil)
	require.NoError(t, err, "Failed to create client")

	// Send request and get SSE events
	method := scenario.Request.GetMethod(scenario.Method)
	req := harness.JSONRPCRequest{
		Method: method,
		Params: scenario.Request.Params,
		ID:     scenario.Request.ID,
	}
	// Handle JSONRPC field:
	// - Not specified (empty string) → Use default "2.0"
	// - "-" → Omit the field entirely
	// - Any other value → Use that value
	if scenario.Request.JSONRPC == "-" {
		// Special value to omit the field
		emptyStr := ""
		req.JSONRPC = &emptyStr
	} else if scenario.Request.JSONRPC != "" {
		// Custom value specified
		req.JSONRPC = &scenario.Request.JSONRPC
	}
	// If JSONRPC is empty string (not specified), req.JSONRPC remains nil and defaults to "2.0"
	events, err := client.CallSSE(ctx, req)
	require.NoError(t, err, "SSE request failed")

	// Validate sequence
	require.Len(t, events, len(scenario.Sequence), "Event count mismatch")

	for i, step := range scenario.Sequence {
		require.Equalf(t, "receive", step.Type, "SSE only supports 'receive' steps, got %s", step.Type)

		require.Lessf(t, i, len(events), "Expected event at step %d, but no more events", i)

		// Parse and validate the event
		var response map[string]any
		err := json.Unmarshal(events[i], &response)
		require.NoErrorf(t, err, "Failed to unmarshal event %d", i)

		// For SSE streaming, step.Expect contains the full expected JSON-RPC message
		expectedMsg, ok := step.Expect.(map[string]any)
		require.True(t, ok, "Step %d: invalid expect format", i)

		// Compare the messages
		e.compareJSONRPCMessages(t, response, expectedMsg)
	}
}

// executeBatch handles batch request scenarios
func (e *executor) executeBatch(t *testing.T, scenario Scenario) {