Server : Apache/2.4.41 (Ubuntu) System : Linux absol.cf 5.4.0-198-generic #218-Ubuntu SMP Fri Sep 27 20:18:53 UTC 2024 x86_64 User : www-data ( 33) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wifcontinued,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_get_handler,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,pcntl_async_signals,pcntl_unshare, Directory :  /proc/thread-self/root/usr/share/emscripten/tests/sockets/p2p/broker/

Upload File : current_dir [ Writeable ] document_root [ Writeable ]

var crypto = require('crypto');
var fs = require('fs');
var https = require('https');

var SSL_KEY = 'ssl/ssl.key';
var SSL_CERT = 'ssl/ssl-unified.crt';
var PORT = 8080;

var sslSupported = false;
if(fs.existsSync(SSL_KEY) && fs.existsSync(SSL_CERT) && fs.statSync(SSL_KEY).isFile() && fs.statSync(SSL_CERT).isFile()) {
	sslSupported = true;
}

function handler(req, res) {
  res.writeHead(200);
  res.end("p2p");
};

var app, port;
if(sslSupported) {
	var sslopts = {
	  key: fs.readFileSync(SSL_KEY),
	  cert: fs.readFileSync(SSL_CERT)
	};
	sslopts.agent = new https.Agent(sslopts);
	app = require('https').createServer(sslopts, handler);
	port = 8081;
	console.info('ssl mode enabled');
} else {
	app = require('http').createServer(handler);
	port = 8080;
	console.info('ssl mode disabled');
}
console.info('listening on port', port);

var io = require('socket.io').listen(app, {
	'log level': 2
});

app.listen(port);

var jsMime = {
  type: 'application/javascript',
  encoding: 'utf8',
  gzip: true
};

io.static.add('/p2p-client.js', {
	mime: jsMime,
  file: 'client/p2p-client.js'
});

/*
io.static.add('/p2p-client.min.js', {
	mime: jsMime,
	file: 'client/p2p-client.min.js'
});
*/

function mkguid() {
  return 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function(c) {
    var r = Math.random()*16|0, v = c == 'x' ? r : (r&0x3|0x8);
    return v.toString(16);
  }).toUpperCase();
};

var peers = {};
var hosts = {};

var E = {
		OK: 'ok'
	, NOROUTE: 'no such route'
	, ISNOTHOST: 'peer is not a host'
};

function Peer(socket) {
	this.socket = socket;
	this.host = null;
};

function Host(options) {
	this.route = options['route'];
	this.url = options['url'];
	this.listed = (undefined !== options['listed']) ? options['listed'] : false;
	this.metadata = options['metadata'] || {};
	this.ctime = Date.now();
	this.mtime = Date.now();
};
Host.prototype.update = function update(options) {
	this.url = options['url'];
	this.listed = (undefined !== options['listed']) ? options['listed'] : false;
	this.metadata = options['metadata'] || {};
	this.mtime = Date.now();
};

io.of('/peer').on('connection', function(socket) {
	var route = crypto.createHash('md5').update(socket['id']).digest('hex');
	socket.emit('route', route);

	socket.on('disconnect', function() {
		if(hosts[route]) {
			var host = hosts[route];
			changeList('remove', host);
		}
		delete hosts[route];
		delete peers[route];
	});

	socket.on('send', function(message, callback) {
		var to = message['to'];

		if(!peers.hasOwnProperty(to)) {
			callback({'error': E.NOROUTE});
			return;
		}

		var from = route;
		var data = message['data'];
		peers[to].emit('receive', {
			'from': from,
			'data': data
		});
	});

	socket.on('listen', function(options, callback) {
		options['route'] = route;
		if(hosts.hasOwnProperty(route)) {
			hosts[route].update(options);
			changeList('update', hosts[route]);
		} else {
			hosts[route] = new Host(options);
			changeList('append', hosts[route]);
		}

		callback();
	});

	socket.on('ignore', function(message, callback) {
		if(!hosts.hasOwnProperty(route)) {
			callback({'error': E.ISNOTHOST});
			return;
		}

		var host = hosts[route];
		delete hosts[route];

		changeList('remove', host);

		callback();
	});

	peers[route] = socket;
});

function Filter(socket, options) {
	this.options = options || {};
	this.socket = socket;
};
Filter.prototype.test = function test(host) {
	var filter = this.options;
	var result;

	if(filter['url'] && typeof host['url'] === 'string') {
		try {
			result = host['url'].match(filter['url']);
			if(!result)
				return true;
		} catch(e) {
			return true;
		}
	}

	if(filter['metadata'] && host['metadata']) {
		var metadataFilter = filter['metadata'];
		var metadataHost = host['metadata'];

		if(metadataFilter['name'] && typeof metadataHost['name'] === 'string') {
			try {
				result = metadataHost['name'].match(metadataFilter['name']);
				if(!result)
					return true;
			} catch(e) {
				return true;
			}
		}
	}

	return false;
};

var lists = {};

function changeList(operation, host) {
	var clients = Object.keys(lists);
	clients.forEach(function(client) {
		var filter = lists[client];
		if(!host['listed'])
			return;
		if(!filter.test(host)) {
			var data = operation === 'remove' ? host['route'] : host;
			filter.socket.emit(operation, data);
		}
	});
};

io.of('/list').on('connection', function(socket) {
	var id = socket['id'];

	socket.on('disconnect', function() {
		delete lists[id];
	});

	socket.on('list', function(options) {
		var filter = new Filter(socket, options);

		var result = [];

		var hostIds = Object.keys(hosts);
		hostIds.forEach(function(hostId) {
			var host = hosts[hostId];
			if(!host['listed'])
				return;
			if(!filter.test(host))
				result.push(host);
		});

		lists[id] = filter;

		socket.emit('truncate', result);
	});
});