chore: refactor: move retry test to API
This commit is contained in:
parent
06262868f5
commit
3c195e4d71
@ -11,6 +11,9 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
|
"github.com/filecoin-project/go-jsonrpc"
|
||||||
|
"golang.org/x/xerrors"
|
||||||
|
|
||||||
"github.com/stretchr/testify/require"
|
"github.com/stretchr/testify/require"
|
||||||
)
|
)
|
||||||
|
|
||||||
@ -124,3 +127,18 @@ func TestPermTags(t *testing.T) {
|
|||||||
_ = PermissionedStorMinerAPI(&StorageMinerStruct{})
|
_ = PermissionedStorMinerAPI(&StorageMinerStruct{})
|
||||||
_ = PermissionedWorkerAPI(&WorkerStruct{})
|
_ = PermissionedWorkerAPI(&WorkerStruct{})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestRetryErrorIsInTrue(t *testing.T) {
|
||||||
|
errorsToRetry := []error{&jsonrpc.RPCConnectionError{}}
|
||||||
|
require.True(t, ErrorIsIn(&jsonrpc.RPCConnectionError{}, errorsToRetry))
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRetryErrorIsInFalse(t *testing.T) {
|
||||||
|
errorsToRetry := []error{&jsonrpc.RPCConnectionError{}}
|
||||||
|
require.False(t, ErrorIsIn(xerrors.Errorf("random error"), errorsToRetry))
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestRetryWrappedErrorIsInTrue(t *testing.T) {
|
||||||
|
errorsToRetry := []error{&jsonrpc.RPCConnectionError{}}
|
||||||
|
require.True(t, ErrorIsIn(xerrors.Errorf("wrapped: %w", &jsonrpc.RPCConnectionError{}), errorsToRetry))
|
||||||
|
}
|
||||||
|
@ -1,27 +0,0 @@
|
|||||||
package retry
|
|
||||||
|
|
||||||
import (
|
|
||||||
"testing"
|
|
||||||
|
|
||||||
"github.com/stretchr/testify/require"
|
|
||||||
"golang.org/x/xerrors"
|
|
||||||
|
|
||||||
"github.com/filecoin-project/go-jsonrpc"
|
|
||||||
|
|
||||||
"github.com/filecoin-project/lotus/api"
|
|
||||||
)
|
|
||||||
|
|
||||||
func TestRetryErrorIsInTrue(t *testing.T) {
|
|
||||||
errorsToRetry := []error{&jsonrpc.RPCConnectionError{}}
|
|
||||||
require.True(t, api.ErrorIsIn(&jsonrpc.RPCConnectionError{}, errorsToRetry))
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestRetryErrorIsInFalse(t *testing.T) {
|
|
||||||
errorsToRetry := []error{&jsonrpc.RPCConnectionError{}}
|
|
||||||
require.False(t, api.ErrorIsIn(xerrors.Errorf("random error"), errorsToRetry))
|
|
||||||
}
|
|
||||||
|
|
||||||
func TestRetryWrappedErrorIsInTrue(t *testing.T) {
|
|
||||||
errorsToRetry := []error{&jsonrpc.RPCConnectionError{}}
|
|
||||||
require.True(t, api.ErrorIsIn(xerrors.Errorf("wrapped: %w", &jsonrpc.RPCConnectionError{}), errorsToRetry))
|
|
||||||
}
|
|
Loading…
Reference in New Issue
Block a user