Lint lib/net

Author: cgewecke

lib/net/peerpool.ts

@@ -77,6 +77,7 @@ export class PeerPool extends EventEmitter {
       })
     })
     this.opened = true
+    // eslint-disable-next-line @typescript-eslint/await-thenable
     this._statusCheckInterval = setInterval(await this._statusCheck.bind(this), 20000)
   }
 
@@ -122,7 +123,7 @@ export class PeerPool extends EventEmitter {
    * @param [filterFn] filter function to apply before finding idle peers
    * @return {Peer}
    */
-  idle(filterFn = (peer: Peer) => true): Peer {
+  idle(filterFn = (_peer: Peer) => true): Peer {
     const idle = this.peers.filter((p: any) => p.idle && filterFn(p))
     const index = Math.floor(Math.random() * idle.length)
     return idle[index]
@@ -141,7 +142,7 @@ export class PeerPool extends EventEmitter {
         this.emit(`message:${protocol}`, message, peer)
       }
     })
-    peer.on('error', (error: Error, protocol: string) => {
+    peer.on('error', (error: Error) => {
       if (this.pool.get(peer.id)) {
         this.logger.warn(`Peer error: ${error} ${peer}`)
         this.ban(peer)

lib/net/protocol/boundprotocol.ts

@@ -1,5 +1,5 @@
 import { EventEmitter } from 'events'
-import { Message, Protocol } from '../protocol/protocol'
+import { Protocol } from '../protocol/protocol'
 import { Peer } from '../peer/peer'
 import { Sender } from './sender'
 

lib/net/protocol/flowcontrol.ts

@@ -57,6 +57,7 @@ export class FlowControl {
     const params = this.in.get(peer.id) || { ble: bl }
     if (params.last) {
       // recharge BLE at rate of MRR when less than BL
+      // eslint-disable-next-line @typescript-eslint/restrict-plus-operands
       params.ble = Math.min(params.ble + mrr * (now - params.last), bl)
     }
     params.last = now
@@ -78,10 +79,12 @@ export class FlowControl {
     const now = Date.now()
     const params = this.out.get(peer.id) || {}
     if (params.bv && params.last) {
+      // eslint-disable-next-line @typescript-eslint/restrict-plus-operands
       params.bv = Math.min(params.bv + this.mrr * (now - params.last), this.bl)
     } else {
       params.bv = this.bl
     }
+    // eslint-disable-next-line @typescript-eslint/restrict-plus-operands
     params.bv -= this.mrc[messageName].base + this.mrc[messageName].req * count
     params.last = now
     if (params.bv < 0) {

lib/net/protocol/libp2psender.ts

@@ -42,6 +42,7 @@ export class Libp2pSender extends Sender {
       this.connection,
       catcher((e: Error) => this.error(e)),
       pull.drain((message: any) => {
+        // eslint-disable-next-line prefer-const
         let [code, payload]: any = rlp.decode(message)
         code = bufferToInt(code)
         if (code === 0) {

lib/net/protocol/protocol.ts

@@ -127,7 +127,7 @@ export class Protocol extends EventEmitter {
    * @param {Object} status status message payload
    * @return {Object}
    */
-  decodeStatus(status: any): any {
+  decodeStatus(_status: any): any {
     throw new Error('Unimplemented')
   }
 

lib/net/protocol/sender.ts

@@ -30,7 +30,7 @@ export class Sender extends EventEmitter {
    * @protected
    * @param  {Object} status
    */
-  sendStatus(status: any) {
+  sendStatus(_status: any) {
     throw new Error('Unimplemented')
   }
 
@@ -40,7 +40,7 @@ export class Sender extends EventEmitter {
    * @param  {number} code message code
    * @param  {Array|Buffer} rlpEncodedData rlp encoded message payload
    */
-  sendMessage(code: number, rlpEncodedData: any[] | Buffer) {
+  sendMessage(_code: number, _rlpEncodedData: any[] | Buffer) {
     throw new Error('Unimplemented')
   }
 }

lib/net/server/rlpxserver.ts

@@ -1,5 +1,4 @@
 import { Server } from './server'
-import { Protocol } from './../protocol/protocol'
 const { randomBytes } = require('crypto')
 import { RLPx as Devp2pRLPx, Peer as Devp2pRLPxPeer, DPT as Devp2pDPT } from 'ethereumjs-devp2p'
 import { RlpxPeer } from '../peer/rlpxpeer'

lib/net/server/server.ts

@@ -91,7 +91,7 @@ export class Server extends EventEmitter {
    * @param  maxAge how long to ban peer
    * @return {Promise}
    */
-  ban(peerId: string, maxAge: number) {
+  ban(_peerId: string, _maxAge: number) {
     // don't do anything by default
   }
 }