feat: add rpc admin namespace draft

Author: PhilippLgh

lib/rpc/modules/admin.ts

@@ -0,0 +1,68 @@
+import { bufferToHex } from 'ethereumjs-util'
+import { getClientVersion } from '../../util'
+import { middleware } from '../validation'
+
+/**
+ * admin_* RPC module
+ * @memberof module:rpc/modules
+ */
+class Admin {
+  /**
+   * Create admin_* RPC module
+   * @param {Node} Node to which the module binds
+   */
+  constructor(node) {
+    const service = node.services.find(s => s.name === 'eth')
+    this._chain = service.chain
+    this._node = node
+    this._ethProtocol = service.protocols.find(p => p.name === 'eth')
+
+    this.nodeInfo = middleware(this.nodeInfo.bind(this), 0, [])
+  }
+
+  /**
+   * Returns information about the currently running node.
+   * see for reference: https://geth.ethereum.org/docs/rpc/ns-admin#admin_nodeinfo 
+   * @param {*} [params] An empty array
+   * @param {*} [cb] A function with an error object as the first argument and the
+   */
+  async nodeInfo(params, cb) {
+    console.log('this._node', this._node)
+    const rlpxInfo = this._node.server('rlpx').getRlpxInfo()
+    const { enode, id, ip, listenAddr, ports } = rlpxInfo
+    const { discovery, listener } = ports
+    const clientName = getClientVersion()
+
+    // TODO version not present in reference..
+    // const ethVersion = Math.max.apply(Math, this._ethProtocol.versions)
+    // TODO _chain._headers might be undefined
+    const latestHeader = this._chain._headers.latest
+    const difficulty = latestHeader.difficulty // should be number
+    const genesis = bufferToHex(this._chain.genesis.hash)
+    const head = bufferToHex(latestHeader.mixHash)
+    const network = this._chain.networkId
+
+    const nodeInfo = {
+      name: clientName,
+      enode,
+      id,
+      ip,
+      listenAddr,
+      ports: {
+        discovery,
+        listener
+      },
+      protocols: {
+        eth: {
+          difficulty,
+          genesis,
+          head,
+          network
+        }
+      }
+    }
+    return cb(null, nodeInfo)
+  }
+}
+
+module.exports = Admin

lib/rpc/modules/index.ts

@@ -1,4 +1,4 @@
-export const list = ['Eth', 'Web3', 'Net']
 export * from './eth'
 export * from './web3'
 export * from './net'
+export * from './admin'

test/rpc/admin/nodeInfo.ts

@@ -0,0 +1,23 @@
+import tape from 'tape'
+import { startRPC, createManager, createNode, params, baseRequest } from '../helpers'
+
+const method = 'admin_nodeInfo'
+
+tape(method, (t) => {
+  const manager = createManager(createNode({ opened: true }))
+  const server = startRPC(manager.getMethods())
+
+  const req = params(method, [])
+
+  const expectRes = (res: any) => {
+    const msg = 'should return the correct info'
+    const { result } = res.body
+    if (result) {
+      t.pass(msg)
+    } else {
+      throw new Error(msg)
+    }
+  }
+  baseRequest(t, server, req, 200, expectRes)
+})
+

test/rpc/helpers.ts

@@ -6,6 +6,7 @@ import { RPCManager as Manager } from '../../lib/rpc'
 import * as Logger from '../../lib/logging'
 import { blockChain } from './blockChainStub'
 import { Chain } from '../../lib/blockchain/chain'
+import RlpxServer from '../../lib/net/server/rlpxserver'
 import Blockchain from '@ethereumjs/blockchain'
 
 const config: any = { loglevel: 'error' }
@@ -36,6 +37,11 @@ export function createNode(nodeConfig?: any) {
     ethProtocolVersions: [63],
   }
   const trueNodeConfig = { ...defaultNodeConfig, ...nodeConfig }
+  const servers = [
+    new RlpxServer({
+      bootnodes: '10.0.0.1:1234,10.0.0.2:1234'
+    })
+  ]
   return {
     services: [
       {
@@ -50,8 +56,12 @@ export function createNode(nodeConfig?: any) {
         ],
       },
     ],
+    servers,
     common: trueNodeConfig.commonChain,
     opened: trueNodeConfig.opened,
+    server: (name: string) => {
+      return servers.find(s => s.name === name)
+    }
   }
 }