Skip to content

M
mybee
Commit c057aedf authored by Janoš Guljaš's avatar Janoš Guljaš Committed by GitHub
Browse files
Options

add pushsync protocol to p2p service instance (#174)

parent e3153aba
Show whitespace changes
Inline Side-by-side
Showing with 4 additions and 0 deletions
pkg/node/node.go
View file @ c057aedf
...@@ -215,6 +215,10 @@ func NewBee(o Options) (*Bee, error) { ...@@ -215,6 +215,10 @@ func NewBee(o Options) (*Bee, error) {
Logger: logger, Logger: logger,
}) })
if err = p2ps.AddProtocol(pushSyncProtocol.Protocol()); err != nil {
return nil, fmt.Errorf("pushsync service: %w", err)
}
pushSyncPusher := pusher.New(pusher.Options{ pushSyncPusher := pusher.New(pusher.Options{
Storer: storer, Storer: storer,
PeerSuggester: topologyDriver, PeerSuggester: topologyDriver,
......
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