fluencelabs/js-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p synced 2025-04-25 18:42:15 +00:00
Code Issues Projects Releases Wiki Activity

fix: wait for peer stats to be updated during test (#1238)

Browse Source 
The peer stats update interval doesn't always align with the timing
in the test so make sure it's elapsed before asserting on the results.

Fixes #1219
This commit is contained in:
Alex Potsides 2022-06-08 16:47:41 +01:00 committed by GitHub
parent f9073ecd21
commit b0472686d2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
test/metrics/index.node.ts
View File

@ -11,6 +11,7 @@ import { createBaseOptions } from '../utils/base-options.js'
import type { Libp2pNode } from '../../src/libp2p.js' import type { Libp2pNode } from '../../src/libp2p.js'
import type { Libp2pOptions } from '../../src/index.js' import type { Libp2pOptions } from '../../src/index.js'
import type { DefaultMetrics } from '../../src/metrics/index.js' import type { DefaultMetrics } from '../../src/metrics/index.js'
import pWaitFor from 'p-wait-for'
import drain from 'it-drain' import drain from 'it-drain'
describe('libp2p.metrics', () => { describe('libp2p.metrics', () => {
@ -170,6 +171,19 @@ describe('libp2p.metrics', () => {
throw new Error('Metrics not configured') throw new Error('Metrics not configured')
} }
await pWaitFor(() => {
const peerStats = metrics.forPeer(connection.remotePeer)?.getSnapshot()
const transferred = parseInt(peerStats?.dataReceived.toString() ?? '0')
if (transferred < bytes.length) {
return false
}
return true
}, {
interval: 100
})
const peerStats = metrics.forPeer(connection.remotePeer)?.getSnapshot() const peerStats = metrics.forPeer(connection.remotePeer)?.getSnapshot()
expect(parseInt(peerStats?.dataReceived.toString() ?? '0')).to.be.at.least(bytes.length) expect(parseInt(peerStats?.dataReceived.toString() ?? '0')).to.be.at.least(bytes.length)