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

Author: osmaczko

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 = '';

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))

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 {

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
 	}