const mongo = require('mongodb').MongoClient;
const client = require('socket.io').listen(4000).sockets;
const mysql = require('mysql');
const cookie = require('cookie');

const Memcached = require('memcached');
const PHPUnserialize = require('php-unserialize');


var connection = mysql.createConnection({
    host: 'localhost',
    user: 'bugsbenny96',
    password: 'password',
    database: 'testdb'
});

connection.connect(function(error) {
    if(error) {
    console.log('Error');
    } else {
    console.log('connected');
    }
});

connection.query("SELECT * FROM test", function(error, rows, fields){
    if(error) {
        console.log(error);
    } else {
        console.log(rows);
    }
});

// Connect to mongo
mongo.connect('mongodb://127.0.0.1/mongochat',{ useNewUrlParser: true }, function(err, dbc) {
    var db = dbc.db('mongochat');
    if(err) {
        throw err;
    }

    console.log('MongoDB connected...');

    // Connect to Socket.io
    client.on('connection', function(socket) {
    console.log('connected...');
        let chat = db.collection('chats');

    var mem = new Memcached('127.0.0.1:11211');

    mem.set('foo', 'dass',100,function(err){
        console.log('Error1:'+err);
    });
    mem.get('foo', function(err, data) {
        console.log('Error:'+err);
        console.log('Data'+data);
    });

    var PHPSESSID = cookie.parse(socket.request.headers.cookie).PHPSESSID;
    console.log(PHPSESSID);

    mem.get(PHPSESSID, function(err, data){
        if(err) return console.error(err);
        if(data===false)return console.error('could not retreive data');
        console.log('raw data:',data);
    });

        // create function to send status
        sendStatus = function(s) {
            socket.emit('status', s);
        }

        // Get chats from mongo collection
        chat.find().limit(100).sort({_id:1}).toArray(function(err, res){
            if(err){
            throw err;
            }

            // Emit the messages
            socket.emit('output', res);
        console.log('output send');
        });

        // Handle input events
        socket.on('input', function(data){
            let name = data.name;
            let message = data.message;

            // Check for name and message
            if(name == '' || message == '') {
            // send error status
            sendStatus('Please enter a name and message');
            } else {
                // Insert message
                chat.insertOne({name: name, message: message}, function() {
                    client.emit('output', [data]);

                    // Send status object
                    sendStatus({
                        message: 'Message sent',
                        clear: true
                    });
                });
            }
        });

        // Handle clear
        socket.on('clear', function(data) {
            // remove all chats from collection
            chat.deleteMany({}, function(){
                // Emit cleared
                socket.emit('cleared');
            });
        });

    });

});