Private Chat Using Node js and socket.io with encrypt and decrypt message and insert into mongo db

-

node.js and socket.io chat tutorial

This is a very simple single-room chat client using node.js, socket.io and the express module.
i found that the ready availability of documentation and the eagerness of experienced individuals to help the newly adopting, throughout the node.js communities, allow for quicker learning and sharing of acquired skills
UPDATE: long overdue, but you can now skip the following step and just install via the .msi or .pkg files and they
include NPM – http://nodejs.org/#download
to begin, you must install node.js and npm along with their dependencies in Linux System
now, install the modules
curl -sL https://deb.nodesource.com/setup_6.x | sudo -E bash -

sudo apt-get install -y nodejs

 For Update 
sudo apt-get purge node-express
now, install the modules
npm install -d
let’s now create the server file, server.js
var express = require('express');
var app = express();
var server = require('http').createServer(app);
io = require('socket.io').listen(server);
var crypto = require('crypto');
var mongo = require("mongojs");
var db = mongo("database_name", ["table nam"]);
var response,algorithm = 'aes256';
server.listen(8081);

app.get('/', function (req, res) {
  res.sendfile(__dirname + '/index.html');
  console.log("server running");
});

io.sockets.on('connection', function (socket) {
  socket.on('register', function (name, email, password) {
    try {
      if (name == '') {
        response = {
          "success": "0"
          , data: {
            "msg": "please enter name"
          }
        }
        socket.emit("register_error", response);
      }
      else if (email == '') {
        response = {
          "success": "0"
          , data: {
            "msg": "Please enter emailid"
          }
        }
        socket.emit("register_error", response);
      }
      else if (password == '') {
        response = {
         "success": "0"
          , data: {
            "msg": "Please enter Password"
          }
        }
        socket.emit("register_error", response);
      }
      else {
        db.users.find({
          email: email
        }, function (err, users) {
          if (err) {
            response = {
            "success": "0"
            , data: {
             "msg": "error in singn up"
             }
            }
           socket.emit("register_error", response);
          }
          else {
            if (users.length == 0) {
              var newuser = ({
                name: name
                , email: email
                , password: password
                , datetime: new Date()
               
              });
              db.users.insert(newuser, function (err, result) {
               if (err) {
                 response = {
                "success": "0",
                  data: {
                 "msg": "Error In Insert user Data"
                }
              }
              socket.emit("register_error", response)
             }
                else {
                  response = {
                    "success": "1"
                    , data: [result]
                  }
                  socket.emit("register_detail", response);
                  socket.nickname = result._id;
                  user[socket.nickname] = socket;
                 
                }
              });
            }
            else {
              response = {
                "success": "0"
                , data: {
                 "msg": "This email Id is already Taken Please Login"
                }
              }
              socket.emit("register_error", response);
            }
          }
        });
      }
    }
    catch (err) {
      response = {
        "success": "0"
        , data: {
         "msg": "Error Handle in Catch"
        }
      }
      socket.emit("register_error", response);
    }
  });


socket.on('send_message', function (sender, receiver, message, hash)
 {
      try {
              
          var delivery;
           // Conveert id to mongo db object id
          var sender_id = new mongo.ObjectID(sender); 
          var receiver_id = new mongo.ObjectID(receiver);
          if (!user[receiver]) {
            delivery = "0";
          }
          else {
            delivery = "1";
          }
          if (!user[sender]) {
            socket.nickname = sender;
            user[socket.nickname] = socket;
           
          }
          var encrypt_message = encryptdata(message, hash);
          var msg = ({
            sender: sender_id
            , receiver: receiver_id
            , msg: encrypt_message
            , msgtype: "0"
            , datetime: new Date()
            , lastupdated: new Date().getTime()
            , isdeliver: delivery
            , isread: "0"
          });
        
          db.Chat.insert(msg, function (err, result) {
            if (err) {
              response = {
                "success": "0"
                , data: {
                  "msg": "Error In Insert Message" + err
                }
              }
              socket.emit('send_message_error', response)
            }
            else {
             
              var decrypt_message = decryptdata(result.msg, hash)
              response = {
                "success": "1"
                , data: [{
                  "_id": result._id
                  , "sender": result.sender
                  , "receiver": result.receiver
                  , "msg": decrypt_message
                  , "msgtype": result.msgtype
                  , "isdeliver": result.isdeliver
                  , "isread": result.isread                
                 }]
              }
              // send response to sender only
              user[sender].emit('send_message_detail', response);
              if (user[receiver]) {  // Check reciver is online or not
               user[receiver].emit('send_message_reciver', response);
              // if receiver is online send response to reciver only else not
              }
             
            }
          })
       
      }
      catch (err) {
        response = {
          "success": "0"
          , data: {
            "msg": "Error Handle in Catch" + err
          }
        }
      
        socket.emit("send_message_error", response);
      }
    })


socket.on('disconnect', function (data) {
    if (!socket.nickname) return;
       delete user[socket.nickname];
// remove user to global array
      });

function encryptdata(msg, key) {
    var cipher = crypto.createCipher(algorithm, key);
    var encrypted = cipher.update(msg, 'utf8', 'hex')
    + cipher.final('hex');
    return encrypted;
  }
  
  function decryptdata(hash, key) {
    var decipher = crypto.createDecipher(algorithm, key);
    var decrypted = decipher.update(hash, 'utf8', 'hex')
    + decipher.final('utf8');
    return decrypted;
  }

});



 now, let’s create the client file, index.html
<script src="http://code.Jquery.com/jquery-latest.min.js"></script>
<script src="socket.io/socket.io.js"></script>
<script>
var socket = io.connect();
var totaluser = [];
Array.prototype.remove = function () {
var what, a = arguments
    , L = a.length
    , ax;
while (L && this.length) {
 what = a[--L];
  while ((ax = this.indexOf(what)) !== -1) {
   this.splice(ax, 1);
 }
}
return this;
};

function Register() {
  $('#userWrap').show();
  $('#nickwrape').hide();
}

jQuery(function ($) {
 var $nickForm = $('#setNick');
 var $users = $('#users');
 var $messageForm = $('#send_message');
 var $messagebox = $('#message');
 var $chat = $('#chat');
 var $userdata = $('#userdata');
 var $uname = $('#uname');
 var $mobile = $('#mobile');
  var $usr = $('#user');

$userdata.submit(function (e) {
 e.preventDefault();
socket.emit('register', $uname.val(), $mobile.val()))
 $uname.val('');
 $mobile.val('');
});

socket.on('register_error', function (data) {
 $usr.html(data);
})

$messageForm.submit(function (e) {
 e.preventDefault();
 socket.emit('send_message', messagebox.val(),totaluser.toString(),
function (data) {
 $chat.append('<span class="error">' + data + '</span><br/>');
});
$messagebox.val('');
});

});
</script>
run the server
node app.js

load up http://localhost:8081 in your browser



Comments

Post a Comment

Popular posts from this blog

How To Migrate MVC 3 Application To MVC 5

-
Image
Introduction In this article we discuss about how to migrate an MVC 3 application to MVC 5. Step 1:  Open your MVC 3 application in Visual Studio and change the .net framework to 4.7.2 as MVC 5 runs on this framework. MVC 3 Project Property Project → Properties → Application → Target Framework → 4.7.2 For Set MVC 5  Note:  targetFramework in Web.Config will be changing to 4.7.2 Step 2:  Install Asp.Net MVC 5 version through Package Manager Console. Run this Command: Install-Package Microsoft.AspNet.Mvc -Version 5.7.2 Nuget Package Manage → Package Manager Console and run above command. Step 3:  Go to Web.Config(root level) and change, <add key="webpages:Version" value="1.0.0.0" /> to <add key="webpages:Version" value="3.0.0.0" /> webpages:Version Step 4:  Check System.Web.Razor, System.Web.Helpers, System.WebPages.Razor versions. These all should be having versions 3.0.0.0. If th...
Read more

Populate a drop-down in Vue.js and Asp.net Core from an ajax call

-
Image
  If you want to call a function on page load and Bind Drop down  List in Vue js then in this example i will show you how to trigger function on page load in vue js. we will run function on page load vue application. we mostly require to call method on page load in our application. so you want to call function in Vue.js app then you can do it using created option in vue js. So i will give full example so you can check it out. Index . cshtml < div id ="apps">     < div class ="form-group">         < label class ="control-label"> State </ label >         < select v-model ="state" class ="form-control" v-on:change ="getcity($event)">             < option v-for ="state in States" : value ="state.stateId"> {{ state.stateName }} </ option >       ...
Read more

Building a CRUD Application with Ag-Grid

-
Image
To Create Crud operation In Ag-Grid using C# MVC here Is a Download Link  Click here.. Bundle Config bundles.Add( new ScriptBundle( "~/bundles/jquery" ).Include(                          "~/Scripts/jquery-1.12.4.js" ,                         "~/Scripts/jquery-ui-1.12.1.js" ,                         "~/Scripts/bootstrap.js" ,                           "~/Scripts/jquery.validate*" ,                     ...
Read more