Skip to content

Commit

Permalink
PR comments
Browse files Browse the repository at this point in the history
  • Loading branch information
vpranckaitis committed Nov 18, 2020
1 parent 15984a6 commit 661c9ae
Showing 1 changed file with 12 additions and 14 deletions.
26 changes: 12 additions & 14 deletions src/cmd/tools/dtest/docker/harness/query_api_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,30 +36,22 @@ type urlTest struct {
}

func TestInvalidInstantQueryReturns400(t *testing.T) {
coord := singleDBNodeDockerResources.Coordinator()

urlPrefix := []string{"", "prometheus/", "m3query/"}
urlPrefixes := []string{"", "prometheus/", "m3query/"}

instantQueryBadRequestTest := addPrefixes(urlPrefix, []urlTest{
urlTests := addPrefixes(urlPrefixes, []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) {
assert.NoError(t, coord.RunQuery(verifyStatus(400), tt.url), "for query '%v'", tt.url)
})
}
testInvalidQueryReturns400(t, urlTests)
}

func TestInvalidRangeQueryReturns400(t *testing.T) {
coord := singleDBNodeDockerResources.Coordinator()

urlPrefix := []string{"", "prometheus/", "m3query/"}
urlPrefixes := []string{"", "prometheus/", "m3query/"}

queryBadRequestTest := addPrefixes(urlPrefix, []urlTest{
urlTests := addPrefixes(urlPrefixes, []urlTest{
{"missing query", queryRangeURL("query", "")},
{"invalid query", queryRangeURL("query", "@!")},
{"missing start", queryRangeURL("start", "")},
Expand All @@ -71,7 +63,13 @@ func TestInvalidRangeQueryReturns400(t *testing.T) {
{"invalid timeout", queryRangeURL("timeout", "INVALID")},
})

for _, tt := range queryBadRequestTest {
testInvalidQueryReturns400(t, urlTests)
}

func testInvalidQueryReturns400(t *testing.T, tests []urlTest) {
coord := singleDBNodeDockerResources.Coordinator()

for _, tt := range tests {
t.Run(tt.name, func(t *testing.T) {
assert.NoError(t, coord.RunQuery(verifyStatus(400), tt.url), "for query '%v'", tt.url)
})
Expand Down

0 comments on commit 661c9ae

Please sign in to comment.