var express = require('express');
var app = express();
var session = require('express-session');
var http = require('http').Server(app);
var io = require('socket.io')(http);
var sharp = require('sharp');
const crypto = require('crypto');
const ChatSingleton = require('./chat');

const Chat = ChatSingleton.instance;


let connect_sid = Date.now();

app.use(session({
    secret: 'keyboard cat',
    resave: true,
    saveUninitialized: true,
    cookie: { secure: false }
}));

app.get('/', function (req, res) {
    console.log(new Date().getTime() + ":[get: /]");

    //connect_sid = req.sessionID;
    console.log('connect_sid', connect_sid);
    
    res.sendFile(__dirname + '/public/index.html');
});

app.get('/customer', function (req, res) {
    console.log(new Date().getTime() + ":[get: /customer]");

    //connect_sid = req.sessionID;
    console.log('connect_sid', connect_sid);
    
    res.sendFile(__dirname + '/public/customer.html');
});

app.get('/operator', function (req, res) {
    console.log(new Date().getTime() + ":[get: /]");

    //connect_sid = req.sessionID;
    console.log('connect_sid', connect_sid);

    res.sendFile(__dirname + '/public/operator.html');
});

app.use(express.static('public'));

http.listen(3001, function () {
    console.log('listening on *:3001');
});


io.on('connection', (socket) => {

    let user = undefined;
    const EVENTS = Chat.EVENTS;
    const ROLES = Chat.ROLES;
    const DEFAULT_ROOMS = Chat.DEFAULT_ROOMS;
    let event = '';
    
    event = Chat.event(EVENTS.CONNECTION.OPEN);
    io.emit(event.type, event.data);
    
    
    // create user and send updates
    socket.on(EVENTS.CONNECTION.OPEN, (data) => {
        console.log('CONNECTION:OPEN', JSON.stringify(data));
        
        // create new user
        const buf = crypto.randomBytes(64);
        const uniqID = buf.toString('hex');
        user = Chat.createUser(data.name, data.role, uniqID);

        console.log('user', user);

        // join user own room
        socket.join(user.room);

        // notify user is ready
        event = Chat.event(EVENTS.ROOM.CREATED, user);
        io.to(user.room).emit(event.type, event.data);

        // join operators room if role is operator
        if (user.role === ROLES.OPERATOR) {
            socket.join(DEFAULT_ROOMS.OPERATORS);
        }

        // send customers updated list to operators
        event = Chat.event(EVENTS.CUSTOMERS.LIST.UPDATE, Chat.getUsersByRole(ROLES.CUSTOMER));
        io.to(DEFAULT_ROOMS.OPERATORS).emit(event.type, event.data);

        // send operators updated list to operators
        event = Chat.event(EVENTS.OPERATORS.LIST.UPDATE, Chat.getUsersByRole(ROLES.OPERATOR));
        io.to(DEFAULT_ROOMS.OPERATORS).emit(event.type, event.data);

        // send rooms updated list to operators
        event = Chat.event(EVENTS.ROOMS.LIST.UPDATE, Chat.rooms);
        io.to(DEFAULT_ROOMS.OPERATORS).emit(event.type, event.data);
    });


    // join room
    socket.on(EVENTS.ROOM.JOIN, (data) => {
        const ownerRoom = Chat.joinOwnerRoom(data.user, user);
        socket.join(ownerRoom);
        
        event = Chat.event(EVENTS.ROOM.JOIN, user);
        io.to(ownerRoom).emit(event.type, event.data);

        console.log('join room', user.name, event.data);
    });


    // send text message
    socket.on(EVENTS.SEND.MESSAGE, (data) => {
        const room = user.role === ROLES.CUSTOMER ? user.room : data.room;

        const message = Chat.message(data, room, user);
        event = Chat.event(EVENTS.SEND.MESSAGE, message);
        io.to(room).emit(event.type, event.data);

        console.log('sendMessage', event);
    });


    socket.on('disconnect', () => {
        console.log('disconnect', user);

        event = Chat.event(EVENTS.CONNECTION.CLOSE);
        io.emit(event.type, event.data);
        
        if (!user) {
            return
        }

        const userRole = user.role;
        Chat.deleteUser(user);

        // send operators updated list to operators
        if (userRole === ROLES.OPERATOR) {
            event = Chat.event(EVENTS.OPERATORS.LIST.UPDATE, Chat.getUsersByRole(ROLES.OPERATOR));
            io.to(DEFAULT_ROOMS.OPERATORS).emit(event.type, event.data);
        }

        // send customers updated list to operators
        if (userRole === ROLES.CUSTOMER) {
            event = Chat.event(EVENTS.CUSTOMERS.LIST.UPDATE, Chat.getUsersByRole(ROLES.CUSTOMER));
            io.to(DEFAULT_ROOMS.OPERATORS).emit(event.type, event.data);
        }
    });
});