Function TestNewRequestPayload

intercept/responses/reqpayload_test.go:19–78

(t *testing.T)

)

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

	payloadWithWrongTypes := []byte(`{"model":123,"stream":"yes","input":42,"background":"nope"}`)
	tests := []struct {
		name       string
		raw        []byte
		want       []byte
		model      string
		stream     bool
		background bool
		err        string
	}{
		{
			name: "empty payload",
			raw:  nil,
			want: nil,
			err:  "empty request body",
		},
		{
			name: "invalid json",
			raw:  []byte(`{broken`),
			want: nil,
			err:  "invalid JSON payload",
		},
		{
			// RequestPayload just checks for JSON validity,
			// schema errors are not surfaced here and
			// the original body is preserved for upstream handling
			// similar to how reverse proxy would behave.
			name:       "wrong field types still wrap",
			raw:        payloadWithWrongTypes,
			want:       payloadWithWrongTypes,
			model:      "123",
			stream:     false,
			background: false,
		},
	}

	for _, tc := range tests {
		t.Run(tc.name, func(t *testing.T) {
			t.Parallel()

			payload, err := NewRequestPayload(tc.raw)

			if tc.err != "" {
				require.ErrorContains(t, err, tc.err)
				assert.Nil(t, payload)
				return
			}

			require.NoError(t, err)
			require.NotNil(t, payload)
			assert.EqualValues(t, tc.want, payload)
			assert.Equal(t, tc.model, payload.model())
			assert.Equal(t, tc.stream, payload.Stream())
			assert.Equal(t, tc.background, payload.background())
		})