From 4ed2235f7943d15dd9412b6ef3a7cff17f874ceb Mon Sep 17 00:00:00 2001
From: Raymond Jacobson <ray@audius.co>
Date: Tue, 23 Jun 2026 18:47:41 -0700
Subject: [PATCH] chore: reduce api log noise

---
 api/server.go                    |  6 ++++--
 esindexer/esindexer.go           |  4 ++--
 solana/indexer/solana_indexer.go | 10 +++++++++-
 3 files changed, 15 insertions(+), 5 deletions(-)

diff --git a/api/server.go b/api/server.go
index 4284a5a8..40da7b4d 100644
--- a/api/server.go
+++ b/api/server.go
@@ -44,6 +44,7 @@ import (
 	"github.com/mcuadros/go-defaults"
 	"github.com/segmentio/encoding/json"
 	"go.uber.org/zap"
+	"go.uber.org/zap/zapcore"
 )
 
 //go:embed swagger/swagger-v1.yaml
@@ -375,7 +376,8 @@ func NewApiServer(config config.Config) *ApiServer {
 
 				return fields
 			},
-			Fields: []string{"status", "method", "url", "route"},
+			Fields: []string{"status", "method", "path", "route"},
+			Levels: []zapcore.Level{zapcore.ErrorLevel, zapcore.WarnLevel, zapcore.DebugLevel},
 		}))
 	}
 
@@ -529,7 +531,7 @@ func NewApiServer(config config.Config) *ApiServer {
 		g.Get("/tracks/unclaimed_id", app.v1TracksUnclaimedId)
 
 		g.Get("/tracks/latest", app.v1TracksLatest)
-			g.Get("/tracks/trending", app.v1TracksTrending)
+		g.Get("/tracks/trending", app.v1TracksTrending)
 		g.Get("/tracks/trending/ids", app.v1TracksTrendingIds)
 		g.Get("/tracks/trending/winners", app.v1TracksTrendingWinners)
 		g.Get("/tracks/trending/underground", app.v1TracksTrendingUnderground)
diff --git a/esindexer/esindexer.go b/esindexer/esindexer.go
index bb5e1c92..fe1f24b5 100644
--- a/esindexer/esindexer.go
+++ b/esindexer/esindexer.go
@@ -219,10 +219,10 @@ func (indexer *EsIndexer) scriptedUpdateSocial(userId int64, fieldName string, e
 		if err := indexer.indexIds("socials", userId); err != nil {
 			slog.Error("socials indexIds failed", "user", userId, "field", fieldName, "id", entityId, "err", err)
 		} else {
-			slog.Info("socials indexIds", "user", userId, "field", fieldName, "id", entityId)
+			slog.Debug("socials indexIds", "user", userId, "field", fieldName, "id", entityId)
 		}
 	} else {
-		slog.Info("social update", "user", userId, "field", fieldName, "id", entityId)
+		slog.Debug("social update", "user", userId, "field", fieldName, "id", entityId)
 	}
 
 }
diff --git a/solana/indexer/solana_indexer.go b/solana/indexer/solana_indexer.go
index 3a68481d..59c25f06 100644
--- a/solana/indexer/solana_indexer.go
+++ b/solana/indexer/solana_indexer.go
@@ -196,6 +196,7 @@ func (s *SolanaIndexer) ProcessRetryQueue(ctx context.Context) {
 	offset := 0
 	logger := s.logger.Named("RetryQueue")
 	count := 0
+	failedByIndexer := map[string]int{}
 	start := time.Now()
 	logger.Debug("starting to process retry queue...")
 	for {
@@ -217,7 +218,8 @@ func (s *SolanaIndexer) ProcessRetryQueue(ctx context.Context) {
 			}
 			err := indexer.HandleUpdate(ctx, item.UpdateMessage.SubscribeUpdate)
 			if err != nil {
-				logger.Error("failed to retry", zap.String("indexer", locker.NAME), zap.Error(err))
+				logger.Debug("retry queue item failed", zap.String("indexer", item.Indexer), zap.Error(err))
+				failedByIndexer[item.Indexer]++
 				offset++
 			} else {
 				err = common.DeleteFromRetryQueue(ctx, s.pool, item.ID)
@@ -234,6 +236,12 @@ func (s *SolanaIndexer) ProcessRetryQueue(ctx context.Context) {
 		return
 	}
 
+	if len(failedByIndexer) > 0 {
+		logger.Warn("retry queue items failed",
+			zap.Int("failed", offset),
+			zap.Any("failed_by_indexer", failedByIndexer))
+	}
+
 	logger.Info("finished processing retry queue",
 		zap.Int("count", count),
 		zap.Int("failed", offset),