client: fix type issues (#2920)

packages/client/test/net/peerpool.spec.ts

@@ -99,12 +99,12 @@ describe('[PeerPool]', async () => {
       pool.ban(p, 1000)
     }
     pool.config.events.on(Event.POOL_PEER_BANNED, (peer) =>
-      assert.equal(peer, peers[1], 'banned peer')
+      assert.equal(peer, peers[1] as any, 'banned peer')
     )
     pool.config.events.on(Event.POOL_PEER_REMOVED, (peer) =>
-      assert.equal(peer, peers[1], 'removed peer')
+      assert.equal(peer, peers[1] as any, 'removed peer')
     )
-    assert.equal(pool.peers[0], peers[0], 'outbound peer not banned')
+    assert.equal(pool.peers[0], peers[0] as any, 'outbound peer not banned')
   })
 
   it('should reset td', () => {

packages/client/test/sim/snapsync.spec.ts

@@ -4,9 +4,9 @@ import debug from 'debug'
 import { Client } from 'jayson/promise'
 import { assert, describe, it } from 'vitest'
 
-import { Config } from '../../src/config'
-import { getLogger } from '../../src/logging'
-import { Event } from '../../src/types'
+import { Config } from '../../src/config.js'
+import { getLogger } from '../../src/logging.js'
+import { Event } from '../../src/types.js'
 
 import {
   createInlineClient,
@@ -64,7 +64,7 @@ describe('simple mainnet test run', async () => {
   }
 
   // ------------Sanity checks--------------------------------
-  it('add some EOA transfers', { skip: process.env.ADD_EOA_STATE === undefined }, async () => {
+  it.skipIf(process.env.ADD_EOA_STATE === undefined)('add some EOA transfers', async () => {
     const startBalance = await client.request('eth_getBalance', [
       '0x3dA33B9A0894b908DdBb00d96399e506515A1009',
       'latest',
@@ -99,7 +99,7 @@ describe('simple mainnet test run', async () => {
     )
   })
 
-  it('setup snap sync', { skip: process.env.SNAP_SYNC === undefined }, async () => {
+  it.skipIf(process.env.ADD_EOA_STATE === undefined)('setup snap sync', async () => {
     // start client inline here for snap sync, no need for beacon
     const { ejsInlineClient, peerConnectedPromise, snapSyncCompletedPromise } =
       // eslint-disable-next-line @typescript-eslint/no-use-before-define

packages/client/test/sync/fetcher/blockfetcher.spec.ts

@@ -148,7 +148,7 @@ describe('[BlockFetcher]', async () => {
       count: BigInt(0),
     })
     td.when((fetcher as any).pool.idle(td.matchers.anything())).thenReturn('peer0')
-    assert.equal(fetcher.peer(), 'peer0', 'found peer')
+    assert.equal(fetcher.peer(), 'peer0' as any, 'found peer')
   })
 
   it('should request correctly', async () => {

packages/client/test/sync/fetcher/fetcher.spec.ts

@@ -73,7 +73,11 @@ describe('[Fetcher]', () => {
     ;(fetcher as any).total = 10
     fetcher.next()
     setTimeout(() => {
-      assert.deepEqual(job, { index: 0, peer: { idle: false }, state: 'expired' }, 'expired job')
+      assert.deepEqual(
+        job as any,
+        { index: 0, peer: { idle: false }, state: 'expired' },
+        'expired job'
+      )
       assert.equal((fetcher as any).in.length, 1, 'enqueued job')
     }, 20)
   })

packages/client/test/sync/fetcher/headerfetcher.spec.ts

@@ -25,12 +25,12 @@ describe('[HeaderFetcher]', async () => {
     assert.deepEqual(
       //@ts-ignore
       fetcher.process({ task: { count: 2 }, peer: 'peer0' }, { headers, bv: BigInt(1) }),
-      headers,
+      headers as any,
       'got results'
     )
     //@ts-ignore
     assert.notOk(
-      fetcher.process({ task: { count: 2 } }, { headers: [], bv: BigInt(1) }),
+      fetcher.process({ task: { count: 2 } } as any, { headers: [], bv: BigInt(1) } as any),
       'bad results'
     )
     td.verify((fetcher as any).flow.handleReply('peer0', 1))
@@ -66,7 +66,7 @@ describe('[HeaderFetcher]', async () => {
     const pool = new PeerPool()
     const fetcher = new HeaderFetcher({ config, pool })
     td.when((fetcher as any).pool.idle(td.matchers.anything())).thenReturn('peer0')
-    assert.equal(fetcher.peer(), 'peer0', 'found peer')
+    assert.equal(fetcher.peer(), 'peer0' as any, 'found peer')
   })
 
   it('should request correctly', async () => {

packages/client/test/sync/fetcher/reverseblockfetcher.spec.ts

@@ -136,7 +136,7 @@ describe('[ReverseBlockFetcher]', async () => {
       count: BigInt(2),
     })
     td.when((fetcher as any).pool.idle(td.matchers.anything())).thenReturn('peer0')
-    assert.equal(fetcher.peer(), 'peer0', 'found peer')
+    assert.equal(fetcher.peer(), 'peer0' as any, 'found peer')
   })
 
   it('should request correctly', async () => {

packages/client/test/sync/snapsync.spec.ts

@@ -94,7 +94,7 @@ describe('[SnapSynchronizer]', async () => {
     ]
     ;(sync as any).pool = { peers }
     ;(sync as any).forceSync = true
-    assert.equal(await sync.best(), peers[1], 'found best')
+    assert.equal(await sync.best(), peers[1] as any, 'found best')
     await sync.start()
   })
 })

packages/devp2p/test/integration/rlpx-simulator.spec.ts

@@ -37,7 +37,7 @@ describe('RLPx simulator tests', () => {
         rlpxs[0]['_dpt']!['_banlist'].has(peer),
         'should not be in ban list before bad peer discovered'
       )
-      rlpxs[0]['_dpt']!.emit('peer:new', peer)
+      rlpxs[0]['_dpt']!.events.emit('peer:new', peer)
       assert.ok(
         rlpxs[0]['_dpt']!['_banlist'].has(peer),
         'should be in ban list after bad peer discovered'

packages/devp2p/test/integration/util.ts

@@ -103,7 +103,7 @@ export function initTwoPeerRLPXSetup(
   capabilities?: any,
   common?: Object | Common,
   basePort = 30306
-) {
+): RLPx[] {
   const rlpxs = getTestRLPXs(2, maxPeers, basePort, capabilities, common)
   const peer = { address: localhost, udpPort: basePort + 1, tcpPort: basePort + 1 }
   rlpxs[0]['_dpt']!.addPeer(peer).catch(() => {