'use strict' const Libp2p = require('../..') const TCP = require('libp2p-tcp') const Mplex = require('libp2p-mplex') const { NOISE } = require('libp2p-noise') const pipe = require('it-pipe') const createNode = async () => { const node = await Libp2p.create({ addresses: { listen: ['/ip4/0.0.0.0/tcp/0'] }, modules: { transport: [TCP], streamMuxer: [Mplex], connEncryption: [NOISE] } }) await node.start() return node } ;(async () => { const [node1, node2] = await Promise.all([ createNode(), createNode() ]) node1.peerStore.addressBook.set(node2.peerId, node2.multiaddrs) node2.handle('/a-protocol', ({ stream }) => { pipe( stream, async function (source) { for await (const msg of source) { console.log(msg.toString()) } } ) }) const { stream } = await node1.dialProtocol(node2.peerId, '/a-protocol') await pipe( ['This information is sent out encrypted to the other peer'], stream ) })();