@@ -81,6 +81,7 @@ export const calculateStaggerTimeMs = (
81
81
} ;
82
82
83
83
export const readActiveDataFeedBatch = async (
84
+ provider : ethers . JsonRpcProvider ,
84
85
airseekerRegistry : AirseekerRegistry ,
85
86
chainId : string ,
86
87
fromIndex : number ,
@@ -130,7 +131,11 @@ export const readActiveDataFeedBatch = async (
130
131
return isRegistered ;
131
132
} ) ;
132
133
133
- const blockNumber = decodeGetBlockNumberResponse ( getBlockNumberReturndata ! ) ;
134
+ // NOTE: https://api3workspace.slack.com/archives/C05TQPT7PNJ/p1713441156074839?thread_ts=1713438669.278119&cid=C05TQPT7PNJ
135
+ const blockNumber =
136
+ chainId === '42161' || chainId === '421614'
137
+ ? await provider . getBlockNumber ( )
138
+ : decodeGetBlockNumberResponse ( getBlockNumberReturndata ! ) ;
134
139
135
140
return {
136
141
batch,
@@ -160,7 +165,7 @@ export const runUpdateFeeds = async (providerName: ProviderName, chain: Chain, c
160
165
logger . debug ( `Fetching first batch of data feeds batches.` ) ;
161
166
const firstBatchStartTimeMs = Date . now ( ) ;
162
167
const goFirstBatch = await go (
163
- async ( ) => readActiveDataFeedBatch ( airseekerRegistry , chainId , 0 , dataFeedBatchSize ) ,
168
+ async ( ) => readActiveDataFeedBatch ( provider , airseekerRegistry , chainId , 0 , dataFeedBatchSize ) ,
164
169
{ totalTimeoutMs : dataFeedUpdateIntervalMs }
165
170
) ;
166
171
if ( ! goFirstBatch . success ) {
@@ -205,6 +210,7 @@ export const runUpdateFeeds = async (providerName: ProviderName, chain: Chain, c
205
210
const dataFeedBatchIndexStart = batchIndex * dataFeedBatchSize ;
206
211
const dataFeedBatchIndexEnd = Math . min ( activeDataFeedCount ! , dataFeedBatchIndexStart + dataFeedBatchSize ) ;
207
212
const activeBatch = await readActiveDataFeedBatch (
213
+ provider ,
208
214
airseekerRegistry ,
209
215
chainId ,
210
216
dataFeedBatchIndexStart ,
0 commit comments