Differential D9396 Diff 22415 support/aphlict/server/aphlict_server.js

Changeset View

Standalone View

support/aphlict/server/aphlict_server.js

Show First 20 Lines • Show All 114 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 = JSON.parse(body);		var msg = JSON.parse(body);
debug.log('notification: ' + JSON.stringify(data));		debug.log('notification: ' + JSON.stringify(msg));
broadcast(data);		broadcast(msg.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': 4		'version': 5
};		};

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