syncthing/lib/protocol/common_test.go

88 lines
1.8 KiB
Go
Raw Normal View History

2015-01-13 12:31:14 +00:00
// Copyright (C) 2014 The Protocol Authors.
2014-09-22 19:42:11 +00:00
package protocol
2016-04-09 01:10:31 +00:00
import "time"
2014-09-22 19:42:11 +00:00
type TestModel struct {
data []byte
folder string
name string
offset int64
size int32
hash []byte
weakHash uint32
fromTemporary bool
indexFn func(string, []FileInfo)
ccFn func(ClusterConfig)
closedCh chan struct{}
closedErr error
2014-09-22 19:42:11 +00:00
}
func newTestModel() *TestModel {
return &TestModel{
2016-01-12 08:19:44 +00:00
closedCh: make(chan struct{}),
2014-09-22 19:42:11 +00:00
}
}
func (t *TestModel) Index(_ Connection, folder string, files []FileInfo) error {
if t.indexFn != nil {
t.indexFn(folder, files)
}
return nil
2014-09-22 19:42:11 +00:00
}
func (*TestModel) IndexUpdate(Connection, string, []FileInfo) error {
return nil
2014-09-22 19:42:11 +00:00
}
func (t *TestModel) Request(_ Connection, folder, name string, _, size int32, offset int64, hash []byte, weakHash uint32, fromTemporary bool) (RequestResponse, error) {
t.folder = folder
2014-09-22 19:42:11 +00:00
t.name = name
t.offset = offset
t.size = size
2015-01-24 21:56:12 +00:00
t.hash = hash
t.weakHash = weakHash
t.fromTemporary = fromTemporary
buf := make([]byte, len(t.data))
2015-07-29 20:23:43 +00:00
copy(buf, t.data)
return &fakeRequestResponse{buf}, nil
2014-09-22 19:42:11 +00:00
}
func (t *TestModel) Closed(_ Connection, err error) {
2016-01-12 08:19:44 +00:00
t.closedErr = err
2014-09-22 19:42:11 +00:00
close(t.closedCh)
}
func (t *TestModel) ClusterConfig(_ Connection, config ClusterConfig) error {
if t.ccFn != nil {
t.ccFn(config)
}
return nil
2014-09-22 19:42:11 +00:00
}
func (*TestModel) DownloadProgress(Connection, string, []FileDownloadProgressUpdate) error {
return nil
}
2016-01-12 08:19:44 +00:00
func (t *TestModel) closedError() error {
2014-09-22 19:42:11 +00:00
select {
case <-t.closedCh:
2016-01-12 08:19:44 +00:00
return t.closedErr
2014-09-22 19:42:11 +00:00
case <-time.After(1 * time.Second):
2016-01-12 08:19:44 +00:00
return nil // Timeout
2014-09-22 19:42:11 +00:00
}
}
type fakeRequestResponse struct {
data []byte
}
func (r *fakeRequestResponse) Data() []byte {
return r.data
}
func (*fakeRequestResponse) Close() {}
func (*fakeRequestResponse) Wait() {}