update postdeploy

Author: apexearth

package.json

@@ -27,7 +27,7 @@
     "process:hyperevm": "sqd process:hyperevm",
     "process:test": "sqd process:test",
     "process": "sqd process",
-    "generate:validations": "ts-node --require tsconfig-paths/register scripts/generate-validations.ts",
+    "generate:validations": "ts-node --require ./scripts/register-js-ts.js --require tsconfig-paths/register scripts/generate-validations.ts",
     "log:processing-times": "ts-node --require tsconfig-paths/register scripts/check-processing-times.ts",
     "postdeploy": "sh -c 'pnpm run log:processing-times $1 && pnpm run generate:validations $1 $2' --",
     "lint": "eslint \"src/**/*.ts\"",

processing-times.log

@@ -1,15 +1,15 @@
 Processing Times
 ==============================
-Version: v151
-Date: 2026-05-06T20:05:42.986Z
+Version: v152
+Date: 2026-05-15T00:51:32.161Z
 ==============================
-arbitrum: 163.19 minutes
-base: 366.49 minutes
-hyperevm: 1.05 minutes
-mainnet: 1400.86 minutes
-oeth: 46.49 minutes
-oethb: 127.09 minutes
-ogv: 48.61 minutes
-os: 32.96 minutes
-ousd: 53.24 minutes
-sonic: 98.72 minutes
+arbitrum: 5.39 minutes
+base: 135.17 minutes
+hyperevm: 2.97 minutes
+mainnet: 112.76 minutes
+oeth: 11.52 minutes
+oethb: 15.47 minutes
+ogv: 40.91 minutes
+os: 29.61 minutes
+ousd: 30.61 minutes
+sonic: 77.74 minutes

scripts/generate-validations.ts

@@ -998,7 +998,7 @@ const bridging = () => {
       bridgeTransferStates: bridgeTransferStates(
         limit: ${LIMIT},
       orderBy: [blockNumber_ASC, id_ASC],
-      ) {  
+      ) {
         blockNumber
         id
         state
@@ -1255,48 +1255,62 @@ const main = async () => {
 
   console.log('Total queries:', queries.length)
 
-  for (let i = 0; i < queries.length; i++) {
-    const query = queries[i]
-    console.log(`Executing: \`${query.replace(/(\n|\s)+/g, ' ').slice(0, 80)}\`...`)
-    const result = await retry(() => executeQuery(query), 5)
-    if (!result.data) {
-      console.log(result)
-      throw new Error('Query failed')
+  const runConcurrently = async (fns: (() => Promise<void>)[], concurrency: number) => {
+    const queue = [...fns]
+    while (queue.length > 0) {
+      const batch = queue.splice(0, concurrency)
+      await Promise.all(batch.map((fn) => fn()))
     }
+  }
 
-    const takeAll = ['ognDailyStats']
-    for (const key of Object.keys(result.data)) {
-      let validationData
-      const rawData = result.data[key]
-
-      // If there are fewer than 20 total entries, save them all
-      if (rawData.length < 20 || takeAll.includes(key)) {
-        validationData = rawData
-      } else if (key === 'exchangeRates' || key === 'exchangeRateDailies') {
-        // Special handling for exchange rates: ensure at least one of every pair
-        validationData = takeExchangeRateValidationEntries(rawData)
-      } else {
-        // Otherwise, filter to validation entries
-        validationData = takeValidationEntries(rawData)
-        if (validationData.length < 5) {
-          validationData = takeEvery(rawData, 50)
-        }
+  const fns: (() => Promise<void>)[] = []
+  for (let i = 0; i < queries.length; i++) {
+    const fn = async () => {
+      const query = queries[i]
+      console.log(`Executing: \`${query.replace(/(\n|\s)+/g, ' ').slice(0, 80)}\`...`)
+      const result = await retry(() => executeQuery(query), 5)
+      if (!result.data) {
+        console.log(result)
+        throw new Error('Query failed')
       }
 
-      const filePath = getFilePathForEntity(key)
-      const dir = path.dirname(filePath)
+      const takeAll = ['ognDailyStats']
+      for (const key of Object.keys(result.data)) {
+        let validationData
+        const rawData = result.data[key]
+
+        // If there are fewer than 20 total entries, save them all
+        if (rawData.length < 20 || takeAll.includes(key)) {
+          validationData = rawData
+        } else if (key === 'exchangeRates' || key === 'exchangeRateDailies') {
+          // Special handling for exchange rates: ensure at least one of every pair
+          validationData = takeExchangeRateValidationEntries(rawData)
+        } else {
+          // Otherwise, filter to validation entries
+          validationData = takeValidationEntries(rawData)
+          if (validationData.length < 5) {
+            validationData = takeEvery(rawData, 50)
+          }
+        }
 
-      // Ensure directory exists
-      if (!fs.existsSync(dir)) {
-        fs.mkdirSync(dir, { recursive: true })
-      }
+        const filePath = getFilePathForEntity(key)
+        const dir = path.dirname(filePath)
+
+        // Ensure directory exists
+        if (!fs.existsSync(dir)) {
+          fs.mkdirSync(dir, { recursive: true })
+        }
 
-      // Write the file
-      fs.writeFileSync(filePath, JSON.stringify(validationData, null, 2))
-      console.log(`  ✓ Wrote ${validationData.length} entries to ${path.relative(__dirname + '/..', filePath)}`)
+        // Write the file
+        fs.writeFileSync(filePath, JSON.stringify(validationData, null, 2))
+        console.log(`  ✓ Wrote ${validationData.length} entries to ${path.relative(__dirname + '/..', filePath)}`)
+      }
     }
+    fns.push(fn)
   }
 
+  await runConcurrently(fns, 10)
+
   console.log('\n✓ All validation files generated successfully')
 }