Commit 7b3a853b authored by Janoš Guljaš's avatar Janoš Guljaš Committed by GitHub

remove libp2p Options type from node Bee Options (#31)

parent 8a8d0198
...@@ -21,7 +21,6 @@ import ( ...@@ -21,7 +21,6 @@ import (
"github.com/ethersphere/bee/pkg/logging" "github.com/ethersphere/bee/pkg/logging"
"github.com/ethersphere/bee/pkg/node" "github.com/ethersphere/bee/pkg/node"
"github.com/ethersphere/bee/pkg/p2p/libp2p"
) )
func (c *command) initStartCmd() (err error) { func (c *command) initStartCmd() (err error) {
...@@ -93,17 +92,14 @@ func (c *command) initStartCmd() (err error) { ...@@ -93,17 +92,14 @@ func (c *command) initStartCmd() (err error) {
} }
b, err := node.NewBee(node.Options{ b, err := node.NewBee(node.Options{
DataDir: c.config.GetString(optionNameDataDir), DataDir: c.config.GetString(optionNameDataDir),
Password: password, Password: password,
APIAddr: c.config.GetString(optionNameAPIAddr), APIAddr: c.config.GetString(optionNameAPIAddr),
DebugAPIAddr: debugAPIAddr, DebugAPIAddr: debugAPIAddr,
LibP2POptions: libp2p.Options{ Addr: c.config.GetString(optionNameP2PAddr),
Addr: c.config.GetString(optionNameP2PAddr), DisableWS: c.config.GetBool(optionNameP2PDisableWS),
DisableWS: c.config.GetBool(optionNameP2PDisableWS), DisableQUIC: c.config.GetBool(optionNameP2PDisableQUIC),
DisableQUIC: c.config.GetBool(optionNameP2PDisableQUIC), NetworkID: c.config.GetInt32(optionNameNetworkID),
NetworkID: c.config.GetInt32(optionNameNetworkID),
Logger: logger,
},
Bootnodes: c.config.GetStringSlice(optionNameBootnodes), Bootnodes: c.config.GetStringSlice(optionNameBootnodes),
TracingEnabled: c.config.GetBool(optionNameTracingEnabled), TracingEnabled: c.config.GetBool(optionNameTracingEnabled),
TracingEndpoint: c.config.GetString(optionNameTracingEndpoint), TracingEndpoint: c.config.GetString(optionNameTracingEndpoint),
......
...@@ -47,7 +47,10 @@ type Options struct { ...@@ -47,7 +47,10 @@ type Options struct {
Password string Password string
APIAddr string APIAddr string
DebugAPIAddr string DebugAPIAddr string
LibP2POptions libp2p.Options Addr string
DisableWS bool
DisableQUIC bool
NetworkID int32
Bootnodes []string Bootnodes []string
Logger logging.Logger Logger logging.Logger
TracingEnabled bool TracingEnabled bool
...@@ -104,12 +107,17 @@ func NewBee(o Options) (*Bee, error) { ...@@ -104,12 +107,17 @@ func NewBee(o Options) (*Bee, error) {
logger.Infof("new libp2p key created") logger.Infof("new libp2p key created")
} }
libP2POptions := o.LibP2POptions p2ps, err := libp2p.New(p2pCtx, libp2p.Options{
libP2POptions.Overlay = address PrivateKey: libp2pPrivateKey,
libP2POptions.PrivateKey = libp2pPrivateKey Overlay: address,
libP2POptions.Addressbook = addressbook Addr: o.Addr,
libP2POptions.Tracer = tracer DisableWS: o.DisableWS,
p2ps, err := libp2p.New(p2pCtx, libP2POptions) DisableQUIC: o.DisableQUIC,
NetworkID: o.NetworkID,
Addressbook: addressbook,
Logger: logger,
Tracer: tracer,
})
if err != nil { if err != nil {
return nil, fmt.Errorf("p2p service: %w", err) return nil, fmt.Errorf("p2p service: %w", err)
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment