const UserRepository = require("../repositories/UserRepository");

module.exports = function registerSocketHandlers(io) {
    io.on("connection", (socket) => {
        const userId = socket.request.session && socket.request.session.userId;
        const user = userId && UserRepository.findById(userId);
        if (!user || !user.household_id) return socket.disconnect(true);

        socket.join(`household:${user.household_id}`);
        socket.on("list:join", (listId) => socket.join(`list:${listId}`));
    });
};