Initial lint:fix

Author: cgewecke

bin/cli.ts

@@ -16,74 +16,73 @@ const fs = require('fs-extra')
 const networks = Object.entries(chains.names)
 const args = require('yargs')
   .options({
-    'network': {
+    network: {
       describe: `Network`,
-      choices: networks.map(n => n[1]),
-      default: networks[0][1]
+      choices: networks.map((n) => n[1]),
+      default: networks[0][1],
     },
     'network-id': {
       describe: `Network ID`,
-      choices: networks.map(n => parseInt(n[0])),
-      default: undefined
+      choices: networks.map((n) => parseInt(n[0])),
+      default: undefined,
     },
-    'syncmode': {
+    syncmode: {
       describe: 'Blockchain sync mode',
-      choices: [ 'light', 'fast' ],
-      default: 'fast'
+      choices: ['light', 'fast'],
+      default: 'fast',
     },
-    'lightserv': {
+    lightserv: {
       describe: 'Serve light peer requests',
       boolean: true,
-      default: false
+      default: false,
     },
-    'datadir': {
+    datadir: {
       describe: 'Data directory for the blockchain',
-      default: `${os.homedir()}/Library/Ethereum`
+      default: `${os.homedir()}/Library/Ethereum`,
     },
-    'transports': {
+    transports: {
       describe: 'Network transports',
       default: ['rlpx:port=30303', 'libp2p'],
-      array: true
+      array: true,
     },
-    'rpc': {
+    rpc: {
       describe: 'Enable the JSON-RPC server',
       boolean: true,
-      default: false
+      default: false,
     },
-    'rpcport': {
+    rpcport: {
       describe: 'HTTP-RPC server listening port',
       number: true,
-      default: 8545
+      default: 8545,
     },
-    'rpcaddr': {
+    rpcaddr: {
       describe: 'HTTP-RPC server listening interface',
-      default: 'localhost'
+      default: 'localhost',
     },
-    'loglevel': {
+    loglevel: {
       describe: 'Logging verbosity',
-      choices: [ 'error', 'warn', 'info', 'debug' ],
-      default: 'info'
+      choices: ['error', 'warn', 'info', 'debug'],
+      default: 'info',
     },
-    'minPeers': {
+    minPeers: {
       describe: 'Peers needed before syncing',
       number: true,
-      default: 2
+      default: 2,
     },
-    'maxPeers': {
+    maxPeers: {
       describe: 'Maximum peers to sync with',
       number: true,
-      default: 25
+      default: 25,
     },
-    'params': {
+    params: {
       describe: 'Path to chain parameters json file',
-      coerce: path.resolve
-    }
+      coerce: path.resolve,
+    },
   })
-  .locale('en_EN')
-  .argv
+  .locale('en_EN').argv
 const logger = getLogger({ loglevel: args.loglevel })
 
-async function runNode (options: any) {
+async function runNode(options: any) {
   logger.info('Initializing Ethereumjs client...')
   if (options.lightserv) {
     logger.info(`Serving light peer requests`)
@@ -104,7 +103,7 @@ async function runNode (options: any) {
   return node
 }
 
-function runRpcServer (node: any, options: any) {
+function runRpcServer(node: any, options: any) {
   const { rpcport, rpcaddr } = options
   const manager = new RPCManager(node, options)
   const server = new RPCServer(manager.getMethods())
@@ -114,11 +113,11 @@ function runRpcServer (node: any, options: any) {
   return server
 }
 
-async function run () {
+async function run() {
   const syncDirName = args.syncmode === 'light' ? 'lightchaindata' : 'chaindata'
   // give network id precedence over network name
   if (args.networkId) {
-    const network = networks.find(n => n[0] === `${args.networkId}`)
+    const network = networks.find((n) => n[0] === `${args.networkId}`)
     if (network) {
       args.network = network[1]
     }
@@ -151,7 +150,7 @@ async function run () {
     rpcport: args.rpcport,
     rpcaddr: args.rpcaddr,
     minPeers: args.minPeers,
-    maxPeers: args.maxPeers
+    maxPeers: args.maxPeers,
   }
   const node = await runNode(options)
   const server = args.rpc ? runRpcServer(node, options) : null
@@ -165,4 +164,4 @@ async function run () {
   })
 }
 
-run().catch(err => logger.error(err))
+run().catch((err) => logger.error(err))

lib/blockchain/chain.ts

@@ -8,15 +8,14 @@ const promisify = require('util-promisify')
 
 const defaultOptions = {
   logger: defaultLogger,
-  common: new Common('mainnet', 'chainstart')
+  common: new Common('mainnet', 'chainstart'),
 }
 
 /**
  * Blockchain
  * @memberof module:blockchain
  */
 export class Chain extends events.EventEmitter {
-
   public logger: any
   public common: Common
   public db: any
@@ -27,13 +26,13 @@ export class Chain extends events.EventEmitter {
   private _headers = {}
   private _blocks = {}
 
-  private _getBlocks: Function | undefined
-  private _getBlock: Function | undefined
-  private _putBlocks: Function | undefined
-  private _putHeaders: Function | undefined
-  private _getLatestHeader: Function | undefined
-  private _getLatestBlock: Function | undefined
-  private _getTd: Function | undefined
+  private _getBlocks: Function | undefined
+  private _getBlock: Function | undefined
+  private _putBlocks: Function | undefined
+  private _putHeaders: Function | undefined
+  private _getLatestHeader: Function | undefined
+  private _getLatestBlock: Function | undefined
+  private _getTd: Function | undefined
 
   /**
    * Create new chain
@@ -42,7 +41,7 @@ export class Chain extends events.EventEmitter {
    * @param {Common}  [options.common] common parameters
    * @param {Logger}  [options.logger] Logger instance
    */
-  constructor (options?: any) {
+  constructor(options?: any) {
     super()
     options = { ...defaultOptions, ...options }
 
@@ -53,12 +52,12 @@ export class Chain extends events.EventEmitter {
     this.init()
   }
 
-  init () {
+  init() {
     if (!this.blockchain) {
       this.blockchain = new Blockchain({
         db: this.db,
         validate: false,
-        common: this.common
+        common: this.common,
       })
       if (!this.db) {
         this.db = this.blockchain.db
@@ -69,32 +68,34 @@ export class Chain extends events.EventEmitter {
     this.opened = false
   }
 
-  reset () {
+  reset() {
     this._headers = {
       latest: null,
       td: new BN(0),
-      height: new BN(0)
+      height: new BN(0),
     }
     this._blocks = {
       latest: null,
       td: new BN(0),
-      height: new BN(0)
+      height: new BN(0),
     }
   }
 
   /**
    * Network ID
    */
-  get networkId (): number {
+  get networkId(): number {
     return this.common.networkId()
   }
 
   /**
    * Genesis block parameters
    */
-  get genesis (): object {
+  get genesis(): object {
     const genesis = this.common.genesis()
-    Object.entries(genesis).forEach(([k, v]) => { genesis[k] = hexToBuffer(v as string) })
+    Object.entries(genesis).forEach(([k, v]) => {
+      genesis[k] = hexToBuffer(v as string)
+    })
     return genesis
   }
 
@@ -103,7 +104,7 @@ export class Chain extends events.EventEmitter {
    * the latest header in the chain, the ``td`` property is the total difficulty of
    * headerchain, and the ``height`` is the height of the headerchain.
    */
-  get headers (): object {
+  get headers(): object {
     return { ...this._headers }
   }
 
@@ -112,14 +113,14 @@ export class Chain extends events.EventEmitter {
    * the latest block in the chain, the ``td`` property is the total difficulty of
    * blockchain, and the ``height`` is the height of the blockchain.
    */
-  get blocks (): object {
+  get blocks(): object {
     return { ...this._blocks }
   }
 
   /**
    * Open blockchain and wait for database to load
    */
-  async open (): Promise<boolean | void> {
+  async open(): Promise<boolean | void> {
     if (this.opened) {
       return false
     }
@@ -132,7 +133,7 @@ export class Chain extends events.EventEmitter {
   /**
    * Close blockchain and database
    */
-  async close (): Promise<boolean | void> {
+  async close(): Promise<boolean | void> {
     if (!this.opened) {
       return false
     }
@@ -145,7 +146,7 @@ export class Chain extends events.EventEmitter {
    * Update blockchain properties (latest block, td, height, etc...)
    * @return {Promise}
    */
-  async update (): Promise<boolean | void> {
+  async update(): Promise<boolean | void> {
     if (!this.opened) {
       return false
     }
@@ -171,7 +172,7 @@ export class Chain extends events.EventEmitter {
    * @param skip number of blocks to skip
    * @param reverse get blocks in reverse
    */
-  async getBlocks (block: Buffer | BN, max: number, skip: number, reverse: boolean): Promise<any[]> {
+  async getBlocks(block: Buffer | BN, max: number, skip: number, reverse: boolean): Promise<any[]> {
     if (!this.opened) {
       await this.open()
     }
@@ -185,7 +186,7 @@ export class Chain extends events.EventEmitter {
    * Gets a block by its hash or number
    * @param blocks block hash or number
    */
-  async getBlock (block: Buffer | BN): Promise<any> {
+  async getBlock(block: Buffer | BN): Promise<any> {
     if (!this.opened) {
       await this.open()
     }
@@ -201,7 +202,7 @@ export class Chain extends events.EventEmitter {
    * @method putBlocks
    * @param {Block[]} blocks list of blocks to add
    */
-  async putBlocks (blocks: object[]): Promise<void> {
+  async putBlocks(blocks: object[]): Promise<void> {
     if (!this.opened) {
       await this.open()
     }
@@ -223,7 +224,12 @@ export class Chain extends events.EventEmitter {
    * @param skip number of headers to skip
    * @param reverse get headers in reverse
    */
-  async getHeaders (block: Buffer | BN, max: number, skip: number, reverse: boolean): Promise<any[]> {
+  async getHeaders(
+    block: Buffer | BN,
+    max: number,
+    skip: number,
+    reverse: boolean
+  ): Promise<any[]> {
     const blocks = await this.getBlocks(block, max, skip, reverse)
     return blocks.map((b: any) => b.header)
   }
@@ -233,7 +239,7 @@ export class Chain extends events.EventEmitter {
    * @method putHeaders
    * @param headers list of headers to add
    */
-  async putHeaders (headers: object[]): Promise<void> {
+  async putHeaders(headers: object[]): Promise<void> {
     if (!this.opened) {
       await this.open()
     }
@@ -251,7 +257,7 @@ export class Chain extends events.EventEmitter {
   /**
    * Gets the latest header in the canonical chain
    */
-  async getLatestHeader (): Promise<any> {
+  async getLatestHeader(): Promise<any> {
     if (!this.opened) {
       await this.open()
     }
@@ -265,7 +271,7 @@ export class Chain extends events.EventEmitter {
   /**
    * Gets the latest block in the canonical chain
    */
-  async getLatestBlock (): Promise<any> {
+  async getLatestBlock(): Promise<any> {
     if (!this.opened) {
       await this.open()
     }
@@ -280,7 +286,7 @@ export class Chain extends events.EventEmitter {
    * Gets total difficulty for a block
    * @param hash block hash
    */
-  async getTd (hash: Buffer): Promise<any> {
+  async getTd(hash: Buffer): Promise<any> {
     if (!this.opened) {
       await this.open()
     }
@@ -291,10 +297,9 @@ export class Chain extends events.EventEmitter {
   }
 }
 
-function hexToBuffer (hexString: string): Buffer | string {
-  if (typeof (hexString) === 'string' && hexString.startsWith('0x')) {
+function hexToBuffer(hexString: string): Buffer | string {
+  if (typeof hexString === 'string' && hexString.startsWith('0x')) {
     return Buffer.from(hexString.slice(2), 'hex')
   }
   return hexString
 }
-