Error string validate json conversion

runtime/router/router.go

@@ -21,8 +21,11 @@
 package router
 
 import (
+	"bytes"
 	"context"
+	"encoding/json"
 	"fmt"
+	"io/ioutil"
 	"net/http"
 	"sort"
 	"strings"
@@ -130,6 +133,23 @@ func (r *Router) ServeHTTP(w http.ResponseWriter, req *http.Request) {
 		if handler, params, err := trie.Get(reqPath, isWhitelisted); err == nil {
 			ctx := context.WithValue(req.Context(), urlParamsKey, params)
 			req = req.WithContext(ctx)
+			body, err := ioutil.ReadAll(req.Body)
+			if err != nil {
+				http.Error(w, "Failed to read request body", http.StatusInternalServerError)
+				return
+			}
+			reqSize := len(body)
+			if reqSize == 0 {
+				http.Error(w, "Failed to parse JSON data", http.StatusBadRequest)
+				return
+			}
+			var buf bytes.Buffer
+			if err := json.Compact(&buf, body); err != nil {
+				http.Error(w, "Failed to parse JSON data", http.StatusBadRequest)
+				return
+			}
+			//Reset back into req body.
+			req.Body = ioutil.NopCloser(bytes.NewReader(buf.Bytes()))
 			handler.ServeHTTP(w, req)
 			return
 		}

runtime/server_http_response.go

@@ -36,6 +36,11 @@ import (
 	"go.uber.org/zap/zapcore"
 )
 
+const (
+	// _errTmpl is Error Template
+	_errTmpl = `{"error":%s}`
+)
+
 // ServerHTTPResponse struct manages server http response
 type ServerHTTPResponse struct {
 	Request              *ServerHTTPRequest
@@ -169,7 +174,7 @@ func (res *ServerHTTPResponse) SendErrorString(
 	statusCode int, errMsg string,
 ) {
 	res.WriteJSONBytes(statusCode, nil,
-		[]byte(`{"error":"`+errMsg+`"}`),
+		[]byte(populateJSONTemplate(_errTmpl, errMsg)),
 	)
 }
 
@@ -179,7 +184,7 @@ func (res *ServerHTTPResponse) SendError(
 ) {
 	res.Err = errCause
 	res.WriteJSONBytes(statusCode, nil,
-		[]byte(`{"error":"`+errMsg+`"}`),
+		[]byte(populateJSONTemplate(_errTmpl, errMsg)),
 	)
 }
 
@@ -337,3 +342,7 @@ func (res *ServerHTTPResponse) GetPendingResponseObject() interface{} {
 func (res *ServerHTTPResponse) Headers() http.Header {
 	return res.responseWriter.Header()
 }
+
+func populateJSONTemplate(template, msg string) string {
+	return fmt.Sprintf(template, strconv.Quote(msg))
+}