2015-09-16 17:42:17 +00:00
|
|
|
package main
|
|
|
|
|
|
|
|
import (
|
|
|
|
"net/http"
|
|
|
|
"net/http/httptest"
|
|
|
|
"regexp"
|
|
|
|
"strings"
|
|
|
|
"sync"
|
|
|
|
|
|
|
|
"github.com/go-check/check"
|
|
|
|
)
|
|
|
|
|
|
|
|
type handlerFunc func(w http.ResponseWriter, r *http.Request)
|
|
|
|
|
|
|
|
type testRegistry struct {
|
|
|
|
server *httptest.Server
|
|
|
|
hostport string
|
|
|
|
handlers map[string]handlerFunc
|
|
|
|
mu sync.Mutex
|
|
|
|
}
|
|
|
|
|
|
|
|
func (tr *testRegistry) registerHandler(path string, h handlerFunc) {
|
|
|
|
tr.mu.Lock()
|
|
|
|
defer tr.mu.Unlock()
|
|
|
|
tr.handlers[path] = h
|
|
|
|
}
|
|
|
|
|
|
|
|
func newTestRegistry(c *check.C) (*testRegistry, error) {
|
|
|
|
testReg := &testRegistry{handlers: make(map[string]handlerFunc)}
|
|
|
|
|
|
|
|
ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
|
|
|
url := r.URL.String()
|
|
|
|
|
|
|
|
var matched bool
|
|
|
|
var err error
|
|
|
|
for re, function := range testReg.handlers {
|
|
|
|
matched, err = regexp.MatchString(re, url)
|
|
|
|
if err != nil {
|
2016-01-09 10:44:15 +00:00
|
|
|
c.Fatal("Error with handler regexp")
|
2015-09-16 17:42:17 +00:00
|
|
|
}
|
|
|
|
if matched {
|
|
|
|
function(w, r)
|
|
|
|
break
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if !matched {
|
2016-01-09 10:44:15 +00:00
|
|
|
c.Fatalf("Unable to match %s with regexp", url)
|
2015-09-16 17:42:17 +00:00
|
|
|
}
|
|
|
|
}))
|
|
|
|
|
|
|
|
testReg.server = ts
|
|
|
|
testReg.hostport = strings.Replace(ts.URL, "http://", "", 1)
|
|
|
|
return testReg, nil
|
|
|
|
}
|