@@ -38,10 +38,14 @@ function setupInProcNode (addrs, hop, callback) {
38
38
}
39
39
40
40
procDf . spawn ( {
41
- relay : {
42
- enabled : true ,
43
- hop : {
44
- enabled : hop
41
+ libp2p : {
42
+ config : {
43
+ relay : {
44
+ enabled : true ,
45
+ hop : {
46
+ enabled : hop
47
+ }
48
+ }
45
49
}
46
50
} ,
47
51
config : Object . assign ( { } , baseConf , {
@@ -73,7 +77,7 @@ describe('circuit relay', () => {
73
77
let relayNode
74
78
75
79
let nodes
76
- before ( function ( done ) {
80
+ before ( 'create and connect' , function ( done ) {
77
81
parallel ( [
78
82
( cb ) => setupInProcNode ( [
79
83
'/ip4/0.0.0.0/tcp/0' ,
@@ -88,29 +92,29 @@ describe('circuit relay', () => {
88
92
relayNode = res [ 0 ] . ipfsd
89
93
90
94
nodeAAddr = tcpAddr ( res [ 1 ] . addrs )
91
- nodeA = res [ 0 ] . ipfsd . api
95
+ nodeA = res [ 1 ] . ipfsd . api
92
96
93
97
nodeBAddr = wsAddr ( res [ 2 ] . addrs )
94
98
95
- nodeB = res [ 1 ] . ipfsd . api
99
+ nodeB = res [ 2 ] . ipfsd . api
96
100
nodeBCircuitAddr = `/p2p-circuit/ipfs/${ multiaddr ( nodeBAddr ) . getPeerId ( ) } `
97
101
98
- done ( )
102
+ // ensure we have an address string
103
+ expect ( nodeAAddr ) . to . be . a ( 'string' )
104
+ expect ( nodeBAddr ) . to . be . a ( 'string' )
105
+ expect ( nodeBCircuitAddr ) . to . be . a ( 'string' )
106
+
107
+ series ( [
108
+ ( cb ) => relayNode . api . swarm . connect ( nodeAAddr , cb ) ,
109
+ ( cb ) => relayNode . api . swarm . connect ( nodeBAddr , cb ) ,
110
+ ( cb ) => setTimeout ( cb , 1000 ) ,
111
+ ( cb ) => nodeA . swarm . connect ( nodeBCircuitAddr , cb )
112
+ ] , done )
99
113
} )
100
114
} )
101
115
102
116
after ( ( done ) => parallel ( nodes . map ( ( node ) => ( cb ) => node . stop ( cb ) ) , done ) )
103
117
104
- it ( 'should connect' , function ( done ) {
105
- series ( [
106
- ( cb ) => relayNode . api . swarm . connect ( nodeAAddr , cb ) ,
107
- ( cb ) => setTimeout ( cb , 1000 ) ,
108
- ( cb ) => relayNode . api . swarm . connect ( nodeBAddr , cb ) ,
109
- ( cb ) => setTimeout ( cb , 1000 ) ,
110
- ( cb ) => nodeA . swarm . connect ( nodeBCircuitAddr , cb )
111
- ] , done )
112
- } )
113
-
114
118
it ( 'should transfer' , function ( done ) {
115
119
const data = crypto . randomBytes ( 128 )
116
120
waterfall ( [
0 commit comments