mirror of
https://github.com/fluencelabs/js-libp2p
synced 2025-05-25 08:31:19 +00:00
d7c38d3fec
* feat: peer-store v0 * feat: registrar * chore: apply suggestions from code review Co-Authored-By: Jacob Heun <jacobheun@gmail.com> * chore: address review * chore: support multiple conns * chore: address review * fix: no remote peer from topology on disconnect
58 lines
1.5 KiB
JavaScript
58 lines
1.5 KiB
JavaScript
'use strict'
|
|
/* eslint-env mocha */
|
|
|
|
const chai = require('chai')
|
|
chai.use(require('dirty-chai'))
|
|
const { expect } = chai
|
|
const sinon = require('sinon')
|
|
|
|
const mergeOptions = require('merge-options')
|
|
|
|
const multiaddr = require('multiaddr')
|
|
const Libp2p = require('../../src')
|
|
|
|
const baseOptions = require('../utils/base-options')
|
|
const peerUtils = require('../utils/creators/peer')
|
|
const listenAddr = multiaddr('/ip4/127.0.0.1/tcp/0')
|
|
|
|
describe('registrar on dial', () => {
|
|
let peerInfo
|
|
let remotePeerInfo
|
|
let libp2p
|
|
let remoteLibp2p
|
|
let remoteAddr
|
|
|
|
before(async () => {
|
|
[peerInfo, remotePeerInfo] = await peerUtils.createPeerInfoFromFixture(2)
|
|
remoteLibp2p = new Libp2p(mergeOptions(baseOptions, {
|
|
peerInfo: remotePeerInfo
|
|
}))
|
|
|
|
await remoteLibp2p.transportManager.listen([listenAddr])
|
|
remoteAddr = remoteLibp2p.transportManager.getAddrs()[0]
|
|
})
|
|
|
|
after(async () => {
|
|
sinon.restore()
|
|
await remoteLibp2p.stop()
|
|
libp2p && await libp2p.stop()
|
|
})
|
|
|
|
it('should inform registrar of a new connection', async () => {
|
|
libp2p = new Libp2p(mergeOptions(baseOptions, {
|
|
peerInfo
|
|
}))
|
|
|
|
sinon.spy(remoteLibp2p.registrar, 'onConnect')
|
|
|
|
await libp2p.dial(remoteAddr)
|
|
expect(remoteLibp2p.registrar.onConnect.callCount).to.equal(1)
|
|
|
|
const libp2pConn = libp2p.registrar.getConnection(remotePeerInfo)
|
|
expect(libp2pConn).to.exist()
|
|
|
|
const remoteConn = remoteLibp2p.registrar.getConnection(peerInfo)
|
|
expect(remoteConn).to.exist()
|
|
})
|
|
})
|