mirror of
https://github.com/weaveworks/scope.git
synced 2026-02-14 18:09:59 +00:00
2ba50b8b3d
```
$ gvt delete golang.org/x/net/context
$ gvt fetch golang.org/x/net/context
2018/07/23 18:03:49 Fetching: golang.org/x/net/context
$ git grep -l "golang.org/x/net/context" | grep -v vendor | xargs sed -i '' 's:golang.org/x/net/context:context:g'
$ git grep -l "context/ctxhttp" | grep -v vendor | xargs sed -i '' 's:context/ctxhttp:golang.org/x/net/context/ctxhttp:g'
$ gofmt -s -w app
$ gofmt -s -w common
$ gofmt -s -w probe
$ gofmt -s -w prog
$ gofmt -s -w tools
```
fixed a bunch of:
```
cannot use func literal (type func("github.com/weaveworks/scope/vendor/golang.org/x/net/context".Context) error) as type func("context".Context) error
```
97 lines
2.5 KiB
Go
97 lines
2.5 KiB
Go
package app_test
|
|
|
|
import (
|
|
"bytes"
|
|
"io/ioutil"
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"reflect"
|
|
"testing"
|
|
"time"
|
|
|
|
"context"
|
|
"github.com/gorilla/mux"
|
|
"github.com/ugorji/go/codec"
|
|
|
|
"github.com/weaveworks/common/test"
|
|
"github.com/weaveworks/scope/app"
|
|
"github.com/weaveworks/scope/test/fixture"
|
|
)
|
|
|
|
type v map[string]string
|
|
|
|
func TestURLMatcher(t *testing.T) {
|
|
test := func(pattern, path string, match bool, vars v) {
|
|
routeMatch := &mux.RouteMatch{}
|
|
if app.URLMatcher(pattern)(&http.Request{RequestURI: path}, routeMatch) != match {
|
|
t.Fatalf("'%s' '%s'", pattern, path)
|
|
}
|
|
if match && !reflect.DeepEqual(v(routeMatch.Vars), vars) {
|
|
t.Fatalf("%v != %v", v(routeMatch.Vars), vars)
|
|
}
|
|
}
|
|
|
|
test("/a/b/c", "/a/b/c", true, v{})
|
|
test("/a/b/c", "/c/b/a", false, v{})
|
|
test("/{a}/b/c", "/b/b/c", true, v{"a": "b"})
|
|
test("/{a}/b/c", "/b/b/b", false, v{})
|
|
test("/a/b/{c}", "/a/b/b", true, v{"c": "b"})
|
|
test("/a/b/{c}", "/a/b/b%2Fb", true, v{"c": "b/b"})
|
|
}
|
|
|
|
func TestReportPostHandler(t *testing.T) {
|
|
test := func(contentType string, encoder func(interface{}) ([]byte, error)) {
|
|
router := mux.NewRouter()
|
|
c := app.NewCollector(1 * time.Minute)
|
|
app.RegisterReportPostHandler(c, router)
|
|
ts := httptest.NewServer(router)
|
|
defer ts.Close()
|
|
|
|
b, err := encoder(fixture.Report)
|
|
if err != nil {
|
|
t.Fatalf("Content-Type %s: %s", contentType, err)
|
|
}
|
|
|
|
req, err := http.NewRequest("POST", ts.URL+"/api/report", bytes.NewReader(b))
|
|
if err != nil {
|
|
t.Fatalf("Error posting report: %v", err)
|
|
}
|
|
req.Header.Set("Content-Type", contentType)
|
|
|
|
resp, err := http.DefaultClient.Do(req)
|
|
if err != nil {
|
|
t.Fatalf("Error posting report %v", err)
|
|
}
|
|
|
|
_, err = ioutil.ReadAll(resp.Body)
|
|
resp.Body.Close()
|
|
if err != nil {
|
|
t.Fatalf("Error posting report: %v", err)
|
|
}
|
|
|
|
if resp.StatusCode != http.StatusOK {
|
|
t.Fatalf("Error posting report: %d", resp.StatusCode)
|
|
}
|
|
|
|
ctx := context.Background()
|
|
report, err := c.Report(ctx, time.Now())
|
|
if err != nil {
|
|
t.Error(err)
|
|
}
|
|
if want, have := fixture.Report.Endpoint.Nodes, report.Endpoint.Nodes; len(have) == 0 || len(want) != len(have) {
|
|
t.Fatalf("Content-Type %s: %v", contentType, test.Diff(have, want))
|
|
}
|
|
}
|
|
|
|
test("application/json", func(v interface{}) ([]byte, error) {
|
|
buf := &bytes.Buffer{}
|
|
err := codec.NewEncoder(buf, &codec.JsonHandle{}).Encode(v)
|
|
return buf.Bytes(), err
|
|
})
|
|
test("application/msgpack", func(v interface{}) ([]byte, error) {
|
|
buf := &bytes.Buffer{}
|
|
err := codec.NewEncoder(buf, &codec.MsgpackHandle{}).Encode(v)
|
|
return buf.Bytes(), err
|
|
})
|
|
}
|