feat: add check for eth provider availability (#402)

src/blockchain/index.ts

@@ -11,11 +11,16 @@ import { ReorgEmitterService, NewBlockEmitterService, ConfirmatorService } from
 
 const logger = loggingFactory('blockchain')
 
-export function ethFactory (): Eth {
+export async function ethFactory (): Promise<Eth> {
   const provider = Eth.givenProvider || config.get('blockchain.provider')
   logger.info(`Connecting to provider ${provider}`)
-
-  return new Eth(provider)
+  const eth = new Eth(provider)
+  try {
+    await eth.getProtocolVersion()
+  } catch (e) {
+    throw new Error(`Can't connect to the node on address ${provider}`)
+  }
+  return eth
 }
 
 export async function web3eventsFactory (eth: Eth, sequelize: Sequelize): Promise<Web3Events> {
@@ -61,7 +66,7 @@ function subscribeAndEmitNewBlocks (app: Application, web3Events: Web3Events): v
 
 export default async function (app: Application): Promise<void> {
   await waitForReadyApp(app)
-  const eth = ethFactory()
+  const eth = await ethFactory()
   app.set('eth', eth)
 
   const sequelize = app.get('sequelize') as Sequelize

src/cli/precache.ts

@@ -53,7 +53,7 @@ ${formattedServices}`
     // Init Store
     await initStore(sequelize)
 
-    const eth = ethFactory()
+    const eth = await ethFactory()
     const web3events = await web3eventsFactory(eth, sequelize)
 
     const tasksDefinition = servicesToPreCache.map(

test/integration/utils.ts

@@ -183,7 +183,7 @@ export class TestingApp {
   }
 
   private async initBlockchainProvider (): Promise<void> {
-    this.eth = ethFactory()
+    this.eth = await ethFactory()
     const [owner, provider, consumer, ...accounts] = await this.eth.getAccounts()
     this.contractOwner = owner
     this.providerAddress = provider