From 244bbb1f5307db2f49c60fc68171a17c290924d8 Mon Sep 17 00:00:00 2001 From: "Biru C. Sainju" Date: Mon, 2 Dec 2024 09:17:08 +0545 Subject: [PATCH] fixed issue with cursor not updated --- relayer/chains/steller/listener.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/relayer/chains/steller/listener.go b/relayer/chains/steller/listener.go index 6d4e9a6e..fa2a7ff7 100644 --- a/relayer/chains/steller/listener.go +++ b/relayer/chains/steller/listener.go @@ -44,13 +44,12 @@ func (p *Provider) Listener(ctx context.Context, lastProcessedTx relayertypes.La pollInterval = p.cfg.PollInterval } ticker := time.NewTicker(pollInterval) - var cursor string for { select { case <-ctx.Done(): return ctx.Err() case <-ticker.C: - eventFilter := p.getEventFilter(startSeq, cursor) + eventFilter := p.getEventFilter(startSeq, "") response, err := p.client.GetEvents(ctx, eventFilter) if err != nil { p.log.Warn("error occurred while fetching transactions", zap.Error(err)) @@ -63,7 +62,6 @@ func (p *Provider) Listener(ctx context.Context, lastProcessedTx relayertypes.La Height: msg.MessageHeight, Messages: []*relayertypes.Message{msg}, } } - cursor = ev.PagingToken } startSeq = response.LatestLedger }