Fixed #17: Implemented eth_getBlockByNumber()

lib/chain/ChainManager.js

@@ -93,6 +93,10 @@ class ChainManager {
       })
     }
   }
+
+  getBlockchain () {
+    return this._blockchain
+  }
 }
 
 module.exports = ChainManager

lib/cliParser.js

@@ -11,6 +11,13 @@ var parser = require('yargs')
     choices: ['error', 'warn', 'info', 'debug'],
     default: 'info'
   })
+  .option('rpc', {
+    describe: 'Enable the JSON-RPC server'
+  })
+  .option('rpcport', {
+    describe: 'HTTP-RPC server listening port',
+    default: 8545
+  })
   .locale('en_EN')
 
 parser.getClientConfig = function () {

lib/index.js

@@ -3,6 +3,7 @@ const Common = require('ethereumjs-common')
 const Logger = require('./logging.js')
 const EthNetworkManager = require('./net/EthNetworkManager.js')
 const ChainManager = require('./chain/ChainManager.js')
+const RPCServer = require('./rpc')
 
 function runClient () {
   const cliParser = require('./cliParser.js')
@@ -16,12 +17,17 @@ function runClient () {
 
   const logger = config.logger
   logger.info('ethereumjs-client initialized')
-  logger.info('Connecting to the %s network', config.common.chainName())
+  // logger.info('Connecting to the %s network', config.common.chainName())
 
   const PRIVATE_KEY = randomBytes(32)
   var nm = new EthNetworkManager(PRIVATE_KEY, config)
 
   var cm = new ChainManager(config, nm) // eslint-disable-line
+
+  if (config.rpc) {
+    const rpc = new RPCServer(cm.getBlockchain())
+    rpc.listen(config.rpcport)
+  }
 }
 
 runClient()

lib/rpc/index.js

@@ -0,0 +1,36 @@
+const http = require('http')
+const RPCManager = require('./rpc-manager')
+
+class RPCServer {
+  constructor (chain) {
+    this._manager = new RPCManager(chain)
+    this._server = http.createServer(this._requestHandler.bind(this))
+  }
+
+  listen (port) {
+    this._server.listen(port)
+  }
+
+  _requestHandler (req, res) {
+    let body = []
+    req.on('data', chunk => body.push(chunk))
+    req.on('end', () => {
+      body = JSON.parse(Buffer.concat(body).toString())
+      this._manager.execute(body, (err, result) => {
+        let response = result
+        let code = 200
+
+        if (err) {
+          code = 406
+          const { message } = err
+          response = { code, message }
+        }
+
+        res.writeHead(code, { 'Content-Type': 'application/json' })
+        res.end(JSON.stringify(response))
+      })
+    })
+  }
+}
+
+module.exports = RPCServer

lib/rpc/modules/eth.js

@@ -0,0 +1,15 @@
+class Eth {
+  constructor (chain) {
+    this._chain = chain
+  }
+
+  getBlockByNumber (params, cb) {
+    let [blockNumber] = params
+    blockNumber = Number.parseInt(blockNumber, 16)
+    this._chain.getBlock(blockNumber, (err, block) => {
+      cb(err, block.toJSON(true))
+    })
+  }
+}
+
+module.exports = Eth

lib/rpc/modules/index.js

@@ -0,0 +1,3 @@
+const Eth = require('./eth')
+
+module.exports = { Eth }

lib/rpc/rpc-manager.js

@@ -0,0 +1,21 @@
+const modules = require('./modules')
+
+class RPCServer {
+  constructor (chain) {
+    this._chain = chain
+    this._modules = {}
+
+    // should be 'Eth', 'EVM', etc.
+    const moduleList = ['Eth']
+    moduleList.forEach(moduleName => {
+      this._modules[moduleName.toLowerCase()] = new modules[moduleName](this._chain)
+    })
+  }
+
+  execute (req, cb) {
+    const [moduleName, methodName] = req.method.split('_')
+    this._modules[moduleName][methodName](req.params, cb)
+  }
+}
+
+module.exports = RPCServer

package.json

@@ -42,6 +42,7 @@
   "devDependencies": {
     "coveralls": "^3.0.0",
     "nyc": "~11.6.0",
+    "sinon": "^6.0.0",
     "standard": "~11.0.1",
     "tape": "~4.9.0"
   }

tests/rpc.js

@@ -0,0 +1,27 @@
+const test = require('tape')
+const sinon = require('sinon')
+const Manager = require('../lib/rpc/rpc-manager')
+
+test('eth_getBlockByNumber', t => {
+  const block = {
+    toJSON: sinon.stub().returns({})
+  }
+  const blockchain = {
+    getBlock: sinon.stub().yields(null, block)
+  }
+  const manager = new Manager(blockchain)
+  const req = {
+    jsonrpc: '2.0',
+    method: 'eth_getBlockByNumber',
+    params: ['0x1', true],
+    id: 1
+  }
+
+  t.false(blockchain.getBlock.called)
+  manager.execute(req, (err, block) => {
+    t.error(err)
+    t.true(blockchain.getBlock.called)
+    t.equal(blockchain.getBlock.firstCall.args[0], 1)
+    t.end()
+  })
+})