Change ingestion lag warn time

internal/services/ingest.go

@@ -23,7 +23,7 @@ import (
 const (
 	rpcHealthCheckSleepTime      = 5 * time.Second
 	rpcHealthCheckMaxWaitTime    = 60 * time.Second
-	ingestHealthCheckMaxWaitTime = 60 * time.Second
+	ingestHealthCheckMaxWaitTime = 90 * time.Second
 )
 
 type IngestService interface {

internal/services/ingest_test.go

@@ -233,10 +233,16 @@ func TestIngest_LatestSyncedLedgerBehindRPC(t *testing.T) {
 	defer dbConnectionPool.Close()
 
 	models, _ := data.NewModels(dbConnectionPool)
+	mockAppTracker := apptracker.MockAppTracker{}
 	mockRPCService := RPCServiceMock{}
 	mockRouter := tssrouter.MockRouter{}
-	tssStore, _ := tssstore.NewStore(dbConnectionPool)
-	ingestService, _ := NewIngestService(models, "ingestionLedger", nil, &mockRPCService, &mockRouter, tssStore)
+
+	tssStore, err := tssstore.NewStore(dbConnectionPool)
+	require.NoError(t, err)
+
+	ingestService, err := NewIngestService(models, "ingestionLedger", &mockAppTracker, &mockRPCService, &mockRouter, tssStore)
+	require.NoError(t, err)
+
 	srcAccount := keypair.MustRandom().Address()
 	destAccount := keypair.MustRandom().Address()
 
@@ -283,6 +289,7 @@ func TestIngest_LatestSyncedLedgerBehindRPC(t *testing.T) {
 		OldestLedgerCloseTime: int64(1),
 	}
 	mockRPCService.On("GetTransactions", int64(50), "", 50).Return(mockResult, nil).Once()
+	//mockAppTracker.On("CaptureMessage", "ingestion service stale for over 1m0s").Maybe()
 
 	err = ingestService.Run(context.Background(), uint32(49), uint32(50))
 	require.NoError(t, err)
@@ -299,7 +306,9 @@ func TestTrackRPCServiceHealth_HealthyService(t *testing.T) {
 	mockRPCService := &RPCServiceMock{}
 	mockAppTracker := &apptracker.MockAppTracker{}
 	heartbeat := make(chan entities.RPCGetHealthResult, 1)
-	ctx := context.Background()
+
+	ctx, cancel := context.WithTimeout(context.Background(), 70*time.Second)
+	defer cancel()
 
 	healthResult := entities.RPCGetHealthResult{
 		Status:                "healthy",
@@ -309,7 +318,14 @@ func TestTrackRPCServiceHealth_HealthyService(t *testing.T) {
 	}
 	mockRPCService.On("GetHealth").Return(healthResult, nil)
 
-	go trackRPCServiceHealth(ctx, heartbeat, mockAppTracker, mockRPCService)
+	go func() {
+		select {
+		case <-ctx.Done():
+			return
+		default:
+			trackRPCServiceHealth(context.Background(), heartbeat, nil, mockRPCService)
+		}
+	}()
 
 	select {
 	case result := <-heartbeat: