Spaces:
Paused
Paused
File size: 2,723 Bytes
a0fda44 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 |
const {
addMessageToChatRoom,
checkMembersOffUndeliveredListInMessage,
addMessageAsUndeliveredToUser,
addMessageAsUnreadToUser,
markMessageAsReadByUser,
} = require("../controllers/chatRoomController");
exports.messagingController = (io, socket) => {
socket.on("user:message", async ({ chatRoomId, message }) => {
if (!socket.userId) return;
// Save message to database
const { messageObj, day } = await addMessageToChatRoom(chatRoomId, message);
// Broadcast message to room
io.timeout(180000)
.to(chatRoomId)
.emit(
"user:message",
{
chatRoomId,
message: messageObj,
day,
userId: socket.userId,
},
async (error, membersId) => {
if (error) {
console.log(error);
} else {
// Unique identifier of a message in chatRoom
const uniqueMessageDetails = {
chatRoomId,
day,
messageId: messageObj._id,
};
// Remove members from undelivered list
const { undeliveredMembers } =
await checkMembersOffUndeliveredListInMessage({
...uniqueMessageDetails,
membersId: membersId.map((id) => id.toString()),
io,
});
// Add message as undelivered to members that aren't currently online
await addMessageAsUndeliveredToUser({
...uniqueMessageDetails,
undeliveredMembers,
});
// Add message as unread to all members of the room except sender of the messagee
await addMessageAsUnreadToUser({
...uniqueMessageDetails,
unreadMembers: messageObj.unreadMembers.filter(
(memberId) =>
memberId.toString() !== messageObj.sender.toString()
),
});
// Emit to all users that message can be read
io.to(chatRoomId).emit("user:messageCanBeRead", {
...uniqueMessageDetails,
message: messageObj,
});
}
}
);
});
};
exports.markMessageReadController = (io, socket) => {
socket.on(
"user:messageRead",
async ({ messageId, chatRoomId, day, userId }) => {
await markMessageAsReadByUser({ messageId, chatRoomId, day, userId, io });
}
);
socket.on(
"user:markMessagesAsRead",
async ({ messages, chatRoomId, userId }) => {
for (let { messageId, day } of messages) {
await markMessageAsReadByUser({
messageId,
chatRoomId,
day,
userId,
io,
});
}
}
);
};
|