Differential D9386 Diff 22395 support/aphlict/server/aphlict_server.js

Changeset View

Standalone View

support/aphlict/server/aphlict_server.js

Show First 20 Lines • Show All 57 Lines • ▼ Show 20 Lines	console.log(
"less-privileged user after binding if you pass a user in the command "+		"less-privileged user after binding if you pass a user in the command "+
"line arguments with '--user=alincoln'.");		"line arguments with '--user=alincoln'.");
process.exit(1);		process.exit(1);
}		}

var net = require('net');		var net = require('net');
var http = require('http');		var http = require('http');
var url = require('url');		var url = require('url');
var querystring = require('querystring');

process.on('uncaughtException', function (err) {		process.on('uncaughtException', function (err) {
debug.log("\n<<< UNCAUGHT EXCEPTION! >>>\n\n" + err);		debug.log("\n<<< UNCAUGHT EXCEPTION! >>>\n\n" + err);
process.exit(1);		process.exit(1);
});		});

var flash_server = new JX.AphlictFlashPolicyServer()		var flash_server = new JX.AphlictFlashPolicyServer()
.setDebugLog(debug)		.setDebugLog(debug)
▲ Show 20 Lines • Show All 41 Lines • ▼ Show 20 Lines	if (request.method == 'POST') {

request.on('data', function (data) {		request.on('data', function (data) {
body += data;		body += data;
});		});

request.on('end', function () {		request.on('end', function () {
++messages_in;		++messages_in;

var data = querystring.parse(body);		var data = JSON.parse(body);
debug.log('notification: ' + JSON.stringify(data));		debug.log('notification: ' + JSON.stringify(data));
broadcast(data);		broadcast(data);
response.end();		response.end();
});		});
} else if (request.url == '/status/') {		} else if (request.url == '/status/') {
request.on('data', function(data) {		request.on('data', function(data) {
// We just ignore the request data, but newer versions of Node don't		// We just ignore the request data, but newer versions of Node don't
// get to 'end' if we don't process the data. See T2953.		// get to 'end' if we don't process the data. See T2953.
});		});

request.on('end', function() {		request.on('end', function() {
var status = {		var status = {
'uptime': (new Date().getTime() - start_time),		'uptime': (new Date().getTime() - start_time),
'clients.active': clients.getActiveListenerCount(),		'clients.active': clients.getActiveListenerCount(),
'clients.total': clients.getTotalListenerCount(),		'clients.total': clients.getTotalListenerCount(),
'messages.in': messages_in,		'messages.in': messages_in,
'messages.out': messages_out,		'messages.out': messages_out,
'log': config.log,		'log': config.log,
'version': 3		'version': 4
};		};

response.write(JSON.stringify(status));		response.write(JSON.stringify(status));
response.end();		response.end();
});		});
} else {		} else {
response.statusCode = 400;		response.statusCode = 400;
response.write('400 Bad Request');		response.write('400 Bad Request');
Show All 28 Lines