Skip to content

Commit 61c9e83

Browse files
committed
chore(logging)_: default waku node logs to INFO level
This ensures waku node logs remain at INFO level, even if the global logging level is set lower (e.g. DEBUG). To enable waku logs at a specific level, one can execute: `wakuext_setLogNamespaces([{"logNamespaces": "wakunode:debug"}])`. iterates: status-im/status-desktop#16511
1 parent 50933aa commit 61c9e83

File tree

3 files changed

+11
-5
lines changed

3 files changed

+11
-5
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
UPDATE log_config
2+
SET
3+
log_namespaces = 'wakunode:info'
4+
WHERE
5+
log_namespaces IS NULL
6+
OR log_namespaces = '';

wakuv2/message_publishing.go

+1-1
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ func (w *Waku) publishEnvelope(envelope *protocol.Envelope) {
8686
var err error
8787
// only used in testing to simulate going offline
8888
if w.cfg.SkipPublishToTopic {
89-
logger.Info("skipping publish to topic")
89+
logger.Debug("skipping publish to topic")
9090
err = errors.New("test send failure")
9191
} else {
9292
err = w.messageSender.Send(publish.NewRequest(w.ctx, envelope))

wakuv2/waku.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -289,7 +289,7 @@ func New(nodeKey *ecdsa.PrivateKey, fleet string, cfg *Config, logger *zap.Logge
289289
node.WithConnectionNotification(waku.connectionNotifChan),
290290
node.WithTopicHealthStatusChannel(waku.topicHealthStatusChan),
291291
node.WithKeepAlive(randomPeersKeepAliveInterval, allPeersKeepAliveInterval),
292-
node.WithLogger(logger),
292+
node.WithLogger(logger.Named("wakunode")),
293293
node.WithLogLevel(logger.Level()),
294294
node.WithClusterID(cfg.ClusterID),
295295
node.WithMaxMsgSize(1024 * 1024),
@@ -609,7 +609,7 @@ func (w *Waku) runPeerExchangeLoop() {
609609
w.logger.Debug("Peer exchange loop stopped")
610610
return
611611
case <-ticker.C:
612-
w.logger.Info("Running peer exchange loop")
612+
w.logger.Debug("Running peer exchange loop")
613613

614614
// We select only the nodes discovered via DNS Discovery that support peer exchange
615615
// We assume that those peers are running peer exchange according to infra config,
@@ -1021,7 +1021,7 @@ func (w *Waku) GetFilter(id string) *common.Filter {
10211021
// Unsubscribe removes an installed message handler.
10221022
func (w *Waku) UnsubscribeMany(ids []string) error {
10231023
for _, id := range ids {
1024-
w.logger.Info("cleaning up filter", zap.String("id", id))
1024+
w.logger.Debug("cleaning up filter", zap.String("id", id))
10251025
ok := w.filters.Uninstall(id)
10261026
if !ok {
10271027
w.logger.Warn("could not remove filter with id", zap.String("id", id))
@@ -1445,7 +1445,7 @@ func (w *Waku) OnNewEnvelopes(envelope *protocol.Envelope, msgType common.Messag
14451445

14461446
_, err := w.add(recvMessage, processImmediately)
14471447
if err != nil {
1448-
logger.Info("invalid envelope received", zap.Error(err))
1448+
logger.Debug("invalid envelope received", zap.Error(err))
14491449
trouble = true
14501450
}
14511451

0 commit comments

Comments
 (0)