martin/SilvrAPI
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

socket stuff

Browse Source
This commit is contained in:
Martin Donnelly 2016-02-17 11:09:57 +00:00
parent 775cd483a3
commit 6e2dd22533
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
routes/temp.js
View File

@ -140,12 +140,12 @@ busEmitter.on('saveTempData', doInsertEvent);
logger.info('Configuring WebSocket Listener...');
var server = http.createServer(function (request, response) {
console.log((new Date()) + ' Received request for ' + request.url);
logger.info((new Date()) + ' Received request for ' + request.url);
response.writeHead(404);
response.end();
});
server.listen(8031, function () {
console.log((new Date()) + ' Server is listening on port 8080');
logger.info((new Date()) + ' Server is listening on port 8031');
});
var wsServer = new WebSocketServer({
httpServer: server,
@ -167,12 +167,12 @@ wsServer.on('request', function (request) {
if (!originIsAllowed(request.origin)) {
// Make sure we only accept requests from an allowed origin
request.reject();
console.log((new Date()) + ' Connection from origin ' + request.origin + ' rejected.');
logger.debug((new Date()) + ' Connection from origin ' + request.origin + ' rejected.');
return;
}
var connection = request.accept('', request.origin);
console.log((new Date()) + ' Connection accepted.');
logger.debug((new Date()) + ' Connection accepted.');
var sendSocketHandler = (obj) => {
// logger.info('sendSocket: ' + JSON.stringify(obj));
@ -182,18 +182,18 @@ wsServer.on('request', function (request) {
connection.on('message', function (message) {
if (message.type === 'utf8') {
console.log('Received Message: ' + message.utf8Data);
logger.debug('Received Message: ' + message.utf8Data);
connection.sendUTF(message.utf8Data);
}
else if (message.type === 'binary') {
console.log('Received Binary Message of ' + message.binaryData.length + ' bytes');
logger.debug('Received Binary Message of ' + message.binaryData.length + ' bytes');
connection.sendBytes(message.binaryData);
}
});
connection.on('close', function (reasonCode, description) {
console.log((new Date()) + ' Peer ' + connection.remoteAddress + ' disconnected.');
logger.debug((new Date()) + ' Peer ' + connection.remoteAddress + ' disconnected.');
busEmitter.removeListener('sendSocket', sendSocketHandler);
});
});;
});;;