[query] Fix /m3query returning 500 on invalid query argument

src/cmd/tools/dtest/docker/harness/query_api_test.go

@@ -38,12 +38,14 @@ type urlTest struct {
 func TestInvalidInstantQueryReturns400(t *testing.T) {
 	coord := singleDBNodeDockerResources.Coordinator()
 
-	instantQueryBadRequestTest := []urlTest{
+	urlPrefix := []string{"", "prometheus/", "m3query/"}
+
+	instantQueryBadRequestTest := addPrefixes(urlPrefix, []urlTest{
 		{"missing query", queryURL("query", "")},
 		{"invalid query", queryURL("query", "@!")},
 		{"invalid time", queryURL("time", "INVALID")},
 		{"invalid timeout", queryURL("timeout", "INVALID")},
-	}
+	})
 
 	for _, tt := range instantQueryBadRequestTest {
 		t.Run(tt.name, func(t *testing.T) {
@@ -55,7 +57,9 @@ func TestInvalidInstantQueryReturns400(t *testing.T) {
 func TestInvalidRangeQueryReturns400(t *testing.T) {
 	coord := singleDBNodeDockerResources.Coordinator()
 
-	queryBadRequestTest := []urlTest{
+	urlPrefix := []string{"", "prometheus/", "m3query/"}
+
+	queryBadRequestTest := addPrefixes(urlPrefix, []urlTest{
 		{"missing query", queryRangeURL("query", "")},
 		{"invalid query", queryRangeURL("query", "@!")},
 		{"missing start", queryRangeURL("start", "")},
@@ -65,7 +69,7 @@ func TestInvalidRangeQueryReturns400(t *testing.T) {
 		{"missing step", queryRangeURL("step", "")},
 		{"invalid step", queryRangeURL("step", "INVALID")},
 		{"invalid timeout", queryRangeURL("timeout", "INVALID")},
-	}
+	})
 
 	for _, tt := range queryBadRequestTest {
 		t.Run(tt.name, func(t *testing.T) {
@@ -74,6 +78,19 @@ func TestInvalidRangeQueryReturns400(t *testing.T) {
 	}
 }
 
+func addPrefixes(prefixes []string, tests []urlTest) []urlTest {
+	res := make([]urlTest, 0)
+	for _, prefix := range prefixes {
+		for _, t := range tests {
+			res = append(res, urlTest{
+				fmt.Sprintf("%v %v", prefix, t.name),
+				fmt.Sprintf("%v%v", prefix, t.url),
+			})
+		}
+	}
+	return res
+}
+
 func queryURL(key, value string) string {
 	params := map[string]string{
 		"query": "foo",

src/query/api/v1/handler/prometheus/native/read_common.go

@@ -176,7 +176,7 @@ func read(
 	parseOpts := engine.Options().ParseOptions()
 	parser, err := promql.Parse(params.Query, params.Step, tagOpts, parseOpts)
 	if err != nil {
-		return emptyResult, err
+		return emptyResult, xerrors.NewInvalidParamsError(err)
 	}
 
 	// Detect clients closing connections.