Merge pull request triggermesh#42 from triggermesh/content-type-fix

Content-type verification fix
sameersbn · Apr 21, 2022 · bf63bce · bf63bce
2 parents 4cb9a5f + dfe6f7e
commit bf63bce
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/pkg/converter/cloudevents/cloudevents.go b/pkg/converter/cloudevents/cloudevents.go
@@ -127,15 +127,16 @@ func (ce *CloudEvent) Request(request []byte, headers http.Header) ([]byte, map[
 	var body []byte
 	var err error
 
-	switch headers.Get("Content-Type") {
-	case "application/cloudevents+json":
+	contentType := headers.Get("Content-Type")
+
+	if strings.HasPrefix(contentType, "application/cloudevents+json") {
 		if body, context, err = parseStructuredCE(request); err != nil {
 			return nil, nil, fmt.Errorf("structured CloudEvent parse error: %w", err)
 		}
-	case "application/json":
+	} else if strings.HasPrefix(contentType, "application/json") {
 		body = request
 		context = parseBinaryCE(headers)
-	default:
+	} else {
 		return request, nil, nil
 	}