chore: quick fix (#170)

* chore: quick fix * chore: remove node linker
mangata-finance · Jul 8, 2024 · f80f1b2 · f80f1b2
1 parent 81bf655
commit f80f1b2
Show file tree

Hide file tree

Showing 5 changed files with 248 additions and 381 deletions.
diff --git a/stash-dev/src/repository/ChainRepository.ts b/stash-dev/src/repository/ChainRepository.ts
@@ -14,7 +14,7 @@ const keyPool = (id: number) => PREFIX_POOL + id
 
 const FIRST_POOL_BLOCK = 251216
 const BLOCK_DECEMBER_2023 = 3_750_000 // 2 december 2023
-const ROLLUP_STARTER_BLOCK = 80000
+const ROLLUP_STARTER_BLOCK = 0 //8 July 2024
 const BATCH = 300 * 12 * 1000 // ~= 1 hour of blocks
 
 export const LIMIT = 10_000

diff --git a/stash-dev/src/server.ts b/stash-dev/src/server.ts
@@ -34,7 +34,7 @@ const server = app.listen(app.get('port'), async () => {
   const run = 1
   while (run) {
     await new Promise((f) => setTimeout(f, BLOCK_TIME * 10))
-    await poolRatesService.initService()
+    // await poolRatesService.initService()
     await priceService.initService()
     await volumeService.initService()
     await tradesService.initService()

diff --git a/stash-dev/src/service/SyncBlockService.ts b/stash-dev/src/service/SyncBlockService.ts
@@ -3,17 +3,26 @@ import * as store from '../repository/ChainRepository.js'
 import * as blocks from '../scraper/BlockScraper.js'
 import * as pools from '../scraper/PoolsScraper.js'
 import * as staking from '../scraper/StakingScraper.js'
+import logger from '../util/Logger.js'
 
 export const initService = async () => {
+  console.log('init service called')
   const api = await MangataClient.api()
 
   const latestBlock = (await store.getLatest()).block
   // const latestBlock = 3719278
   await blocks.withBlocks(api, latestBlock, async (block) => {
-    await blocks.processEvents(block)
-    await pools.fetchPools(block)
-    await staking.processStaking(api, block)
-    await staking.processLiquidStaking(api, block)
-    await store.saveLatest({ timestamp: block.timestamp, block: block.number })
+    try {
+      // await blocks.processEvents(block)
+      // await pools.fetchPools(block)
+      // await staking.processStaking(api, block)
+      // await staking.processLiquidStaking(api, block)
+      // await store.saveLatest({
+      //   timestamp: block.timestamp,
+      //   block: block.number,
+      // })
+    } catch (e) {
+      logger.error('Error in processing block: ', e)
+    }
   })
 }
diff --git a/stash-dev/src/util/Chain.ts b/stash-dev/src/util/Chain.ts
@@ -3,8 +3,8 @@ import { Codec } from '@polkadot/types/types'
 import { blake2AsHex } from '@polkadot/util-crypto'
 import _ from 'lodash'
 
-export const GETH = 5
-export const KSM = 4
+export const GETH = 1
+export const KSM = 1
 export const BASE_TOKEN = process.env.APP_ENV === 'rollup-dev' ? GETH : KSM
 
 export type CodecOrArray = Codec | Codec[]