swarm discovery

swarm.js

var swarm = require('discovery-swarm');
const crypto = require('crypto');
const net = require('net');
const topic = crypto.createHash('sha256')
    .update('my key')
    .digest();
console.log('args',process.argv);
const port = process.argv[2] || 10001;
var sw = swarm({
    dns:{
        server:['192.168.31.1']
    }
})
const sockets = [];
const metadata = new WeakMap();
sw.listen(port);
sw.join(topic) // can be any id/name/hash

sw.on('connection', function (peerSocket,info) {

    console.log('peer info',info);
    if(!info.channel || info.channel !== topic){
        return;
    }

    sockets.push(peerSocket);
    peerSocket.on('data', function (data) {
        console.log('on data', data.toString());
        try{
            
            metadata.set(peerSocket,JSON.parse(data.toString()));
        }catch(err){
            //
        }
    });
    peerSocket.on('close', function () {
        sockets.splice(sockets.indexOf(peerSocket),1);
        console.log('Connection closed',sockets.length);
    });
    peerSocket.write(JSON.stringify({
        namespace:'test '+port
    }));
    console.log('total sockets',sockets.length);
});