Skip to content
This repository was archived by the owner on Aug 1, 2023. It is now read-only.

Commit 2982fd5

Browse files
Stebaliendaviddias
authored andcommitted
test: add circuit reconnect test
@whyrusleeping noticed a bug where this didn't appear to work. I can't reproduce but this is still a useful test to have.
1 parent 52b6570 commit 2982fd5

File tree

2 files changed

+23
-1
lines changed

2 files changed

+23
-1
lines changed

test/circuit.js

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -15,10 +15,12 @@ const browser = require('./circuit/browser')
1515
const isNode = require('detect-node')
1616
const send = require('./utils/circuit').send
1717
const connect = require('./utils/circuit').connect
18+
const disconnect = require('./utils/circuit').disconnect
1819

1920
const timeout = 80 * 1000
2021
const baseTest = {
2122
connect,
23+
disconnect,
2224
send,
2325
timeout
2426
}
@@ -65,6 +67,18 @@ describe('circuit', () => {
6567
it('send', (done) => {
6668
tests[test].send(nodeA.ipfsd.api, nodeB.ipfsd.api, done)
6769
})
70+
71+
it('disconnect', (done) => {
72+
tests[test].disconnect(nodeA, nodeB, done)
73+
})
74+
75+
it('reconnect', (done) => {
76+
tests[test].connect(nodeA, nodeB, relay, done)
77+
})
78+
79+
it('resend', (done) => {
80+
tests[test].send(nodeA.ipfsd.api, nodeB.ipfsd.api, done)
81+
})
6882
})
6983
})
7084
})

test/utils/circuit.js

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -95,8 +95,8 @@ exports.createGoNode = (addrs, callback) => {
9595
})
9696
}
9797

98-
const data = crypto.randomBytes(128)
9998
exports.send = (nodeA, nodeB, callback) => {
99+
const data = crypto.randomBytes(128)
100100
waterfall([
101101
(cb) => nodeA.add(data, cb),
102102
(res, cb) => nodeB.cat(res[0].hash, cb),
@@ -161,3 +161,11 @@ exports.connWithTimeout = (timeout) => {
161161
connect(nodeA, nodeB, relay, timeout, callback)
162162
}
163163
}
164+
165+
const disconnect = (nodeA, nodeB, callback) => {
166+
series([
167+
(cb) => nodeA.ipfsd.api.swarm.disconnect(getCircuitAddr(nodeB.addrs), cb)
168+
], callback)
169+
}
170+
171+
exports.disconnect = disconnect

0 commit comments

Comments
 (0)