Function TestSimulateHTTP_SSEStreamMismatch_317

pkg/util_test.go:322–399

(t *testing.T)

}

func TestSimulateHTTP_SSEStreamMismatch_317(t *testing.T) {
	ctx := context.Background()
	logger := zap.NewNop()

	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, _ *http.Request) {
		w.Header().Set("Content-Type", "text/event-stream")
		flusher, ok := w.(http.Flusher)
		require.True(t, ok, "server response writer must support flushing")

		_, _ = w.Write([]byte("id:1\nevent:update\ndata:{\"value\":1}\n\n"))
		flusher.Flush()
		_, _ = w.Write([]byte("id:2\nevent:update\ndata:{\"value\":999}\n\n"))
		flusher.Flush()
	}))
	defer server.Close()

	tc := &models.TestCase{
		Name: "sse-mismatch",
		HTTPReq: models.HTTPReq{
			Method: "GET",
			URL:    server.URL,
			Header: map[string]string{
				"Accept": "text/event-stream",
			},
		},
		HTTPResp: models.HTTPResp{
			Header: map[string]string{
				"Content-Type": "text/event-stream",
			},
			Body: strings.Join([]string{
				"id:1",
				"event:update",
				"data:{\"value\":1}",
				"",
				"id:2",
				"event:update",
				"data:{\"value\":2}",
				"",
			}, "\n"),
			StreamBody: []models.HTTPStreamChunk{
				{
					Data: []models.HTTPStreamDataField{
						{Key: "id", Value: "1"},
						{Key: "event", Value: "update"},
						{Key: "data", Value: `{"value":1}`},
					},
				},
				{
					Data: []models.HTTPStreamDataField{
						{Key: "id", Value: "2"},
						{Key: "event", Value: "update"},
						{Key: "data", Value: `{"value":2}`},
					},
				},
			},
		},
	}