mirror of
https://github.com/status-im/status-go.git
synced 2025-02-10 05:45:30 +00:00
40359f9c1b
* Adding wakunode module * Adding wakuv2 fleet files * Add waku fleets to update-fleet-config script * Adding config items for waku v2 * Conditionally start waku v2 node depending on config * Adapting common code to use go-waku * Setting log level to info * update dependencies * update fleet config to use WakuNodes instead of BootNodes * send and receive messages * use hash returned when publishing a message * add waku store protocol * trigger signal after receiving store messages * exclude linting rule SA1019 to check deprecated packages
109 lines
2.2 KiB
Go
109 lines
2.2 KiB
Go
package gethbridge
|
|
|
|
import (
|
|
"errors"
|
|
|
|
"go.uber.org/zap"
|
|
|
|
"github.com/status-im/status-go/waku"
|
|
"github.com/status-im/status-go/wakuv2"
|
|
|
|
"github.com/ethereum/go-ethereum/node"
|
|
"github.com/ethereum/go-ethereum/p2p/enode"
|
|
|
|
gethens "github.com/status-im/status-go/eth-node/bridge/geth/ens"
|
|
"github.com/status-im/status-go/eth-node/types"
|
|
enstypes "github.com/status-im/status-go/eth-node/types/ens"
|
|
)
|
|
|
|
type gethNodeWrapper struct {
|
|
stack *node.Node
|
|
}
|
|
|
|
func NewNodeBridge(stack *node.Node) types.Node {
|
|
return &gethNodeWrapper{stack: stack}
|
|
}
|
|
|
|
func (w *gethNodeWrapper) Poll() {
|
|
// noop
|
|
}
|
|
|
|
func (w *gethNodeWrapper) NewENSVerifier(logger *zap.Logger) enstypes.ENSVerifier {
|
|
return gethens.NewVerifier(logger)
|
|
}
|
|
|
|
func (w *gethNodeWrapper) GetWaku(ctx interface{}) (types.Waku, error) {
|
|
var nativeWaku *waku.Waku
|
|
if ctx == nil || ctx == w {
|
|
err := w.stack.Service(&nativeWaku)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
} else {
|
|
switch serviceProvider := ctx.(type) {
|
|
case *node.ServiceContext:
|
|
err := serviceProvider.Service(&nativeWaku)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
}
|
|
}
|
|
if nativeWaku == nil {
|
|
return nil, errors.New("waku service is not available")
|
|
}
|
|
|
|
return NewGethWakuWrapper(nativeWaku), nil
|
|
}
|
|
|
|
func (w *gethNodeWrapper) GetWakuV2(ctx interface{}) (types.Waku, error) {
|
|
var nativeWaku *wakuv2.Waku
|
|
if ctx == nil || ctx == w {
|
|
err := w.stack.Service(&nativeWaku)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
} else {
|
|
switch serviceProvider := ctx.(type) {
|
|
case *node.ServiceContext:
|
|
err := serviceProvider.Service(&nativeWaku)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
}
|
|
}
|
|
if nativeWaku == nil {
|
|
return nil, errors.New("waku service is not available")
|
|
}
|
|
|
|
return NewGethWakuV2Wrapper(nativeWaku), nil
|
|
}
|
|
|
|
func (w *gethNodeWrapper) AddPeer(url string) error {
|
|
parsedNode, err := enode.ParseV4(url)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
w.stack.Server().AddPeer(parsedNode)
|
|
|
|
return nil
|
|
}
|
|
|
|
func (w *gethNodeWrapper) RemovePeer(url string) error {
|
|
parsedNode, err := enode.ParseV4(url)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
w.stack.Server().RemovePeer(parsedNode)
|
|
|
|
return nil
|
|
}
|
|
|
|
func (w *gethNodeWrapper) PeersCount() int {
|
|
if w.stack.Server() == nil {
|
|
return 0
|
|
}
|
|
return len(w.stack.Server().Peers())
|
|
}
|