diff --git a/routes/temp.js b/routes/temp.js index 5aa17dc..2de353b 100644 --- a/routes/temp.js +++ b/routes/temp.js @@ -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); }); -});; +});;;