HTTP server NoOpRequestDecoder

transport/http/server.go

@@ -136,6 +136,12 @@ type ErrorEncoder func(ctx context.Context, err error, w http.ResponseWriter)
 // provided in the context under keys with the ContextKeyResponse prefix.
 type ServerFinalizerFunc func(ctx context.Context, code int, r *http.Request)
 
+// NopRequestDecoder is a DecodeRequestFunc that can be used for requests that do not
+// need to be decoded, and simply returns nil, nil.
+func NopRequestDecoder(ctx context.Context, r *http.Request) (interface{}, error) {
+	return nil, nil
+}
+
 // EncodeJSONResponse is a EncodeResponseFunc that serializes the response as a
 // JSON object to the ResponseWriter. Many JSON-over-HTTP services can use it as
 // a sensible default. If the response implements Headerer, the provided headers

transport/http/server_test.go

@@ -393,6 +393,28 @@ func TestEnhancedError(t *testing.T) {
 	}
 }
 
+func TestNoOpRequestDecoder(t *testing.T) {
+	resw := httptest.NewRecorder()
+	req, err := http.NewRequest(http.MethodGet, "/", nil)
+	if err != nil {
+		t.Error("Failed to create request")
+	}
+	handler := httptransport.NewServer(
+		func(ctx context.Context, request interface{}) (interface{}, error) {
+			if request != nil {
+				t.Error("Expected nil request in endpoint when using NopRequestDecoder")
+			}
+			return nil, nil
+		},
+		httptransport.NopRequestDecoder,
+		httptransport.EncodeJSONResponse,
+	)
+	handler.ServeHTTP(resw, req)
+	if resw.Code != http.StatusOK {
+		t.Errorf("Expected status code %d but got %d", http.StatusOK, resw.Code)
+	}
+}
+
 func testServer(t *testing.T) (step func(), resp <-chan *http.Response) {
 	var (
 		stepch   = make(chan bool)