128 lines
3.0 KiB
Go
128 lines
3.0 KiB
Go
package handler_test
|
|
|
|
import (
|
|
"fmt"
|
|
"io"
|
|
"io/ioutil"
|
|
"net/http"
|
|
"net/http/httptest"
|
|
"reflect"
|
|
"testing"
|
|
|
|
"github.com/golang/mock/gomock"
|
|
"github.com/tus/tusd/pkg/handler"
|
|
)
|
|
|
|
//go:generate mockgen -package handler_test -source utils_test.go -aux_files handler=datastore.go -destination=handler_mock_test.go
|
|
|
|
// FullDataStore is an interface combining most interfaces for data stores.
|
|
// This is used by mockgen(1) to generate a mocked data store used for testing
|
|
// (see https://github.com/golang/mock). The only interface excluded is
|
|
// LockerDataStore because else we would have to explicitly expect calls for
|
|
// locking in every single test which would result in more verbose code.
|
|
// Therefore it has been moved into its own type definition, the Locker.
|
|
type FullDataStore interface {
|
|
handler.DataStore
|
|
handler.TerminaterDataStore
|
|
handler.ConcaterDataStore
|
|
handler.LengthDeferrerDataStore
|
|
}
|
|
|
|
type FullUpload interface {
|
|
handler.Upload
|
|
handler.TerminatableUpload
|
|
handler.LengthDeclarableUpload
|
|
handler.ConcatableUpload
|
|
}
|
|
|
|
type FullLocker interface {
|
|
handler.Locker
|
|
}
|
|
|
|
type FullLock interface {
|
|
handler.Lock
|
|
}
|
|
|
|
type httpTest struct {
|
|
Name string
|
|
|
|
Method string
|
|
URL string
|
|
|
|
ReqBody io.Reader
|
|
ReqHeader map[string]string
|
|
|
|
Code int
|
|
ResBody string
|
|
ResHeader map[string]string
|
|
}
|
|
|
|
func (test *httpTest) Run(handler http.Handler, t *testing.T) *httptest.ResponseRecorder {
|
|
req, _ := http.NewRequest(test.Method, test.URL, test.ReqBody)
|
|
req.RequestURI = test.URL
|
|
|
|
// Add headers
|
|
for key, value := range test.ReqHeader {
|
|
req.Header.Set(key, value)
|
|
}
|
|
|
|
req.Host = "tus.io"
|
|
w := httptest.NewRecorder()
|
|
handler.ServeHTTP(w, req)
|
|
|
|
if w.Code != test.Code {
|
|
t.Errorf("Expected %v %s as status code (got %v %s)", test.Code, http.StatusText(test.Code), w.Code, http.StatusText(w.Code))
|
|
}
|
|
|
|
for key, value := range test.ResHeader {
|
|
header := w.Header().Get(key)
|
|
|
|
if value != header {
|
|
t.Errorf("Expected '%s' as '%s' (got '%s')", value, key, header)
|
|
}
|
|
}
|
|
|
|
if test.ResBody != "" && w.Body.String() != test.ResBody {
|
|
t.Errorf("Expected '%s' as body (got '%s'", test.ResBody, w.Body.String())
|
|
}
|
|
|
|
return w
|
|
}
|
|
|
|
type readerMatcher struct {
|
|
expect string
|
|
}
|
|
|
|
// NewReaderMatcher returns a gomock.Matcher which can be used in tests for
|
|
// expecting io.Readers as arguments. It will only report an argument x as
|
|
// matching if it's an io.Reader which, if fully read, equals the string `expect`.
|
|
func NewReaderMatcher(expect string) gomock.Matcher {
|
|
return readerMatcher{
|
|
expect: expect,
|
|
}
|
|
}
|
|
|
|
func (m readerMatcher) Matches(x interface{}) bool {
|
|
input, ok := x.(io.Reader)
|
|
if !ok {
|
|
return false
|
|
}
|
|
|
|
bytes, err := ioutil.ReadAll(input)
|
|
// Handle closed pipes similar to how EOF are handled by ioutil.ReadAll,
|
|
// we handle this error as if the stream ended normally.
|
|
if err == io.ErrClosedPipe {
|
|
err = nil
|
|
}
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
readStr := string(bytes)
|
|
return reflect.DeepEqual(m.expect, readStr)
|
|
}
|
|
|
|
func (m readerMatcher) String() string {
|
|
return fmt.Sprintf("reads to %s", m.expect)
|
|
}
|