generated from libp2p/js-libp2p-example-fork-go-template
-
Notifications
You must be signed in to change notification settings - Fork 3
/
listener.js
48 lines (40 loc) · 1.26 KB
/
listener.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
/* eslint-disable no-console */
import { noise } from '@chainsafe/libp2p-noise'
import { yamux } from '@chainsafe/libp2p-yamux'
import { circuitRelayTransport } from '@libp2p/circuit-relay-v2'
import { identify } from '@libp2p/identify'
import { webSockets } from '@libp2p/websockets'
import { multiaddr } from '@multiformats/multiaddr'
import { createLibp2p } from 'libp2p'
async function main () {
const relayAddr = process.argv[2]
if (!relayAddr) {
throw new Error('the relay address needs to be specified as a parameter')
}
const node = await createLibp2p({
transports: [
webSockets(),
circuitRelayTransport({
discoverRelays: 2
})
],
connectionEncrypters: [
noise()
],
streamMuxers: [
yamux()
],
services: {
identify: identify()
}
})
console.log(`Node started with id ${node.peerId.toString()}`)
const conn = await node.dial(multiaddr(relayAddr))
console.log(`Connected to the relay ${conn.remotePeer.toString()}`)
// Wait for connection and relay to be bind for the example purpose
node.addEventListener('self:peer:update', (evt) => {
// Updated self multiaddrs?
console.log(`Advertising with a relay address of ${node.getMultiaddrs()[0].toString()}`)
})
}
main()