2015-12-01 19:44:58 +01:00
|
|
|
// Copyright (c) 2014 The btcsuite developers
|
|
|
|
// Use of this source code is governed by an ISC
|
|
|
|
// license that can be found in the LICENSE file.
|
2014-08-08 22:43:50 +02:00
|
|
|
|
|
|
|
package waddrmgr_test
|
|
|
|
|
|
|
|
import (
|
2015-05-27 22:50:05 +02:00
|
|
|
"errors"
|
2014-08-08 22:43:50 +02:00
|
|
|
"fmt"
|
|
|
|
"testing"
|
|
|
|
|
2021-08-26 00:58:28 +02:00
|
|
|
"github.com/lbryio/lbcwallet/waddrmgr"
|
2014-08-08 22:43:50 +02:00
|
|
|
)
|
|
|
|
|
|
|
|
// TestErrorCodeStringer tests the stringized output for the ErrorCode type.
|
|
|
|
func TestErrorCodeStringer(t *testing.T) {
|
|
|
|
tests := []struct {
|
|
|
|
in waddrmgr.ErrorCode
|
|
|
|
want string
|
|
|
|
}{
|
|
|
|
{waddrmgr.ErrDatabase, "ErrDatabase"},
|
2015-03-03 18:51:21 +01:00
|
|
|
{waddrmgr.ErrUpgrade, "ErrUpgrade"},
|
2014-08-08 22:43:50 +02:00
|
|
|
{waddrmgr.ErrKeyChain, "ErrKeyChain"},
|
|
|
|
{waddrmgr.ErrCrypto, "ErrCrypto"},
|
2014-10-31 16:20:58 +01:00
|
|
|
{waddrmgr.ErrInvalidKeyType, "ErrInvalidKeyType"},
|
2014-08-08 22:43:50 +02:00
|
|
|
{waddrmgr.ErrNoExist, "ErrNoExist"},
|
|
|
|
{waddrmgr.ErrAlreadyExists, "ErrAlreadyExists"},
|
|
|
|
{waddrmgr.ErrCoinTypeTooHigh, "ErrCoinTypeTooHigh"},
|
|
|
|
{waddrmgr.ErrAccountNumTooHigh, "ErrAccountNumTooHigh"},
|
|
|
|
{waddrmgr.ErrLocked, "ErrLocked"},
|
|
|
|
{waddrmgr.ErrInvalidAccount, "ErrInvalidAccount"},
|
|
|
|
{waddrmgr.ErrAddressNotFound, "ErrAddressNotFound"},
|
|
|
|
{waddrmgr.ErrAccountNotFound, "ErrAccountNotFound"},
|
2014-12-12 09:54:26 +01:00
|
|
|
{waddrmgr.ErrDuplicateAddress, "ErrDuplicateAddress"},
|
|
|
|
{waddrmgr.ErrDuplicateAccount, "ErrDuplicateAccount"},
|
2014-08-08 22:43:50 +02:00
|
|
|
{waddrmgr.ErrTooManyAddresses, "ErrTooManyAddresses"},
|
|
|
|
{waddrmgr.ErrWrongPassphrase, "ErrWrongPassphrase"},
|
|
|
|
{waddrmgr.ErrWrongNet, "ErrWrongNet"},
|
Modernize the RPC server.
This is a rather monolithic commit that moves the old RPC server to
its own package (rpc/legacyrpc), introduces a new RPC server using
gRPC (rpc/rpcserver), and provides the ability to defer wallet loading
until request at a later time by an RPC (--noinitialload).
The legacy RPC server remains the default for now while the new gRPC
server is not enabled by default. Enabling the new server requires
setting a listen address (--experimenalrpclisten). This experimental
flag is used to effectively feature gate the server until it is ready
to use as a default. Both RPC servers can be run at the same time,
but require binding to different listen addresses.
In theory, with the legacy RPC server now living in its own package it
should become much easier to unit test the handlers. This will be
useful for any future changes to the package, as compatibility with
Core's wallet is still desired.
Type safety has also been improved in the legacy RPC server. Multiple
handler types are now used for methods that do and do not require the
RPC client as a dependency. This can statically help prevent nil
pointer dereferences, and was very useful for catching bugs during
refactoring.
To synchronize the wallet loading process between the main package
(the default) and through the gRPC WalletLoader service (with the
--noinitialload option), as well as increasing the loose coupling of
packages, a new wallet.Loader type has been added. All creating and
loading of existing wallets is done through a single Loader instance,
and callbacks can be attached to the instance to run after the wallet
has been opened. This is how the legacy RPC server is associated with
a loaded wallet, even after the wallet is loaded by a gRPC method in a
completely unrelated package.
Documentation for the new RPC server has been added to the
rpc/documentation directory. The documentation includes a
specification for the new RPC API, addresses how to make changes to
the server implementation, and provides short example clients in
several different languages.
Some of the new RPC methods are not implementated exactly as described
by the specification. These are considered bugs with the
implementation, not the spec. Known bugs are commented as such.
2015-06-01 21:57:50 +02:00
|
|
|
{waddrmgr.ErrCallBackBreak, "ErrCallBackBreak"},
|
|
|
|
{waddrmgr.ErrEmptyPassphrase, "ErrEmptyPassphrase"},
|
2014-08-08 22:43:50 +02:00
|
|
|
{0xffff, "Unknown ErrorCode (65535)"},
|
|
|
|
}
|
|
|
|
t.Logf("Running %d tests", len(tests))
|
|
|
|
for i, test := range tests {
|
|
|
|
result := test.in.String()
|
|
|
|
if result != test.want {
|
|
|
|
t.Errorf("String #%d\ngot: %s\nwant: %s", i, result,
|
|
|
|
test.want)
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// TestManagerError tests the error output for the ManagerError type.
|
|
|
|
func TestManagerError(t *testing.T) {
|
|
|
|
tests := []struct {
|
|
|
|
in waddrmgr.ManagerError
|
|
|
|
want string
|
|
|
|
}{
|
|
|
|
// Manager level error.
|
|
|
|
{
|
|
|
|
waddrmgr.ManagerError{Description: "human-readable error"},
|
|
|
|
"human-readable error",
|
|
|
|
},
|
|
|
|
|
|
|
|
// Encapsulated database error.
|
|
|
|
{
|
|
|
|
waddrmgr.ManagerError{
|
|
|
|
Description: "failed to store master private " +
|
|
|
|
"key parameters",
|
|
|
|
ErrorCode: waddrmgr.ErrDatabase,
|
|
|
|
Err: fmt.Errorf("underlying db error"),
|
|
|
|
},
|
|
|
|
"failed to store master private key parameters: " +
|
|
|
|
"underlying db error",
|
|
|
|
},
|
|
|
|
|
|
|
|
// Encapsulated key chain error.
|
|
|
|
{
|
|
|
|
waddrmgr.ManagerError{
|
|
|
|
Description: "failed to derive extended key " +
|
|
|
|
"branch 0",
|
|
|
|
ErrorCode: waddrmgr.ErrKeyChain,
|
|
|
|
Err: fmt.Errorf("underlying error"),
|
|
|
|
},
|
|
|
|
"failed to derive extended key branch 0: underlying " +
|
|
|
|
"error",
|
|
|
|
},
|
|
|
|
|
|
|
|
// Encapsulated crypto error.
|
|
|
|
{
|
|
|
|
waddrmgr.ManagerError{
|
|
|
|
Description: "failed to decrypt account 0 " +
|
|
|
|
"private key",
|
|
|
|
ErrorCode: waddrmgr.ErrCrypto,
|
|
|
|
Err: fmt.Errorf("underlying error"),
|
|
|
|
},
|
|
|
|
"failed to decrypt account 0 private key: underlying " +
|
|
|
|
"error",
|
|
|
|
},
|
|
|
|
}
|
|
|
|
|
|
|
|
t.Logf("Running %d tests", len(tests))
|
|
|
|
for i, test := range tests {
|
|
|
|
result := test.in.Error()
|
|
|
|
if result != test.want {
|
|
|
|
t.Errorf("Error #%d\ngot: %s\nwant: %s", i, result,
|
|
|
|
test.want)
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
2015-05-27 22:50:05 +02:00
|
|
|
|
|
|
|
// TestIsError tests the IsError func.
|
|
|
|
func TestIsError(t *testing.T) {
|
|
|
|
tests := []struct {
|
|
|
|
err error
|
|
|
|
code waddrmgr.ErrorCode
|
|
|
|
exp bool
|
|
|
|
}{
|
|
|
|
{
|
|
|
|
err: waddrmgr.ManagerError{
|
|
|
|
ErrorCode: waddrmgr.ErrDatabase,
|
|
|
|
},
|
|
|
|
code: waddrmgr.ErrDatabase,
|
|
|
|
exp: true,
|
|
|
|
},
|
|
|
|
{
|
|
|
|
// package should never return *ManagerError
|
|
|
|
err: &waddrmgr.ManagerError{
|
|
|
|
ErrorCode: waddrmgr.ErrDatabase,
|
|
|
|
},
|
|
|
|
code: waddrmgr.ErrDatabase,
|
|
|
|
exp: false,
|
|
|
|
},
|
|
|
|
{
|
|
|
|
err: waddrmgr.ManagerError{
|
|
|
|
ErrorCode: waddrmgr.ErrCrypto,
|
|
|
|
},
|
|
|
|
code: waddrmgr.ErrDatabase,
|
|
|
|
exp: false,
|
|
|
|
},
|
|
|
|
{
|
|
|
|
err: errors.New("not a ManagerError"),
|
|
|
|
code: waddrmgr.ErrDatabase,
|
|
|
|
exp: false,
|
|
|
|
},
|
|
|
|
}
|
|
|
|
|
|
|
|
for i, test := range tests {
|
|
|
|
got := waddrmgr.IsError(test.err, test.code)
|
|
|
|
if got != test.exp {
|
|
|
|
t.Errorf("Test %d: got %v expected %v", i, got, test.exp)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|