feat: sign pubsub messages (#362)

* fix: forward pubsub publish callback to floodsub chore: update floodsub version * test: add random walk delay to config * chore: update floodsub
libp2p · May 7, 2019 · 40978a1 · 40978a1
1 parent 71dcaaf
commit 40978a1
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 4 deletions.
diff --git a/package.json b/package.json
@@ -43,7 +43,7 @@
     "err-code": "^1.1.2",
     "fsm-event": "^2.1.0",
     "libp2p-connection-manager": "~0.1.0",
-    "libp2p-floodsub": "~0.15.8",
+    "libp2p-floodsub": "~0.16.0",
     "libp2p-ping": "~0.8.5",
     "libp2p-switch": "~0.42.9",
     "libp2p-websockets": "~0.12.2",

diff --git a/src/pubsub.js b/src/pubsub.js
@@ -63,9 +63,7 @@ module.exports = (node) => {
         return nextTick(callback, errCode(new Error('data must be a Buffer'), 'ERR_DATA_IS_NOT_A_BUFFER'))
       }
 
-      floodSub.publish(topic, data)
-
-      nextTick(() => callback())
+      floodSub.publish(topic, data, callback)
     },
 
     ls: (callback) => {

diff --git a/test/peer-discovery.node.js b/test/peer-discovery.node.js
@@ -423,6 +423,7 @@ describe('peer discovery', () => {
           randomWalk: {
             enabled: true,
             queriesPerPeriod: 1,
+            delay: 100,
             interval: 200, // start the query sooner
             timeout: 3000
           }