dragonroll/server/io/campaign.js

const CampaignUser = require("../models/CampaignUser");
const User = require("../models/User");
const FilterUser = require('../utils/filters');

let sessions = {};

async function GetOfflinePlayers(campaign){
    let players = await CampaignUser.find({campaign}).populate('user').exec();
    let finalPlayers = [];
    console.log(players)
    // TODO: Filter
    players.forEach(player => finalPlayers.push(FilterUser(player)));

    return finalPlayers;
}

function SetPlayerProperty(campaign, player_id, key, value){
    objIndex = sessions[campaign].players.findIndex(player => player.user._id.toString() == player_id);
    if(objIndex != -1){        
        sessions[campaign].players[objIndex][key] = value;
    }
}

module.exports = io => {
    io.on('connection', (socket) => {
        socket.on('enter', (user, campaignId) => {
            User.findOne(user).then(user => {
                if(user){
                    socket.user = user;
                    CampaignUser.findOne({campaign: campaignId, user}).then(async campaignUser => {
                        if(campaignUser){
                            socket.join(campaignId);
                            socket.campaign = campaignId;

                            if(!sessions[campaignId]) sessions[campaignId] = {
                                players: await GetOfflinePlayers(campaignId)
                            };
                            
                            
                            console.log(socket.user.username + " ha entrado!");
                            SetPlayerProperty(campaignId, socket.user._id, "online", true);
                            io.to(socket.campaign).emit('update-players', sessions[campaignId].players)

                            // console.log(JSON.stringify(sessions[campaignId], null, 4));
                        }
                    });
                }
            })
        });

        socket.on('exit', () => {
            SetPlayerProperty(socket.campaign, socket.user._id, "online", false);
            io.to(socket.campaign).emit('update-players', sessions[socket.campaign].players)
            socket.leave(socket.campaign)

            console.log(socket.user.username + " ha salido!")
        });
    });
}