const express = require('express');
const app = express();
const port = process.env.PORT || 3002;
const http = require('http');
const { Server } = require("socket.io");
const server = http.createServer(app);
const io = new Server(server, {
    cors: {
        origin: "http://127.0.0.1:4200",
        methods: ["GET", "POST"],
        credentials: true
    }
});

const bodyParser = require('body-parser');
app.use(bodyParser.urlencoded({extended:true}));
app.use(bodyParser.json());

const cookieParser = require('cookie-parser');
app.use(cookieParser());

const cors = require('cors');
app.use(cors({origin: 'http://127.0.0.1:4200', credentials: true}));

const auth = require("./auth");

const Message = require("../service-privateroom/models/Message");
const conversationRoute = require("./routes/conversations");
app.use("/conversations", conversationRoute);

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

    auth.getSession(socket.request, function(res){
        const getUsername = auth.getUsername(res);
        if (getUsername === -1) {
            socket.send('error','not authenticated');
        }
        else{

            socket.on('joinroom', function (data){
                console.log(`${new Date()}] ${getUsername} joined the chat.`);
                const conversationId = data.room;
                socket.broadcast.emit(conversationId,[{
                    username: 'Server',
                    date: new Date(),
                    channel: conversationId,
                    message: `${getUsername} joined the chat.`
                }]);

                Message.find({conversationId: {$eq: conversationId}}, {'_id':0, 'username': '$sender', 'date':'$date', 'channel':'$conversationId', 'message':'$text'},{sort: {'date':1}},(err, res) => {
                    if(err) throw err;
                    if(res.length > 0){
                        socket.emit(conversationId,res);
                    }
                    socket.emit(conversationId,[{
                        username: 'Server',
                        date: new Date(),
                        channel: conversationId,
                        message: `${getUsername} joined the chat.`
                    }]);
                });
            });

            socket.on('privateroom',function(data){
                console.log(`${getUsername} joined the chat.`);
                const sender = data.sender;
                const conversationId = data.room;
                const date = data.date;
                const message = data.message;

                Message.insertMany([{
                    conversationId: conversationId,
                    sender: sender,
                    text: message,
                    date: date
                }
                ]).then(function(){
                    console.log(data, "inserted");
                    const newData = {
                        username: data.sender,
                        date: data.date,
                        channel: conversationId,
                        message: data.message
                    }
                    socket.broadcast.emit(conversationId,[newData]);
                    socket.emit(conversationId,[newData]);
                }).catch(function(error){
                    console.log("error",error);
                });
            });

            socket.on("disconnect", function() {
                console.log(`${new Date()}] ${getUsername} left the chat.`);
            });
        }
    });
});

server.listen(port, () => {
    console.log(`listening on *:${port}/`);
});