1
0
nodeMessageBoard/server.js

131 lines
3.9 KiB
JavaScript

var fs = require('fs'),
http = require('http'),
socketio = require('socket.io'),
url = require("url"),
serialport = require("serialport");
low = require('lowdb'),
storage = require('lowdb/file-async'),
db = low('db.json', { storage });
const port = 3000;
var SerialPort = serialport.SerialPort;
var socketServer;
var serialPort;
var portName = '/dev/tty.usbmodemFD121'; //change this to your Arduino port
var numberStringRecieved = "";
var numberRecieved = "";
var timeRecieved = "";
// utility function for ucs2 decode
function ucs2Parse(ucs2){
codeArray = ucs2.match(/.{1,4}/g);
var returnString = "";
for(i=0;i<codeArray.length;i++){
returnString += String.fromCharCode(parseInt(codeArray[i], 16));
}
return returnString;
}
// handle contains locations to browse to (vote and poll); pathnames.
function startServer(route,handle,debug)
{
// on request event
function onRequest(request, response) {
// parse the requested url into pathname. pathname will be compared
// in route.js to handle (var content), if it matches the a page will
// come up. Otherwise a 404 will be given.
var pathname = url.parse(request.url).pathname;
console.log("Request for " + pathname + " received");
var content = route(handle,pathname,response,request,debug);
}
var httpServer = http.createServer(onRequest).listen(port, function(){
console.log("Listening at: http://localhost:"+port);
console.log("Server is up");
});
serialListener(debug);
initSocketIO(httpServer,debug);
}
function initSocketIO(httpServer,debug)
{
socketServer = socketio.listen(httpServer);
if(debug == false){
socketServer.set('log level', 1); // socket IO debug off
}
socketServer.on('connection', function (socket) {
console.log("user connected");
socket.emit('onconnection');
socket.on('sendAT', function(data) {
serialPort.write('AT\r');
console.log('sending AT...');
});
socket.on('getLastMessages', function(number) {
console.log('retrieving messages');
var times = db('messages').chain().takeRight(number).map('time').value();
var numbers = db('messages').chain().takeRight(number).map('number').value();
var messages = db('messages').chain().takeRight(number).map('message').value();
for(var i = 0; i < messages.length; i++){
socket.emit('newMessage',times[i],numbers[i],messages[i]);
}
});
});
}
// Listen to serial port
function serialListener(debug)
{
var receivedData = "";
serialPort = new SerialPort(portName, {
baudrate: 19200,
parser: serialport.parsers.readline("\n")
});
serialPort.on("open", function () {
console.log('opened serial communication');
serialPort.on('data', function(data) {
console.log('Incomming serial data...\r');
console.log(data);
console.log("\r"); //+data.length
// send the incoming data to clients using the socket.
if(data.startsWith("+CMT:")){ // if message ok
numberStringRecieved = data;
numberRecieved = data.substring(data.indexOf('+CMT: "') + 7, data.indexOf('",'));
numberRecieved = ucs2Parse(numberRecieved);
timeRecieved = data.substring(data.indexOf('","","') + 15, data.indexOf('+04'));
} else if (data.length > 1) {
if(numberRecieved){
//console.log("emit");
var messageRecieved = ucs2Parse(data);
db('messages').push({ numberString: numberStringRecieved,number: numberRecieved, time: timeRecieved, message: messageRecieved });
//add a new message to the board directly
socketServer.emit('newMessage', timeRecieved, numberRecieved, messageRecieved);
numberStringRecieved = null;
numberRecieved = null;
timeRecieved = null;
}
else {
//console.log("nothing");
}
} else {
//debugMessages trigger an alert on the clients
//socketServer.emit('debugMessage', data);
}
});
serialPort.write('AT+CPIN=3797\r');
console.log("Sent Pincode...");
});
}
exports.start = startServer;