Function TestReadPayload

lambda/invoke_loop_test.go:280–296

(t *testing.T)

}

func TestReadPayload(t *testing.T) {
	ts, record := runtimeAPIServer(`{"message": "I am craving tacos"}`, 1)
	defer ts.Close()

	handler := NewHandler(func(event struct{ Message string }) (string, error) {
		length := utf8.RuneCountInString(event.Message)
		reversed := make([]rune, length)
		for i, v := range event.Message {
			reversed[length-i-1] = v
		}
		return string(reversed), nil
	})
	endpoint := strings.Split(ts.URL, "://")[1]
	_ = startRuntimeAPILoop(endpoint, handler)
	assert.Equal(t, `"socat gnivarc ma I"`, string(record.responses[0]))
	assert.Equal(t, contentTypeJSON, record.contentTypes[0])
}

type readCloser struct {
	closed bool