diff --git a/waku/v2/node/wakunode2.go b/waku/v2/node/wakunode2.go index 3771f723..cecfef35 100644 --- a/waku/v2/node/wakunode2.go +++ b/waku/v2/node/wakunode2.go @@ -88,7 +88,7 @@ func New(ctx context.Context, opts ...WakuNodeOption) (*WakuNode, error) { } if params.privKey != nil { - params.libP2POpts = append(params.libP2POpts, libp2p.Identity(*params.privKey)) + params.libP2POpts = append(params.libP2POpts, params.Identity()) } if params.addressFactory != nil { diff --git a/waku/v2/node/wakuoptions.go b/waku/v2/node/wakuoptions.go index 1342af00..8f1ff76c 100644 --- a/waku/v2/node/wakuoptions.go +++ b/waku/v2/node/wakuoptions.go @@ -10,6 +10,7 @@ import ( connmgr "github.com/libp2p/go-libp2p-connmgr" "github.com/libp2p/go-libp2p-core/crypto" pubsub "github.com/libp2p/go-libp2p-pubsub" + "github.com/libp2p/go-libp2p/config" basichost "github.com/libp2p/go-libp2p/p2p/host/basic" "github.com/multiformats/go-multiaddr" ma "github.com/multiformats/go-multiaddr" @@ -54,6 +55,10 @@ func (w WakuNodeParameters) MultiAddresses() []ma.Multiaddr { return w.multiAddr } +func (w WakuNodeParameters) Identity() config.Option { + return libp2p.Identity(*w.privKey) +} + // WithHostAddress is a WakuNodeOption that configures libp2p to listen on a list of net endpoint addresses func WithHostAddress(hostAddr []net.Addr) WakuNodeOption { return func(params *WakuNodeParameters) error {