socket.js

app = require('express')();
server = require('http').Server(app);
io = require('socket.io')(server);
redis = require('redis');
request=require('request');

//online users and pharmacies
user=[];
//holding key as socket

customerSocket={valid_key:  undefined};
//holding id as key
customerId={valid_key:  undefined};
//holding key as socket

pharmacySocket={valid_key:  undefined};
//holding id as key
pharmacyId={valid_key:  undefined};


server.listen(8890);
io.on('connection', function (socket) {

    socket.on('addCustomer',function(data){
        console.log("new customer added with id"+data.id);
        customerSocket[data.socket_id]=data;
        customerId[data.id]=data;

        }
    );


    // console.log(socket.id);
//init redis
    redisClient = redis.createClient();

    redisClient.subscribe('message');
    redisClient.subscribe('notification');
    redisClient.subscribe('addPharmacy');
    redisClient.subscribe('pharmacyToCustomerResponse');


    socket.on('disconnect', function() {

        if(customerSocket.hasOwnProperty(socket.id))
        {
            console.log("customer disconnected");
             CustomerId=(customerSocket[socket.id]).id;
            delete   customerSocket[socket.id];
            delete   customerId[CustomerId];
            console.log(" customer disconnected! with id "+ customerId.toString());

            return;
        }
        else if(pharmacySocket.hasOwnProperty(socket.id)){
        var json = {
            "user":pharmacySocket[socket.id]
        };
        var options = {
            url: 'http://Localhost/findmydrug/public/api/v1/setoffline?token='+
        //    url: 'http://192.168.1.7/public/api/v1/setoffline?token='+
            pharmacySocket[socket.id].token,
            method: 'POST',
            headers: {
                'Content-Type': 'application/json'
            },
            json: json
        };
        request(options, function(err, res, body) {
            if (res && (res.statusCode === 200 || res.statusCode === 201)) {
                console.log("pharmacy setoffline successed");
            }
            else {
                console.log(err);
                console.log(res.body);
            }
        });
        //io.emit("goOffline","new notification available..");

        pharmaId=(pharmacySocket[socket.id]).id;
        delete   pharmacySocket[socket.id];
        delete   pharmacyId[pharmaId];
        console.log("pharmacy offline with id "+pharmaId);
        redisClient.quit();
        }
    });


});


redisClient = redis.createClient();

redisClient.subscribe('message');
redisClient.subscribe('notification');
redisClient.subscribe('addPharmacy');
redisClient.subscribe('pharmacyToCustomerResponse');


redisClient.on("message", function(channel, message) {
    //console.log("new message in queue "+ channel + "channel");
    //console.log(message);
    // console.log("new request sent");
    message=JSON.parse(message);
    console.log(channel);
    if(channel=="pharmacyToCustomerResponse"){
        console.log("pharmacy customer response");
        pharmacyToCustomerResponse(message);
    }
    if(channel=="addPharmacy"){
        addPharmacy(message);
    }
    if(channel=="notification"){

        // io.emit("notification","ok");
        for(var i of message.pharmacies) {


            if (i != undefined) {
                console.log("notification to pharmacy id " +
                    i);
                io.to(pharmacyId[i].socketId).emit("notification", message);

            }
        }
        /*  if(pharmacyId!=undefined)
         {
         console.log('i:'+i);
         console.log(pharmacyId[i]);
         io.socket.connected[pharmacyId[i].socketId].emit("notification",message);}
         }*/
    }
});
//add pharmacy
function addPharmacy(pharmacyJsonData)
{


    pharmacySocketId=pharmacyJsonData.socketId;

    pharmaId=pharmacyJsonData.id;

    pharmacySocket[pharmacySocketId]=pharmacyJsonData;
    pharmacyId[pharmaId]=pharmacyJsonData;
    console.log("new pharmacy is online with id "+pharmaId);
  //  console.log(" new user added with socket->"+pharmacySocketId);
   // console.log(" id->"+pharmaId);
    //io.emit("notification","new notification available");
    // console.log(pharmacyId);
    //console.log(pharmacySocket);

}
function pharmacyToCustomerResponse(data)
{
    //sending request back to customer

    if(customerId[data.user_id]==undefined)
    {
        console.log("a request was sent while client is offline , cannot be handled" +
            "by our simple technology");
        return ;
    }
    var CustomerSocketId=customerId[data.user_id].socket_id;
    dataToSend={
        "pharmacy_id":data.pharmacy.id,
        "pharmacy_name":data.pharmacy.name,
        "drug_id":data.drug_id,
        "drug_name":data.drug_name,
        "user_id":data.user_id
    };
    console.log("data sent to customer from pharmacy -> ")
    console.log(dataToSend);
    if(CustomerSocketId!=null) {
        if(CustomerSocketId!=undefined)
        io.to(CustomerSocketId).emit("pharmacyResponse", dataToSend);
    }
}