client.js

"use strict";

const nkn = require("../lib");

const useMultiClient = true;

(async function () {
  let Client = useMultiClient ? nkn.MultiClient : nkn.Client;
  let alice = new Client({ identifier: "alice" });
  let bob = new Client({ identifier: "bob" });

  console.log("Secret seed:", alice.getSeed());

  alice.onConnectFailed(() => {
    console.error("Alice connect failed");
  });

  if (useMultiClient) {
    for (let clientID of Object.keys(alice.clients)) {
      alice.clients[clientID].onConnectFailed(() => {
        console.error("Alice client", clientID, "connect failed");
      });
    }
  }

  await Promise.all([
    new Promise((resolve, reject) => alice.onConnect(resolve)),
    new Promise((resolve, reject) => bob.onConnect(resolve)),
  ]);

  await new Promise((resolve, reject) => setTimeout(resolve, 1000));

  let timeSent = Date.now();

  bob.onMessage(async ({ src, payload, isEncrypted }) => {
    console.log(
      "Receive",
      isEncrypted ? "encrypted" : "unencrypted",
      "message",
      '"' + payload + '"',
      "from",
      src,
      "after",
      Date.now() - timeSent,
      "ms",
    );
    // For byte array response:
    // return Uint8Array.from([1,2,3,4,5])
    return "Well received!";
  });

  try {
    console.log("Send message from", alice.addr, "to", bob.addr);
    // For byte array data:
    // let reply = await alice.send(bob.addr, Uint8Array.from([1,2,3,4,5]));
    let reply = await alice.send(bob.addr, "Hello world!");
    console.log(
      "Receive reply",
      '"' + reply + '"',
      "from",
      bob.addr,
      "after",
      Date.now() - timeSent,
      "ms",
    );
  } catch (e) {
    console.error(e);
  }

  alice.close();
  bob.close();
})();