fix: move current era check to be lazy operation

.gitignore

@@ -2,7 +2,7 @@
 *.npmrc
 *.nyc_output
 *coverage
-*d.ts
+*.d.ts
 !packages/api-cardano-db-hasura/src/blake2b.d.ts
 *dist/
 lerna-debug.log

packages/api-cardano-db-hasura/src/CardanoNodeClient.ts

@@ -46,6 +46,9 @@ export class CardanoNodeClient {
     if (this.state !== 'initialized') {
       throw new errors.ModuleIsNotInitialized(MODULE_NAME, 'getProtocolParams')
     }
+    if (!(await this.isInCurrentEra())) {
+      throw new errors.OperationRequiresNodeInCurrentEra('getProtocolParams')
+    }
     const protocolParams = await this.stateQueryClient.currentProtocolParameters()
     this.logger.debug({ module: MODULE_NAME, protocolParams }, 'getProtocolParams')
     return protocolParams
@@ -55,20 +58,15 @@ export class CardanoNodeClient {
     if (this.state !== null) return
     this.state = 'initializing'
     this.logger.info({ module: MODULE_NAME }, 'Initializing')
-    this.isInitialized = true
     await pRetry(async () => {
       const options = ogmiosConnectionConfig ? { connection: ogmiosConnectionConfig } : {}
-      this.stateQueryClient = await createStateQueryClient(options)
-      this.txSubmissionClient = await createTxSubmissionClient(options)
-      if (!(await this.isInCurrentEra())) {
-        this.logger.warn({ module: MODULE_NAME }, 'cardano-node is still synchronizing')
-        throw new Error()
-      }
+      this.stateQueryClient = await createStateQueryClient(this.logger.error, options)
+      this.txSubmissionClient = await createTxSubmissionClient(this.logger.error, options)
     }, {
-      factor: 1.5,
-      retries: 39,
+      factor: 1.2,
+      retries: 100,
       onFailedAttempt: util.onFailedAttemptFor(
-        'Establishing connection to cardano-node and ensuring state is in the expected era',
+        'Establishing connection to cardano-node',
         this.logger
       )
     })

packages/api-cardano-db-hasura/src/ChainFollower.ts

@@ -5,7 +5,6 @@ import {
   isMaryBlock,
   Schema
 } from '@cardano-ogmios/client'
-import { errors } from '@cardano-graphql/util'
 import { Config } from './Config'
 import { errors, RunnableModuleState } from '@cardano-graphql/util'
 import { Asset } from './graphql_types'

packages/api-cardano-db-hasura/src/HasuraClient.ts

@@ -1,4 +1,3 @@
-import util, { DataFetcher } from '@cardano-graphql/util'
 import { Schema } from '@cardano-ogmios/client'
 import { exec } from 'child_process'
 import util, { DataFetcher, ModuleState } from '@cardano-graphql/util'

packages/util/src/errors/OperationRequiresNodeInCurrentEra.ts

@@ -0,0 +1,8 @@
+import { CustomError } from 'ts-custom-error'
+
+export class OperationRequiresNodeInCurrentEra extends CustomError {
+  public constructor (operation: string) {
+    super()
+    this.message = `${operation} cannot be called until cardano-node's block sync is in the current era`
+  }
+}

packages/util/src/errors/index.ts

@@ -1,3 +1,4 @@
 export * from './HostDoesNotExist'
 export * from './MissingConfig'
 export * from './ModuleIsNotInitialized'
+export * from './OperationRequiresNodeInCurrentEra'