Method executeWebSocket

jsonrpc/integration_tests/framework/executor.go:173–199

executeWebSocket handles WebSocket transport scenarios

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

// executeWebSocket handles WebSocket transport scenarios
func (e *executor) executeWebSocket(ctx context.Context, t *testing.T, scenario Scenario) {
	t.Helper()

	// WebSocket scenarios always use sequence
	if len(scenario.Sequence) > 0 {
		e.executeWebSocketSequence(ctx, t, scenario)
		return
	}

	// If no sequence, create a simple send/receive sequence from request/expect
	if scenario.Request.Params != nil {
		// Pass method, params, and id as separate fields
		data := map[string]any{
			"method": scenario.Method,
			"params": scenario.Request.Params,
		}
		if scenario.Request.ID != nil {
			data["id"] = scenario.Request.ID
		}

		scenario.Sequence = []Action{
			{Type: "send", Data: data},
			{Type: "receive", Expect: scenario.Expect},
		}
		e.executeWebSocketSequence(ctx, t, scenario)
	}
}

// executeSSE handles Server-Sent Events scenarios
func (e *executor) executeSSE(_ context.Context, t *testing.T, _ Scenario) {