mirror of
https://github.com/rclone/rclone.git
synced 2024-11-23 08:54:10 +01:00
f78cd1e043
- Change rclone/fs interfaces to accept context.Context - Update interface implementations to use context.Context - Change top level usage to propagate context to lover level functions Context propagation is needed for stopping transfers and passing other request-scoped values.
118 lines
2.7 KiB
Go
118 lines
2.7 KiB
Go
package rc
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"testing"
|
|
|
|
"github.com/pkg/errors"
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func clearOptionBlock() {
|
|
optionBlock = map[string]interface{}{}
|
|
}
|
|
|
|
var testOptions = struct {
|
|
String string
|
|
Int int
|
|
}{
|
|
String: "hello",
|
|
Int: 42,
|
|
}
|
|
|
|
func TestAddOption(t *testing.T) {
|
|
defer clearOptionBlock()
|
|
assert.Equal(t, len(optionBlock), 0)
|
|
AddOption("potato", &testOptions)
|
|
assert.Equal(t, len(optionBlock), 1)
|
|
assert.Equal(t, len(optionReload), 0)
|
|
assert.Equal(t, &testOptions, optionBlock["potato"])
|
|
}
|
|
|
|
func TestAddOptionReload(t *testing.T) {
|
|
defer clearOptionBlock()
|
|
assert.Equal(t, len(optionBlock), 0)
|
|
reload := func() error { return nil }
|
|
AddOptionReload("potato", &testOptions, reload)
|
|
assert.Equal(t, len(optionBlock), 1)
|
|
assert.Equal(t, len(optionReload), 1)
|
|
assert.Equal(t, &testOptions, optionBlock["potato"])
|
|
assert.Equal(t, fmt.Sprintf("%p", reload), fmt.Sprintf("%p", optionReload["potato"]))
|
|
}
|
|
|
|
func TestOptionsBlocks(t *testing.T) {
|
|
defer clearOptionBlock()
|
|
AddOption("potato", &testOptions)
|
|
call := Calls.Get("options/blocks")
|
|
require.NotNil(t, call)
|
|
in := Params{}
|
|
out, err := call.Fn(context.Background(), in)
|
|
require.NoError(t, err)
|
|
require.NotNil(t, out)
|
|
assert.Equal(t, Params{"options": []string{"potato"}}, out)
|
|
}
|
|
|
|
func TestOptionsGet(t *testing.T) {
|
|
defer clearOptionBlock()
|
|
AddOption("potato", &testOptions)
|
|
call := Calls.Get("options/get")
|
|
require.NotNil(t, call)
|
|
in := Params{}
|
|
out, err := call.Fn(context.Background(), in)
|
|
require.NoError(t, err)
|
|
require.NotNil(t, out)
|
|
assert.Equal(t, Params{"potato": &testOptions}, out)
|
|
}
|
|
|
|
func TestOptionsSet(t *testing.T) {
|
|
defer clearOptionBlock()
|
|
var reloaded int
|
|
AddOptionReload("potato", &testOptions, func() error {
|
|
if reloaded > 0 {
|
|
return errors.New("error while reloading")
|
|
}
|
|
reloaded++
|
|
return nil
|
|
})
|
|
call := Calls.Get("options/set")
|
|
require.NotNil(t, call)
|
|
|
|
in := Params{
|
|
"potato": Params{
|
|
"Int": 50,
|
|
},
|
|
}
|
|
out, err := call.Fn(context.Background(), in)
|
|
require.NoError(t, err)
|
|
require.Nil(t, out)
|
|
assert.Equal(t, 50, testOptions.Int)
|
|
assert.Equal(t, "hello", testOptions.String)
|
|
assert.Equal(t, 1, reloaded)
|
|
|
|
// error from reload
|
|
_, err = call.Fn(context.Background(), in)
|
|
require.Error(t, err)
|
|
assert.Contains(t, err.Error(), "error while reloading")
|
|
|
|
// unknown option block
|
|
in = Params{
|
|
"sausage": Params{
|
|
"Int": 50,
|
|
},
|
|
}
|
|
_, err = call.Fn(context.Background(), in)
|
|
require.Error(t, err)
|
|
assert.Contains(t, err.Error(), "unknown option block")
|
|
|
|
// bad shape
|
|
in = Params{
|
|
"potato": []string{"a", "b"},
|
|
}
|
|
_, err = call.Fn(context.Background(), in)
|
|
require.Error(t, err)
|
|
assert.Contains(t, err.Error(), "failed to write options")
|
|
|
|
}
|