EVM event subscription should reconnect on the last received height

m-Peter · m-Peter · commit 418fe700e2ac · 2025-11-12T12:47:15.000+02:00
diff --git a/services/ingestion/event_subscriber.go b/services/ingestion/event_subscriber.go
@@ -232,11 +232,11 @@ func (r *RPCEventSubscriber) subscribe(ctx context.Context, height uint64) <-cha
 					return
 				}
 
-				if err := connect(lastReceivedHeight + 1); err != nil {
+				if err := connect(lastReceivedHeight); err != nil {
 					eventsChan <- models.NewBlockEventsError(
 						fmt.Errorf(
 							"failed to resubscribe for events on height: %d, with: %w",
-							lastReceivedHeight+1,
+							lastReceivedHeight,
 							err,
 						),
 					)

Original file line number	Diff line number	Diff line change
`@@ -232,11 +232,11 @@ func (r *RPCEventSubscriber) subscribe(ctx context.Context, height uint64) <-cha`
`232`	`232`	`return`
`233`	`233`	`}`
`234`	`234`
`235`		`- if err := connect(lastReceivedHeight + 1); err != nil {`
	`235`	`+ if err := connect(lastReceivedHeight); err != nil {`
`236`	`236`	`eventsChan <- models.NewBlockEventsError(`
`237`	`237`	`fmt.Errorf(`
`238`	`238`	`"failed to resubscribe for events on height: %d, with: %w",`
`239`		`- lastReceivedHeight+1,`
	`239`	`+ lastReceivedHeight,`
`240`	`240`	`err,`
`241`	`241`	`),`
`242`	`242`	`)`