relay.js

'use strict';

require('debug-trace')({ always: true });

const SEEDS = {
  origin: 'unknown burger engine plug teach spot squeeze fringe ethics skate riot brand hurry melody double then trumpet impulse lesson inflict enlist eager region ride',
  relayer: 'salmon asthma decorate oxygen relief excite lamp huge bunker tennis spread chase liar glass shoe giant crane drama media step crack decline ring stay',
  destination: 'frown equal zero tackle relief shallow leisure diet roast festival good plunge pencil virus vote property blame random bacon rich ecology major survey slice'
}

const DESTINATION_ID = 'mt4Wm6TW4ejU51iviiD73ECNCfRsjiBhQf';

const Peer = require('../types/peer');
const Message = require('../types/message');

async function main () {
  const swarm = {
    origin: new Peer({
      listen: true,
      wallet: {
        seed: SEEDS.origin
      }
    }),
    relayer: new Peer({
      port: 7778,
      peers: ['localhost:7777'],
      listen: true,
      wallet: {
        seed: SEEDS.relayer
      }
    }),
    destination: new Peer({
      peers: ['localhost:7778'],
      wallet: {
        seed: SEEDS.destination
      }
    })
  };

  swarm.origin.on('peer:candidate', async function (peer) {
    console.log('[EXAMPLES:RELAY]', 'Origin Peer emitted "peer:candidate" event:', peer);

    if (peer.id === DESTINATION_ID) {
      console.warn('[EXAMPLES:RELAY]', 'Peer event was destination peer!');
      console.warn('[EXAMPLES:RELAY]', 'Origin node peers:', swarm.origin.peers);
      console.warn('[EXAMPLES:RELAY]', 'Relay node peers:', swarm.relayer.peers);
      console.warn('[EXAMPLES:RELAY]', 'Destination node peers:', swarm.destination.peers);

      let message = Message.fromVector(['Generic', 'Hello, world!']);
      await swarm.origin.broadcast(message);
    }
  });

  swarm.destination.on('message', async function handleSwarmMessage (msg) {
    console.log('[EXAMPLES:RELAY]', 'Got message on destination:', msg);
  });

  console.log('[EXAMPLES:RELAY]', 'Starting origin Peer...');
  await swarm.origin.start();
  console.log('[EXAMPLES:RELAY]', 'Origin Peer started!');

  console.log('[EXAMPLES:RELAY]', 'Starting relayer Peer...');
  await swarm.relayer.start();
  console.log('[EXAMPLES:RELAY]', 'Relayer Peer started!');

  console.log('[EXAMPLES:RELAY]', 'Starting destination Peer...');
  await swarm.destination.start();
  console.log('[EXAMPLES:RELAY]', 'Destination Peer started!');
}

main().catch(function exceptionHandler (exception) {
  console.error('[EXAMPLES:RELAY]', 'Main process threw Exception:', exception);
});