import { TextDecoder, TextEncoder } from 'util';

import test from 'ava';

import { createNode } from './node';

function delay(ms: number) {
  return new Promise((resolve) => setTimeout(resolve, ms));
}

test('Can publish message', async (t) => {
  const topic = 'news';

  const [node1, node2] = await Promise.all([createNode(), createNode()]);

  // Add node's 2 data to the PeerStore
  node1.peerStore.addressBook.set(node2.peerId, node2.multiaddrs);
  await node1.dial(node2.peerId);

  let node1Received = '';

  node1.pubsub.on(topic, (msg) => {
    node1Received = new TextDecoder().decode(msg.data);
    console.log(`node1 received: ${node1Received}`);
  });

  await node1.pubsub.subscribe(topic);

  // Will not receive own published messages by default
  node2.pubsub.on(topic, (msg) => {
    console.log(`node2 received: ${new TextDecoder().decode(msg.data)}`);
  });

  await node2.pubsub.subscribe(topic);

  const message = 'Bird bird bird, bird is the word!';

  await delay(1000);

  await node2.pubsub.publish(topic, new TextEncoder().encode(message));

  await delay(1000);

  t.deepEqual(node1Received, message);
});