Merge pull request #520 from khaihkd/master

update logger

server/src/api/AccountController.js

@@ -21,7 +21,7 @@ AccountController.get('/accounts', async (req, res) => {
 
         return res.json(data)
     } catch (e) {
-        logger.error(e)
+        logger.warn(e)
         return res.status(500).send()
     }
 })

server/src/crawl.js

@@ -73,8 +73,8 @@ let watch = async () => {
             }
         }
     } catch (e) {
-        logger.error(e)
-        logger.error('Sleep 2 seconds before going back to work')
+        logger.warn(e)
+        logger.warn('Sleep 2 seconds before going back to work')
         await sleep(2000)
         return watch()
     }

server/src/helpers/account.js

@@ -15,7 +15,8 @@ let AccountHelper = {
 
         web3.eth.getBalance(hash, function (err, balance) {
             if (err) {
-                logger.error(err)
+                logger.warn('get balance of account %s has error', hash)
+                logger.warn(err)
             } else {
                 _account.balance = balance
                 _account.balanceNumber = balance
@@ -49,7 +50,8 @@ let AccountHelper = {
 
             web3.eth.getBalance(hash, function (err, balance) {
                 if (err) {
-                    logger.error(err)
+                    logger.warn('get balance of account %s has error', hash)
+                    logger.warn(err)
                 } else {
                     _account.balance = balance
                     _account.balanceNumber = balance
@@ -80,7 +82,7 @@ let AccountHelper = {
             await db.Account.updateOne({ hash: hash }, _account,
                 { upsert: true, new: true })
         } catch (e) {
-            logger.error(e)
+            logger.warn(e)
         }
     },
     async formatAccount (account) {

server/src/helpers/block.js

@@ -113,7 +113,8 @@ let BlockHelper = {
 
             return block
         } catch (e) {
-            logger.error(e)
+            logger.warn(e)
+            logger.warn('cannot get block %s', hashOrNumber)
             return {}
         }
     },
@@ -150,7 +151,7 @@ let BlockHelper = {
 
             return _block
         } catch (e) {
-            logger.error(e)
+            logger.warn(e)
             return {}
         }
     },

server/src/helpers/tomo.js

@@ -14,7 +14,7 @@ let blockSigner = {
     getSigners: async (blockHash) => {
         let bs = await blockSigner.getBlockSignerContract()
         return bs.methods.getSigners(blockHash).call().catch(e => {
-            logger.error('Cannot get signer of block %s. Sleep 2 seconds and try more', blockHash)
+            logger.warn('Cannot get signer of block %s. Sleep 2 seconds and try more', blockHash)
             return sleep(2000).then(() => {
                 return blockSigner.getSigners(blockHash)
             })
@@ -33,7 +33,7 @@ let tomoValidator = {
     getCandidateOwner: async (candidate) => {
         let tc = await tomoValidator.getValidatorContract()
         return tc.methods.getCandidateOwner(candidate).call().catch(e => {
-            logger.error('cannot get owner of candidate %s. Sleep 2 seconds and try more', candidate)
+            logger.warn('cannot get owner of candidate %s. Sleep 2 seconds and try more', candidate)
             return sleep(2000).then(() => {
                 return tomoValidator.getCandidateOwner(candidate)
             })
@@ -42,7 +42,7 @@ let tomoValidator = {
     getVoterCapacity: async (candidate, voter) => {
         let tc = await tomoValidator.getValidatorContract()
         return tc.methods.getVoterCap(candidate, voter).call().catch(e => {
-            logger.error('cannot get owner of candidate %s. Sleep 2 seconds and try more', candidate)
+            logger.warn('cannot get owner of candidate %s. Sleep 2 seconds and try more', candidate)
             return sleep(2000).then(() => {
                 return tomoValidator.getVoterCapacity(candidate, voter)
             })

server/src/helpers/transaction.js

@@ -122,7 +122,8 @@ let TransactionHelper = {
             await db.Tx.updateOne({ hash: hash }, tx,
                 { upsert: true, new: true })
         } catch (e) {
-            logger.error(e)
+            logger.warn('cannot crawl transaction %s', hash)
+            logger.warn(e)
         }
     },
     getTxDetail: async (hash) => {

server/src/queues/rewardValidator.js

@@ -125,7 +125,7 @@ consumer.task = async function (job, done) {
             await db.Reward.insertMany(rewardValidator)
         }
     } catch (e) {
-        logger.error(e)
+        logger.warn(e)
         done(e)
     }
 

server/src/queues/rewardVoter.js

@@ -61,7 +61,7 @@ consumer.task = async function (job, done) {
             await db.Reward.insertMany(rewardVoter)
         }
     } catch (e) {
-        logger.error(e)
+        logger.warn(e)
         done(e)
     }
 

server/src/queues/token.js

@@ -49,7 +49,7 @@ consumer.task = async function (job, done) {
         token.status = true
         token.save()
     } catch (e) {
-        logger.error(e)
+        logger.warn(e)
         done(e)
     }
 

server/src/queues/tokenHolder.js

@@ -20,7 +20,7 @@ consumer.task = async function (job, done) {
         // Add holder to.
         await TokenHolderHelper.updateQuality(token.to, token.address, token.value)
     } catch (e) {
-        logger.error(e)
+        logger.warn(e)
         done(e)
     }
 

server/src/queues/tokenTransaction.js

@@ -48,7 +48,7 @@ consumer.task = async function (job, done) {
             .priority('normal').removeOnComplete(true)
             .attempts(5).backoff({ delay: 2000, type: 'fixed' }).save()
     } catch (e) {
-        logger.error(e)
+        logger.warn(e)
         done(e)
     }
 

server/src/queues/updateBlockFinality.js

@@ -1,28 +1,27 @@
 'use strict'
 
 const db = require('../models')
-const Web3 = require('../helpers/web3')
 const logger = require('../helpers/logger')
+const BlockHelper = require('../helpers/block')
 
 const consumer = {}
 consumer.name = 'BlockFinalityProcess'
 consumer.processNumber = 1
 consumer.task = async function (job, done) {
-    let web3 = await Web3.getWeb3()
     let blocks = await db.Block.find({ finality: { $lt: 50 }, updateFinalityTime: { $lt: 10 } })
         .sort({ number: -1 }).limit(500)
     logger.info('Update finality %s blocks', blocks.length)
     try {
         let map = blocks.map(async function (block) {
-            let b = await web3.eth.getBlock(block.number)
+            let b = await BlockHelper.getBlock(block.number)
             block.finality = b.hasOwnProperty('finality') ? parseInt(b.finality) : 0
             block.updateFinalityTime = block.updateFinalityTime ? block.updateFinalityTime + 1 : 1
             block.save()
         })
         await Promise.all(map)
         done()
     } catch (e) {
-        logger.error(e)
+        logger.warn(e)
         done(e)
     }
 }