Required NPM Packages

var express         = require(‘express’);

var router            = express.Router();

…

//define the controller’s method and map the request URL ‘/’ to this method

router.get(‘/’, function(req, res)

…

app.use(bodyParser.json());

app.use(bodyParser.urlencoded({ extended: true }));

…

//Getting parameters values from req.body

var customer = new Customer(0, req.body.firstname, req.body.lastname, req.body.telephone, req.body.email, req.body.age, req.body.gender, req.body.username, req.body.password);

app.set(‘views’, __dirname + ‘/app/views’);

app.set(‘view engine’, ‘ejs’);

…

//Output the results to related ejs template

res.render(‘customer/new‘, { title: ‘New Customer’, msgType: ”, msg: ”, customer: customer});

//check if logFolder is existing. Otherwise, create this folder

fs.existsSync(logFolder) || fs.mkdirSync(logFolder);

…

//Logger details

var logFileStream = FileStreamRotator.getStream({

date_format:   ‘YYYY-MM-DD’,

filename:           logFolder + ‘/demo2_%DATE%.log‘,

frequency:        ‘daily‘,

verbose:            false

});

//Assign the logger with file stream

app.use(morgan(‘combined’, {stream: logFileStream}));

var mysql             = require(‘mysql’);

//Declare MySQL connection pool

var pool =  mysql.createPool({

host:                      ‘localhost’,

user:                      ‘root’,

password:           ‘root’,

database:            ‘itblogs2’,

port:                      3306

});

…

//Getting DB connection from connection pool, and then running SQL

exports.runQuery = function(query,callback) {

//Making Query

pool.getConnection(function(err, connection){

connection.query( query, function(err, rows){

if(err)    {

throw err;

}else{

console.log( query );

callback(rows);

}

});

connection.release();

});

};

200 – HttpStatus.OK

404 – HttpStatus.NOT_FOUND

409 – HttpStatus.CONFLICT

…

//response the request with HTTP status 200 – HttpStatus.OK

res.send( HttpStatus.OK );

…

app.use(express.static( path.join(__dirname, ‘/public’)));

var io                                     = require(‘socket.io’)();

…

//When new client is connected

io.on(‘connection’, function (socket) {

console.log(‘hello… you are connected (id=’ + socket.id + ‘).’);

_socket = socket;

//Receiving incoming message ‘message_reply’

socket.on(‘message_reply’, function(msg) {

console.info(‘message_reply : ‘+msg);

});

//When disconnect

socket.on(‘disconnect’, function() {

console.info(‘Socket id=’ + _socket.id + ‘ has gone.’);

});

});

var io                     = require(‘socket.io-client’);

var client              = io.connect(‘http://localhost:3000’);

…

//Receiving incoming message ‘ping_client’

client.on(‘ping_client’, function(msg) {

console.info(‘Receiving ping message from server : ‘+msg);

//Send message to server

client.emit(‘message_reply’, ‘Hi server, got your message’);

console.info(‘Sending ack message to server’);

});