Merge pull request #268 from thanhson1085/master

readd signers

crawl.js

@@ -3,6 +3,7 @@
 const { Validator } = require('./models/blockchain/validator')
 const { BlockSigner } = require('./models/blockchain/blockSigner')
 const chain = require('./models/blockchain/chain')
+const config = require('config')
 const db = require('./models/mongodb')
 const q = require('./queues')
 const moment = require('moment')
@@ -162,6 +163,55 @@ async function getCurrentCandidates () {
     }
 }
 
+async function updateSigners (blk) {
+    try {
+        if (!blk) {
+            let latestBlockNumber = await chain.eth.blockNumber
+            let lastCheckpoint = latestBlockNumber - (latestBlockNumber % parseInt(config.get('blockchain.epoch')))
+            if (lastCheckpoint > 0) {
+                blk = await chain.eth.getBlock(lastCheckpoint)
+            } else {
+                return false
+            }
+        }
+        let buff = Buffer.from(blk.extraData.substring(2), 'hex')
+        let sbuff = buff.slice(32, buff.length - 65)
+        let signers = []
+        if (sbuff.length > 0) {
+            for (let i = 1; i <= sbuff.length / 20; i++) {
+                let address = sbuff.slice((i - 1) * 20, i * 20)
+                signers.push('0x' + address.toString('hex'))
+            }
+            await db.Signer.create({
+                networkId: config.get('blockchain.networkId'),
+                blockNumber: blk.number,
+                signers: signers
+            })
+        }
+        return signers
+    } catch (e) {
+        console.error(e)
+    }
+}
+
+function watchNewBlock () {
+    try {
+        chain.eth.filter('latest').watch(async (err, block) => {
+            if (err) {
+                emitter.emit('error', err)
+            }
+            try {
+                let blk = await chain.eth.getBlock('latest')
+                await updateSigners(blk)
+            } catch (e) {
+                console.error(e)
+            }
+        })
+    } catch (e) {
+        emitter.emit('error', e)
+    }
+}
+
 async function watchBlockSigner () {
     try {
         let bs = await BlockSigner.deployed()
@@ -204,9 +254,12 @@ async function watchBlockSigner () {
 
 watchBlockSigner()
 
-getCurrentCandidates().then(() => {
-    watchValidator()
-    watchBlockSigner()
+updateSigners(false).then(() => {
+    return getCurrentCandidates().then(() => {
+        watchNewBlock()
+        watchValidator()
+        watchBlockSigner()
+    })
 }).catch(e => {
     console.log('getCurrentCandidates', e)
     process.exit(1)