Code Base var dbutil = require('../ util / dbutil '); var uuidv1 = require(' uuid /v1'); function successfullMessage (response){ if(response){ // response.jsonp (200,'Successfully Executed Query'); console.log ('Successfully Executed Query'); } } function errorMessage (response){ if(response){ // response.jsonp (200,'Errorin Executing the Query'); console.log (' Errorin Executing the Query'); } } var persistence = { saveMessage:function ( message,response ){ message.msg_id =1; message.msg_attachment =' abc.gif '; message.msg_fromname ='Shyam'; message.msg_seentime = 1; message.msg_deliverytime = 1; message.msg_senttime =1; message.msg_status =112121; message.msg_type ='txt'; message.msg_fromid =11212; message.msg_toid =21212; message.msg_entitytype ='group'; message.msg_toname ="ram"; message.msg_txt = message.msg_txt ; console.log ("Message :::"+ JSON.stringify (message)); console.log ("inside the Save Method") ; var params =[ message.msg_id , message.msg_attachment , message.msg_deliverytime , message.msg_entitytype , message.msg_fromid , message.msg_fromname , message.msg_seentime , message.msg_senttime , message.msg_status , message.msg_toid , message.msg_toname , message.msg_txt , message.msg_type ]; // var query= "INSERT INTO chat_history ("+ config.MSG_ID +", "+ config.MSG_TYPE +", "+ config.FROM +", "+ config.TO +", "+ config.FROM_NAME +", "+ config.TO_NAME +", "+ config.MSG +", "+ config.ENTITY_TYPE +", "+ config.STATUS +", "+ config.TIME +","+ config.ATTACHMENT +")"+ // "VALUES("+ msg_id +",'"+ chatMessageData [ config.MSG_TYPE ]+"', "+ chatMessageData [ config.FROM ]+","+ chatMessageData [ config.TO ]+", '"+ chatMessageData [ config.FROM_NAME ]+"','"+ chatMessageData [ config.TO_NAME ]+"','"+ chatMessageData [ config.MSG ]+"','"+ chatMessageData [ config.ENTITY_TYPE ]+"',"+ config.SENT +","+ msg_senttime +",’ "+ chatMessageData [ config.ATTACHMENT ]+"')"; var query= "INSERT INTO iconmaconnect.chathistory ( msg_id , msg_attachment , msg_deliverytime , msg_entitytype , msg_fromid , msg_fromname , msg_seentime , msg_senttime , msg_status , msg_toid , msg_toname , msg_txt , msg_type ) VALUES ("+ message.msg_id +","+ message.msg_attachment +","+ message.msg_deliverytime +","+ message.msg_entitytype +","+ message.msg_fromid +","+ message.msg_fromname +", "+ message.msg_seentime +","+ message.msg_senttime +","+ message.msg_status +","+ message.msg_toid +","+ message.msg_toname +","+ message.msg_txt +","+ message.msg_type +");" console.log ("Formed Query"+query ); dbutil.executeQuery ( query,response,function (){ errorMessage (response); },function (){ successfullMessage (response); }); }, } module.exports =persistence; var config = require('./config'); var Redis = require(' ioredis '); // var server = require('http'). createServer (); var cassandra = require(' cassandra -driver'); var redisadapter = require(' socket.io-redis '); var persist = require('./database/persistence'); var express = require('express') var app = express(); var server = require('http').Server(app); var io = require(' socket.io ')(server); const fileUpload = require('express- fileupload '); require('events').EventEmitter.prototype._ maxListeners = 100; app.use ( fileUpload ({ limits: { fileSize : 50 * 1024 * 1024 }, })); app.use ( express.static (__ dirname + '/public')); var io = require(' socket.io ')(server, { /* following options are for maintaing the socket connectivity interval with the server */ pingInterval : 25000, pingTimeout : 60000, });