forked from lbsadmin/nodeMessageBoard
178 lines
5.7 KiB
JavaScript
178 lines
5.7 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 });
|
|
|
|
var convert = require('emojize').emojize;
|
|
|
|
var SerialPort = serialport.SerialPort;
|
|
var config = low('config.json', { storage });
|
|
var socketServer;
|
|
var port = config('mainConfig').chain().find({ param: 'port' }).value()['value'];
|
|
var serialPort;
|
|
var portName = config('mainConfig').chain().find({ param: 'serialport' }).value()['value'];
|
|
|
|
var numberStringRecieved = "";
|
|
var numberRecieved = "";
|
|
var timeRecieved = "";
|
|
var color = 0;
|
|
|
|
// 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;
|
|
}
|
|
|
|
// utility function for escaping HTML tags
|
|
function escapeHtml(unsafe) {
|
|
return unsafe
|
|
.replace(/&/g, "&")
|
|
.replace(/</g, "<")
|
|
.replace(/>/g, ">")
|
|
.replace(/"/g, """)
|
|
.replace(/'/g, "'");
|
|
}
|
|
|
|
|
|
|
|
|
|
// handle contains locations to browse to (vote and poll); pathnames.
|
|
function startServer(route,handle,debug)
|
|
{
|
|
|
|
db('messages').size(); //call this once to establish the db if there is nothing in the json file
|
|
var mynumber = config('mainConfig').chain().find({ param: 'mynumber' }).value()['value'];
|
|
if(db('messages').size() == 0)db('messages').push({ numberString: "",number: mynumber, time: "now", message: "SMS MessageBoard",color: 0 });
|
|
|
|
// 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('clear', function(number) {
|
|
|
|
var index = db.object.messages.length - number;
|
|
db.object.messages.splice(index,1);
|
|
db.write();
|
|
|
|
console.log('removed entry ' + number)
|
|
});
|
|
|
|
socket.on('getConfig', function(data) {
|
|
var number = config('mainConfig').chain().find({ param: 'mynumber' }).value()['value'];
|
|
socket.emit('config',number);
|
|
});
|
|
|
|
socket.on('sendAT', function(data) {
|
|
serialPort.write('AT\r');
|
|
console.log('sending AT...');
|
|
});
|
|
|
|
socket.on('refreshClients', function() {
|
|
console.log('Refreshing all clients');
|
|
socketServer.emit('clientrefresh'); // send this to all so use socketServer
|
|
});
|
|
|
|
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();
|
|
var colors = db('messages').chain().takeRight(number).map('color').value();
|
|
|
|
for(var i = 0; i < messages.length; i++){
|
|
socket.emit('newMessage',times[i],numbers[i],convert(messages[i]),colors[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('+0')); // the end of this string has to do with time zone and daylightsaving time mode
|
|
} else if (data.length > 1) {
|
|
|
|
if(numberRecieved){
|
|
//console.log("emit");
|
|
var color = db('messages').chain().takeRight(1).map('color').value();
|
|
console.log(JSON.stringify(color));
|
|
if (color == null)color = 0;//no messages yet
|
|
color++;
|
|
if(color > 4) color = 0;
|
|
var messageRecieved = escapeHtml(ucs2Parse(data));
|
|
db('messages').push({ numberString: numberStringRecieved,number: numberRecieved, time: timeRecieved, message: messageRecieved,color: color });
|
|
//add a new message to the board directly
|
|
socketServer.emit('newMessage', timeRecieved, numberRecieved, convert(messageRecieved),color);
|
|
numberStringRecieved = null;
|
|
numberRecieved = null;
|
|
timeRecieved = null;
|
|
}
|
|
else {
|
|
//console.log("nothing");
|
|
}
|
|
} else {
|
|
//debugMessages trigger an alert on the clients
|
|
//socketServer.emit('debugMessage', data);
|
|
}
|
|
});
|
|
var pincode = config('mainConfig').chain().find({ param: 'pincode' }).value()['value'];
|
|
serialPort.write('AT+CPIN='+pincode+'\r');
|
|
console.log("Sent Pincode...");
|
|
});
|
|
}
|
|
|
|
|
|
exports.start = startServer;
|