@@ -67,6 +67,7 @@ module.exports = (common) => {
67
67
let ipfs1
68
68
let ipfs2
69
69
let ipfs3
70
+ let withGo
70
71
71
72
before ( function ( done ) {
72
73
// CI takes longer to instantiate the daemon, so we need to increase the
@@ -90,7 +91,12 @@ module.exports = (common) => {
90
91
ipfs1 = nodes [ 0 ]
91
92
ipfs2 = nodes [ 1 ]
92
93
ipfs3 = nodes [ 2 ]
93
- done ( )
94
+
95
+ ipfs1 . id ( ( err , id ) => {
96
+ expect ( err ) . to . not . exist ( )
97
+ withGo = id . agentVersion . startsWith ( 'go-ipfs' )
98
+ done ( )
99
+ } )
94
100
} )
95
101
} )
96
102
} )
@@ -497,7 +503,13 @@ module.exports = (common) => {
497
503
} )
498
504
} )
499
505
500
- it ( 'receive multiple messages' , ( done ) => {
506
+ it ( 'receive multiple messages' , function ( done ) {
507
+ // TODO fix https://github.com/ipfs/interface-ipfs-core/pull/188#issuecomment-354673246
508
+ // and https://github.com/ipfs/go-ipfs/issues/4778
509
+ if ( withGo ) {
510
+ this . skip ( )
511
+ }
512
+
501
513
const inbox1 = [ ]
502
514
const inbox2 = [ ]
503
515
const outbox = [ 'hello' , 'world' , 'this' , 'is' , 'pubsub' ]
@@ -566,16 +578,22 @@ module.exports = (common) => {
566
578
let sub1
567
579
let sub2
568
580
569
- before ( ( ) => {
581
+ beforeEach ( function ( ) {
582
+ // TODO fix https://github.com/ipfs/interface-ipfs-core/pull/188#issuecomment-354673246
583
+ // and https://github.com/ipfs/go-ipfs/issues/4778
584
+ if ( withGo ) {
585
+ this . skip ( )
586
+ }
587
+
570
588
topic = getTopic ( )
571
589
} )
572
590
573
- after ( ( ) => {
591
+ afterEach ( ( ) => {
574
592
ipfs1 . pubsub . unsubscribe ( topic , sub1 )
575
593
ipfs2 . pubsub . unsubscribe ( topic , sub2 )
576
594
} )
577
595
578
- it . skip ( 'send/receive 10k messages' , function ( done ) {
596
+ it ( 'send/receive 10k messages' , function ( done ) {
579
597
this . timeout ( 2 * 60 * 1000 )
580
598
581
599
const msgBase = 'msg - '
0 commit comments