forked from ipfs/js-ipfs
-
Notifications
You must be signed in to change notification settings - Fork 0
/
test.js
73 lines (60 loc) · 1.68 KB
/
test.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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
'use strict'
const path = require('path')
const execa = require('execa')
const Libp2p = require('libp2p')
const TCP = require('libp2p-tcp')
const SPDY = require('libp2p-spdy')
const MPLEX = require('pull-mplex')
const SECIO = require('libp2p-secio')
const PeerInfo = require('peer-info')
const PeerId = require('peer-id')
const multiaddr = require('multiaddr')
const promisify = require('promisify-es6')
const PeerBook = require('peer-book')
async function test () {
let output = ''
const proc = execa('node', [path.join(__dirname, 'index.js')], {
cwd: path.resolve(__dirname),
all: true
})
proc.all.on('data', async (data) => {
process.stdout.write(data)
output += data.toString('utf8')
if (output.includes('The node now has')) {
// the node has started up, try to dial it
const address = output.trim().match(/Swarm listening on (.*)\n/)[1]
console.info('Dialling', address)
const peerInfo = new PeerInfo(await promisify(PeerId.create)())
peerInfo.multiaddrs.add(multiaddr('/ip4/127.0.0.1/tcp/0'))
const libp2p = new Libp2p({
peerInfo,
peerBook: new PeerBook(),
modules: {
transport: [
TCP
],
streamMuxer: [
MPLEX,
SPDY
],
connEncryption: [
SECIO
]
}
})
await libp2p.start()
await libp2p.dial(address)
console.info('Dialled', address)
proc.kill()
await libp2p.stop()
}
})
await proc.catch(() => {
// throw new Error('libp2p should have been killed')
}, (err) => {
if (err.exitSignal !== 'SIGTERM') {
throw err
}
})
}
module.exports = test