fix websocket connection

apis/candidates.js

@@ -3,7 +3,7 @@ const express = require('express')
 const axios = require('axios')
 const router = express.Router()
 const db = require('../models/mongodb')
-const web3 = require('../models/blockchain/web3')
+const web3 = require('../models/blockchain/web3rpc')
 const validator = require('../models/blockchain/validator')
 const HDWalletProvider = require('truffle-hdwallet-provider')
 const PrivateKeyProvider = require('truffle-privatekey-provider')

crawl.js

@@ -2,7 +2,7 @@
 
 const validator = require('./models/blockchain/validator')
 const blockSigner = require('./models/blockchain/blockSigner')
-const web3 = require('./models/blockchain/web3')
+const web3 = require('./models/blockchain/web3ws')
 const config = require('config')
 const db = require('./models/mongodb')
 const EventEmitter = require('events').EventEmitter

models/blockchain/blockSigner.js

@@ -1,7 +1,7 @@
 'use strict'
 
 const BlockSignerABI = require('../../build/contracts/BlockSigner')
-const web3 = require('./web3')
+const web3 = require('./web3ws')
 const config = require('config')
 const blockSigner = new web3.eth.Contract(BlockSignerABI.abi, config.get('blockchain.blockSignerAddress'))
 

models/blockchain/validator.js

@@ -1,7 +1,7 @@
 'use strict'
 
 const ValidatorABI = require('../../build/contracts/TomoValidator')
-const web3 = require('./web3')
+const web3 = require('./web3ws')
 const config = require('config')
 const validator = new web3.eth.Contract(ValidatorABI.abi, config.get('blockchain.validatorAddress'))
 

models/blockchain/web3ws.js

@@ -0,0 +1,18 @@
+'use strict'
+
+const Web3 = require('web3')
+const config = require('config')
+
+const provider = new Web3.providers.WebsocketProvider(config.get('blockchain.ws'))
+const web3 = new Web3(provider)
+
+const restart = function (e) {
+    console.error('Connection error', e)
+    console.error('Restart process')
+    process.exit(1)
+}
+
+provider.on('error', (e) => restart(e))
+provider.on('end', (e) => restart(e))
+
+module.exports = web3