diff --git a/consensus/bor/bor.go b/consensus/bor/bor.go index 790fe86cf587a0594c8a0ffef821a1b72b9ba77e..f456dc871c16d10f33c1d31e55a0633393eff96f 100644 --- a/consensus/bor/bor.go +++ b/consensus/bor/bor.go @@ -1075,10 +1075,6 @@ func (c *Bor) CommitStates( chain chainContext, ) error { number := header.Number.Uint64() - // lastSync, err := c.GenesisContractsClient.LastStateSyncTime(number - 1) - // if err != nil { - // return err - // } _lastStateID, err := c.GenesisContractsClient.LastStateId(number - 1) if err != nil { return err diff --git a/consensus/bor/rest.go b/consensus/bor/rest.go index 35ac91622fd02d1e90435a9969ed56ad75404121..43a4439fde659a19125d471748768b3d17954d77 100644 --- a/consensus/bor/rest.go +++ b/consensus/bor/rest.go @@ -45,10 +45,9 @@ func NewHeimdallClient(urlString string) (*HeimdallClient, error) { } func (h *HeimdallClient) FetchStateSyncEvents(fromID uint64, to int64) ([]*EventRecordWithTime, error) { - page := 1 eventRecords := make([]*EventRecordWithTime, 0) for { - queryParams := fmt.Sprintf("from-id=%d&to-time=%d&page=%d&limit=%d", fromID, to, page, stateFetchLimit) + queryParams := fmt.Sprintf("from-id=%d&to-time=%d&limit=%d", fromID, to, stateFetchLimit) log.Info("Fetching state sync events", "queryParams", queryParams) response, err := h.FetchWithRetry("clerk/event-record/list", queryParams) if err != nil { @@ -65,7 +64,7 @@ func (h *HeimdallClient) FetchStateSyncEvents(fromID uint64, to int64) ([]*Event if len(_eventRecords) < stateFetchLimit { break } - page++ + fromID += uint64(stateFetchLimit) } sort.SliceStable(eventRecords, func(i, j int) bool {