Use Content-Type application/cloudevents+json for http provider (#415)

* Use Content-Type application/cloudevents+json for http provider * gofmt
serverless · Apr 27, 2018 · 5bf5be8 · 5bf5be8
1 parent e75ed0c
commit 5bf5be8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/providers/http/http.go b/providers/http/http.go
@@ -32,7 +32,7 @@ func (h HTTP) Call(payload []byte) ([]byte, error) {
 		Timeout: time.Second * 5,
 	}
 
-	resp, err := client.Post(h.URL, "application/json", bytes.NewReader(payload))
+	resp, err := client.Post(h.URL, "application/cloudevents+json", bytes.NewReader(payload))
 	if err != nil {
 		return nil, &function.ErrFunctionCallFailed{Original: err}
 	}

diff --git a/providers/http/http_test.go b/providers/http/http_test.go
@@ -22,7 +22,9 @@ func TestLoad(t *testing.T) {
 }
 
 func TestCall(t *testing.T) {
+	var contentType string
 	echo := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		contentType = r.Header.Get("Content-Type")
 		payload, _ := ioutil.ReadAll(r.Body)
 		defer r.Body.Close()
 		fmt.Fprint(w, string(payload))
@@ -34,6 +36,7 @@ func TestCall(t *testing.T) {
 	resp, err := provider.Call([]byte("hello"))
 
 	assert.Nil(t, err)
+	assert.Equal(t, "application/cloudevents+json", contentType)
 	assert.Equal(t, "hello", string(resp))
 }