add sharness test for pubsub

test/sharness/lib/iptb-lib.sh

@@ -21,9 +21,15 @@ startup_cluster() {
 	num_nodes="$1"
 	bound=$(expr "$num_nodes" - 1)
 
-	test_expect_success "start up nodes" '
-		iptb start
-	'
+	if [ "$2" = "--enable-pubsub-experiment" ]; then
+		test_expect_success "start up nodes with pubsub enabled" '
+			iptb start --args --enable-pubsub-experiment
+		'
+	else
+		test_expect_success "start up nodes" '
+			iptb start
+		'
+	fi
 
 	test_expect_success "connect nodes to eachother" '
 		iptb connect [1-$bound] 0

test/sharness/t0180-pubsub.sh

@@ -0,0 +1,48 @@
+#!/bin/sh
+
+test_description="Test dht command"
+
+. lib/test-lib.sh
+
+# start iptb + wait for peering
+NUM_NODES=5
+test_expect_success 'init iptb' '
+  iptb init -n $NUM_NODES --bootstrap=none --port=0
+'
+
+startup_cluster $NUM_NODES --enable-pubsub-experiment
+
+test_expect_success 'peer ids' '
+  PEERID_0=$(iptb get id 0) &&
+  PEERID_2=$(iptb get id 2)
+'
+
+# ipfs pubsub sub
+test_expect_success 'pubsub' '
+	echo "testOK" > expected &&
+	mkfifo done &&
+
+	(
+		ipfsi 0 pubsub sub --enc=ndpayload testTopic | 
+			while read line; do
+				echo $line > actual &&
+				echo > done
+				exit
+			done
+	) &
+
+	ipfspid=$!
+
+	sleep 1
+
+	ipfsi 1 pubsub pub testTopic "testOK" &> pubErr1 &&
+
+	cat done &&
+	test_cmp actual expected
+'
+
+test_expect_success 'stop iptb' '
+  iptb stop
+'
+
+test_done