Use GetLastConfirmedBlockNum to set checkForMissedEvents startBlock

statechannels · Oct 9, 2023 · 3b27f46 · 3b27f46
1 parent 471e0d7
commit 3b27f46
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/node/engine/chainservice/eth_chainservice.go b/node/engine/chainservice/eth_chainservice.go
@@ -372,11 +372,11 @@ func (ecs *EthChainService) listenForEventLogs(errorChan chan<- error, eventChan
 			return
 
 		case err := <-ecs.eventSub.Err():
+			latestBlockNum := ecs.GetLastConfirmedBlockNum()
+
 			ecs.eventTracker.mu.Lock()
 			defer ecs.eventTracker.mu.Unlock()
 
-			latestBlockNum := ecs.eventTracker.latestBlockNum
-
 			if err != nil {
 				ecs.logger.Warn("error in chain event subscription: " + err.Error())
 				ecs.eventSub.Unsubscribe()