var ActiveClient = require('./Redis/ActiveUsers')
var Alerts = require('./Notifications/alerts')
var TimeConvert = require('./TimeConversion/ConvertTime')
var Status = require('./Status/Status')
var rp = require('request-promise');
var SendMessage = require('./Actions/Send/Send');
var ReceiveMessage = require('./Actions/Receive/Receive');
var Tracking = require('./Actions/Receive/ChatHistory');
var jwt = require('jsonwebtoken');
var Login = require('./Routes/LoginHandling');
const PORT = 3600;
var Promise = require('bluebird');
var request = require('request');
var parser = require('json-parser');
var bodyParser = require('body-parser')
var jsonParser = bodyParser.json();
const express = require('express');
const http = require('http');
const app = express();
/**
 * Create HTTP server.
 */
var server = require('http').createServer();
var io = require('socket.io')(server);
io.set('origins', '*');
// io.attach(client)

server.listen(PORT, () => console.log(`API running on localhost:${PORT}`));
io.origins(['http://localhost:4200']);

server.listen(9200, () => console.log("Starting Server On Port Number:" + PORT));

var nsp = io.of('/chat');
nsp.on('connection', function (socket) {
    console.log(' Connection established');
    socket.on('private', function (data) {
        let chat_object = JSON.parse(data.chat_object);
        let message = chat_object.text;
        let recipient = chat_object.to;
        let sender = chat_object.from;
        let date = chat_object.date;
        let read_flag = chat_object.read;
        let message_pending_for = recipient;

        let _active_users = new ActiveClient();
        _active_users.add_new_client(sender, socket.id);
        _active_users.does_client_exist(recipient)
            .then(res => {
                if (res === 1) {
                    _active_users.get_client_key(recipient)
                        .then(socket_id => {
                            console.log('======='+io.sockets.name)
                            console.log('I am sending the message to: '+ recipient + 'and my socket id is'+ socket_id)
                        //    socket.to(socket_id)socket.emit('incoming', "this is top secret"
                        io.of('/chat').to(socket_id).emit('incoming', "this is top secret")

                        })
                        .catch(error => {
                            console.log("COULD NOT RETRIEVE KEY: " + error)
                        })
                }
            })
            .catch(error => {
                console.log("Message Not Delivered To Recipient" + error)
            })

    })