From 35895f0ea856ff1436e697d9f3254f4494524881 Mon Sep 17 00:00:00 2001
From: Randy Schott <1815175+schottra@users.noreply.github.com>
Date: Thu, 16 Oct 2025 15:08:58 -0400
Subject: [PATCH 1/2] sync core indexer logger so it actually pushes them up

---
 indexer/indexer.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/indexer/indexer.go b/indexer/indexer.go
index 616d450e..b51a48e9 100644
--- a/indexer/indexer.go
+++ b/indexer/indexer.go
@@ -52,6 +52,7 @@ func NewIndexer(config config.Config) *CoreIndexer {
 
 func (ci *CoreIndexer) Start(ctx context.Context) error {
 	sdk := sdk.NewAudiusdSDK(ci.Config.AudiusdURL)
+	go logging.SyncOnTicks(ctx, ci.logger, time.Second*10)
 
 	var height int64
 	err := ci.pool.QueryRow(context.Background(), `select last_checkpoint from indexing_checkpoints where tablename = $1`, CoreIndexerCheckpointName).Scan(&height)
@@ -156,4 +157,8 @@ func (ci *CoreIndexer) handleManageEntity(dbTx dbv1.DBTX, logger *zap.Logger, em
 
 func (ci *CoreIndexer) Close() {
 	ci.pool.Close()
+	err := ci.logger.Sync()
+	if err != nil {
+		ci.logger.Error("failed to sync logger", zap.Error(err))
+	}
 }

From 94ff9e5b468f2ebf8a27bc5f3571776112dec684 Mon Sep 17 00:00:00 2001
From: Randy Schott <1815175+schottra@users.noreply.github.com>
Date: Thu, 16 Oct 2025 15:34:17 -0400
Subject: [PATCH 2/2] fix error returning and ignore sync errors on shutdown

---
 indexer/indexer.go | 14 ++++++--------
 1 file changed, 6 insertions(+), 8 deletions(-)

diff --git a/indexer/indexer.go b/indexer/indexer.go
index b51a48e9..bc622739 100644
--- a/indexer/indexer.go
+++ b/indexer/indexer.go
@@ -3,7 +3,6 @@ package indexer
 import (
 	"context"
 	"fmt"
-	"log"
 	"time"
 
 	"api.audius.co/config"
@@ -77,14 +76,15 @@ func (ci *CoreIndexer) Start(ctx context.Context) error {
 		select {
 		case <-ctx.Done():
 			ci.logger.Info("Shutting down core indexer")
-			return nil
+			return ctx.Err()
 		default:
 		}
 		block, err := sdk.Core.GetBlock(context.Background(), connect.NewRequest(&corev1.GetBlockRequest{
 			Height: height,
 		}))
 		if err != nil {
-			log.Fatal(err)
+			ci.logger.Error("failed to get block", zap.Error(err))
+			return err
 		}
 
 		if block.Msg.Block.Height < 0 {
@@ -94,7 +94,8 @@ func (ci *CoreIndexer) Start(ctx context.Context) error {
 
 		err = ci.handleBlock(block.Msg.Block)
 		if err != nil {
-			log.Fatal(err)
+			ci.logger.Error("failed to handle block", zap.Error(err))
+			return err
 		}
 
 		height++
@@ -157,8 +158,5 @@ func (ci *CoreIndexer) handleManageEntity(dbTx dbv1.DBTX, logger *zap.Logger, em
 
 func (ci *CoreIndexer) Close() {
 	ci.pool.Close()
-	err := ci.logger.Sync()
-	if err != nil {
-		ci.logger.Error("failed to sync logger", zap.Error(err))
-	}
+	ci.logger.Sync()
 }