mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-18 18:02:24 +00:00
fix: fix typos
This commit is contained in:
parent
7a2706f2a8
commit
0413f3777f
2 changed files with 11 additions and 6 deletions
|
|
@ -34,6 +34,7 @@ import (
|
||||||
"github.com/ethereum/go-ethereum/ethclient"
|
"github.com/ethereum/go-ethereum/ethclient"
|
||||||
"github.com/ethereum/go-ethereum/internal/debug"
|
"github.com/ethereum/go-ethereum/internal/debug"
|
||||||
"github.com/ethereum/go-ethereum/internal/flags"
|
"github.com/ethereum/go-ethereum/internal/flags"
|
||||||
|
"github.com/ethereum/go-ethereum/internal/walletevent"
|
||||||
"github.com/ethereum/go-ethereum/log"
|
"github.com/ethereum/go-ethereum/log"
|
||||||
"github.com/ethereum/go-ethereum/metrics"
|
"github.com/ethereum/go-ethereum/metrics"
|
||||||
"github.com/ethereum/go-ethereum/node"
|
"github.com/ethereum/go-ethereum/node"
|
||||||
|
|
@ -368,7 +369,8 @@ func startNode(ctx *cli.Context, stack *node.Node, isConsole bool) {
|
||||||
// Create a client to interact with local geth node.
|
// Create a client to interact with local geth node.
|
||||||
rpcClient := stack.Attach()
|
rpcClient := stack.Attach()
|
||||||
ethClient := ethclient.NewClient(rpcClient)
|
ethClient := ethclient.NewClient(rpcClient)
|
||||||
walletEventListener := walletevent.NewListener(&log)
|
logger := log.New(ctx)
|
||||||
|
walletEventListener := walletevent.NewListener(logger, ethClient)
|
||||||
|
|
||||||
go walletEventListener.Listen(stack.AccountManager().Wallets(), events)
|
go walletEventListener.Listen(stack.AccountManager().Wallets(), events)
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -17,12 +17,14 @@
|
||||||
package walletevent
|
package walletevent
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"github.com/ethereum/go-ethereum"
|
||||||
"github.com/ethereum/go-ethereum/accounts"
|
"github.com/ethereum/go-ethereum/accounts"
|
||||||
)
|
)
|
||||||
|
|
||||||
type (
|
type (
|
||||||
Listener struct {
|
Listener struct {
|
||||||
logger logger
|
logger logger
|
||||||
|
ethClient ethereum.ChainStateReader
|
||||||
}
|
}
|
||||||
|
|
||||||
logger interface {
|
logger interface {
|
||||||
|
|
@ -32,9 +34,10 @@ type (
|
||||||
)
|
)
|
||||||
|
|
||||||
// NewListener creates a new wallet event listener.
|
// NewListener creates a new wallet event listener.
|
||||||
func NewListener(logger logger) *Listener {
|
func NewListener(logger logger, ethClient ethereum.ChainStateReader) *Listener {
|
||||||
return Listener{
|
return &Listener{
|
||||||
logger: logger,
|
logger: logger,
|
||||||
|
ethClient: ethClient,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -63,7 +66,7 @@ func (l *Listener) Listen(wallets []accounts.Wallet, events chan accounts.Wallet
|
||||||
}
|
}
|
||||||
derivationPaths = append(derivationPaths, accounts.DefaultBaseDerivationPath)
|
derivationPaths = append(derivationPaths, accounts.DefaultBaseDerivationPath)
|
||||||
|
|
||||||
event.Wallet.SelfDerive(derivationPaths, ethClient)
|
event.Wallet.SelfDerive(derivationPaths, l.ethClient)
|
||||||
|
|
||||||
case accounts.WalletDropped:
|
case accounts.WalletDropped:
|
||||||
l.logger.Info("Old wallet dropped", "url", event.Wallet.URL())
|
l.logger.Info("Old wallet dropped", "url", event.Wallet.URL())
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue