diff --git a/waku/v2/node/wakunode2.go b/waku/v2/node/wakunode2.go index 48ad8b7e..e4e3cd65 100644 --- a/waku/v2/node/wakunode2.go +++ b/waku/v2/node/wakunode2.go @@ -9,6 +9,7 @@ import ( "sync" "time" + golog "github.com/ipfs/go-log/v2" "github.com/libp2p/go-libp2p" "go.uber.org/zap" @@ -129,6 +130,7 @@ func New(opts ...WakuNodeOption) (*WakuNode, error) { if params.logger == nil { params.logger = utils.Logger() + golog.SetAllLoggers(params.logLevel) } if params.privKey == nil { diff --git a/waku/v2/node/wakuoptions.go b/waku/v2/node/wakuoptions.go index b0c1c377..ae59ec9e 100644 --- a/waku/v2/node/wakuoptions.go +++ b/waku/v2/node/wakuoptions.go @@ -58,7 +58,8 @@ type WakuNodeParameters struct { wssPort int tlsConfig *tls.Config - logger *zap.Logger + logger *zap.Logger + logLevel logging.LogLevel noDefaultWakuTopic bool enableRelay bool @@ -150,7 +151,8 @@ func WithLogger(l *zap.Logger) WakuNodeOption { // WithLogLevel is a WakuNodeOption that sets the log level for go-waku func WithLogLevel(lvl zapcore.Level) WakuNodeOption { return func(params *WakuNodeParameters) error { - logging.SetAllLoggers(logging.LogLevel(lvl)) + params.logLevel = logging.LogLevel(lvl) + logging.SetAllLoggers(params.logLevel) return nil } }