From e7ad81afee149b7a5c8c588cf68ac08d9a066c29 Mon Sep 17 00:00:00 2001
From: Franck Royer <franck@royer.one>
Date: Tue, 23 Mar 2021 14:11:29 +1100
Subject: [PATCH] Re-add Publish test

---
 src/lib/waku_relay.spec.ts | 29 +++++++++++++++++++++++++++++
 1 file changed, 29 insertions(+)

diff --git a/src/lib/waku_relay.spec.ts b/src/lib/waku_relay.spec.ts
index b63dc49444..aaee067cef 100644
--- a/src/lib/waku_relay.spec.ts
+++ b/src/lib/waku_relay.spec.ts
@@ -66,6 +66,35 @@ describe('Waku Relay', () => {
     expect(protocols.findIndex((value) => value.match(/sub/))).to.eq(-1);
   });
 
+  // TODO: Fix this
+  it.skip('Publish', async function () {
+    this.timeout(10000);
+
+    const message = Message.fromUtf8String('JS to JS communication works');
+    // waku.libp2p.pubsub.globalSignaturePolicy = 'StrictSign';
+
+    const receivedPromise = waitForNextData(waku2.libp2p.pubsub);
+
+    await Promise.all([
+      new Promise((resolve) =>
+        waku1.libp2p.pubsub.once('gossipsub:heartbeat', resolve)
+      ),
+      new Promise((resolve) =>
+        waku2.libp2p.pubsub.once('gossipsub:heartbeat', resolve)
+      ),
+    ]);
+
+    await waku1.relay.publish(message);
+
+    const receivedMsg = await receivedPromise;
+
+    expect(receivedMsg.contentTopic).to.eq(message.contentTopic);
+    expect(receivedMsg.version).to.eq(message.version);
+
+    const payload = Buffer.from(receivedMsg.payload!);
+    expect(Buffer.compare(payload, message.payload!)).to.eq(0);
+  });
+
   describe('Interop: Nim', function () {
     describe('Nim connects to js', function () {
       let waku: Waku;