Merge pull request #1049 from cardano-foundation/fix/slow-server-startup

fix: retry ada supply fetch on startup failure and stabilize ada test

Author: VladislavKudrin

packages/api-cardano-db-hasura/test/ada.query.test.ts

@@ -1,6 +1,7 @@
 import path from 'path'
 
 import { DocumentNode } from 'graphql'
+import pRetry from 'p-retry'
 import util from '@cardano-graphql/util'
 import { TestClient } from '@cardano-graphql/util-dev'
 import { testClient } from './util'
@@ -23,16 +24,17 @@ describe('ada', () => {
   })
 
   it('returns ada supply information', async () => {
-    const result = await client.query({
-      query: await loadQueryNode('adaSupply')
-    })
+    const query = await loadQueryNode('adaSupply')
+    const result = await pRetry(
+      () => client.query({ query }),
+      { retries: 40, minTimeout: 3000, factor: 1 }
+    )
     const { ada } = result.data
     const circulatingSupply = new BigNumber(ada.supply.circulating).toNumber()
     const maxSupply = new BigNumber(ada.supply.max).toNumber()
     const totalSupply = new BigNumber(ada.supply.total).toNumber()
     expect(maxSupply).toEqual(genesis.shelley.maxLovelaceSupply)
     expect(maxSupply).toBeGreaterThan(circulatingSupply)
-    // expect(totalSupply).toBeGreaterThan(circulatingSupply)
     expect(totalSupply).toBeLessThan(maxSupply)
   })
 })

packages/util/src/data_fetching/DataFetcher.ts

@@ -2,6 +2,9 @@ import { FetchFunction } from './index'
 import { clearIntervalAsync, setIntervalAsync, SetIntervalAsyncTimer } from 'set-interval-async/dynamic'
 import { dummyLogger, Logger } from 'ts-log'
 
+const INITIAL_FETCH_RETRY_INTERVAL = 15000
+const INITIAL_FETCH_MAX_ATTEMPTS = 40
+
 export class DataFetcher<DataValue> {
   private pollingQueryTimer: SetIntervalAsyncTimer
   private fetch: () => Promise<void>
@@ -29,6 +32,12 @@ export class DataFetcher<DataValue> {
 
   public async initialize () {
     await this.fetch()
+    let initialAttempts = 0
+    while (this.value === undefined && initialAttempts < INITIAL_FETCH_MAX_ATTEMPTS) {
+      initialAttempts++
+      await new Promise(resolve => setTimeout(resolve, INITIAL_FETCH_RETRY_INTERVAL))
+      await this.fetch()
+    }
     this.logger.debug({ module: 'DataFetcher', instance: this.name, value: this.value }, 'Initial value fetched')
     this.pollingQueryTimer = setIntervalAsync(async () => {
       await this.fetch()