From 52e56097e1430df32508a8dfcc44616016a211ef Mon Sep 17 00:00:00 2001 From: Gurjot Date: Fri, 6 Dec 2024 12:31:45 +0530 Subject: [PATCH] fix timeout --- internal/shared/db/model/setup.go | 4 ++-- internal/v2/queue/handler/stats.go | 2 +- internal/v2/queue/queue.go | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/internal/shared/db/model/setup.go b/internal/shared/db/model/setup.go index 62420e6..d2516cb 100644 --- a/internal/shared/db/model/setup.go +++ b/internal/shared/db/model/setup.go @@ -59,9 +59,9 @@ var collections = map[string][]index{ V1BtcInfoCollection: {{Indexes: map[string]int{}}}, // V2 V2StatsLockCollection: {{Indexes: map[string]int{}}}, - V2StakerStatsCollection: {{Indexes: map[string]int{}}}, - V2FinalityProviderStatsCollection: {{Indexes: map[string]int{"active_tvl": -1}, Unique: false}}, V2OverallStatsCollection: {{Indexes: map[string]int{}}}, + V2FinalityProviderStatsCollection: {{Indexes: map[string]int{"active_tvl": -1}, Unique: false}}, + V2StakerStatsCollection: {{Indexes: map[string]int{"active_tvl": -1}, Unique: false}}, } func Setup(ctx context.Context, cfg *config.Config) error { diff --git a/internal/v2/queue/handler/stats.go b/internal/v2/queue/handler/stats.go index 7f9b0dc..4a29705 100644 --- a/internal/v2/queue/handler/stats.go +++ b/internal/v2/queue/handler/stats.go @@ -23,7 +23,7 @@ func (h *V2QueueHandler) ActiveStakingHandler(ctx context.Context, messageBody s // Mark as v1 delegation as transitioned if it exists if err := h.Services.V2Service.MarkV1DelegationAsTransitioned(ctx, activeStakingEvent.StakingTxHashHex); err != nil { log.Ctx(ctx).Error().Err(err).Msg("Failed to mark v1 delegation as transitioned") - return err + return types.NewError(http.StatusInternalServerError, types.InternalServiceError, err) } // TODO: Perform the address lookup conversion diff --git a/internal/v2/queue/queue.go b/internal/v2/queue/queue.go index 0deda0d..81af62a 100644 --- a/internal/v2/queue/queue.go +++ b/internal/v2/queue/queue.go @@ -43,7 +43,7 @@ func New(cfg *queueConfig.QueueConfig, service *services.Services) *Queues { handlers := v2queuehandler.NewV2QueueHandler(service) return &Queues{ Handlers: handlers, - processingTimeout: time.Duration(cfg.QueueProcessingTimeout) * time.Second, + processingTimeout: cfg.QueueProcessingTimeout, maxRetryAttempts: cfg.MsgMaxRetryAttempts, ActiveStakingQueueClient: activeStakingQueueClient, UnbondingStakingQueueClient: unbondingStakingQueueClient,