diff --git a/appdatabase/migrations/sql/1733335056_default_log_namespaces.up.sql b/appdatabase/migrations/sql/1733335056_default_log_namespaces.up.sql new file mode 100644 index 00000000000..9001e2e5d57 --- /dev/null +++ b/appdatabase/migrations/sql/1733335056_default_log_namespaces.up.sql @@ -0,0 +1,6 @@ +UPDATE log_config +SET + log_namespaces = 'wakunode:info' +WHERE + log_namespaces IS NULL + OR log_namespaces = ''; diff --git a/wakuv2/message_publishing.go b/wakuv2/message_publishing.go index 93543bc6e39..c49532ec04f 100644 --- a/wakuv2/message_publishing.go +++ b/wakuv2/message_publishing.go @@ -86,7 +86,7 @@ func (w *Waku) publishEnvelope(envelope *protocol.Envelope) { var err error // only used in testing to simulate going offline if w.cfg.SkipPublishToTopic { - logger.Info("skipping publish to topic") + logger.Debug("skipping publish to topic") err = errors.New("test send failure") } else { err = w.messageSender.Send(publish.NewRequest(w.ctx, envelope)) diff --git a/wakuv2/persistence/dbstore.go b/wakuv2/persistence/dbstore.go index 4d75c0a56a0..5d5d889abe9 100644 --- a/wakuv2/persistence/dbstore.go +++ b/wakuv2/persistence/dbstore.go @@ -200,7 +200,7 @@ func (d *DBStore) Query(query *storepb.HistoryQuery) (*storepb.Index, []gowakuPe start := time.Now() defer func() { elapsed := time.Since(start) - d.log.Info(fmt.Sprintf("Loading records from the DB took %s", elapsed)) + d.log.Debug(fmt.Sprintf("Loading records from the DB took %s", elapsed)) }() sqlQuery := `SELECT id, receiverTimestamp, senderTimestamp, contentTopic, pubsubTopic, payload, version @@ -361,7 +361,7 @@ func (d *DBStore) GetAll() ([]gowakuPersistence.StoredMessage, error) { start := time.Now() defer func() { elapsed := time.Since(start) - d.log.Info("loading records from the DB", zap.Duration("duration", elapsed)) + d.log.Debug("loading records from the DB", zap.Duration("duration", elapsed)) }() rows, err := d.db.Query("SELECT id, receiverTimestamp, senderTimestamp, contentTopic, pubsubTopic, payload, version FROM store_messages ORDER BY senderTimestamp ASC") @@ -381,7 +381,7 @@ func (d *DBStore) GetAll() ([]gowakuPersistence.StoredMessage, error) { result = append(result, record) } - d.log.Info("DB returned records", zap.Int("count", len(result))) + d.log.Debug("DB returned records", zap.Int("count", len(result))) err = rows.Err() if err != nil { diff --git a/wakuv2/waku.go b/wakuv2/waku.go index 1fc541bd2f7..8df2a430f76 100644 --- a/wakuv2/waku.go +++ b/wakuv2/waku.go @@ -289,7 +289,7 @@ func New(nodeKey *ecdsa.PrivateKey, fleet string, cfg *Config, logger *zap.Logge node.WithConnectionNotification(waku.connectionNotifChan), node.WithTopicHealthStatusChannel(waku.topicHealthStatusChan), node.WithKeepAlive(randomPeersKeepAliveInterval, allPeersKeepAliveInterval), - node.WithLogger(logger), + node.WithLogger(logger.Named("wakunode")), node.WithLogLevel(logger.Level()), node.WithClusterID(cfg.ClusterID), node.WithMaxMsgSize(1024 * 1024), @@ -609,7 +609,7 @@ func (w *Waku) runPeerExchangeLoop() { w.logger.Debug("Peer exchange loop stopped") return case <-ticker.C: - w.logger.Info("Running peer exchange loop") + w.logger.Debug("Running peer exchange loop") // We select only the nodes discovered via DNS Discovery that support peer exchange // 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 { // Unsubscribe removes an installed message handler. func (w *Waku) UnsubscribeMany(ids []string) error { for _, id := range ids { - w.logger.Info("cleaning up filter", zap.String("id", id)) + w.logger.Debug("cleaning up filter", zap.String("id", id)) ok := w.filters.Uninstall(id) if !ok { 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 _, err := w.add(recvMessage, processImmediately) if err != nil { - logger.Info("invalid envelope received", zap.Error(err)) + logger.Debug("invalid envelope received", zap.Error(err)) trouble = true }