redis.subscribe('new-message', function (err, count) {});
redis.subscribe('new-chat', function (err, count) {});
redis.subscribe('update-chats', function (err, count) {});
redis.subscribe('message-read', function (err, count) {});
redis.subscribe('typing-chat', function (err, count) {});
redis.subscribe('update-user', function (err, count) {});

io.sockets.on('connection', function (socket) {
    socket.on('join', function (room) {
        socket.join(room);

        socket.on('typing', async function (data) {
            data['auth_id'] = room;
            console.log(`ENV: ${process.env.NODE_ENV}. User_id: ${room}. Base url: ${api_url}`);
            const res = await request('typing', data);
        });

        socket.on('read-message', async (data) => {
            data['auth_id'] = room;
            await request('read_message', data);
        });
    });
});

redis.on('message', function (eventName, msgData) {
    console.log(`Event: ${eventName}`);
    const msg = JSON.parse(msgData);
    const channel_id = msg.data.channel_id;
    io.sockets.to(channel_id).emit(eventName, msg.data);
}, err => {
    console.log(err);
});