({
socketId,
userIdsToNotify,
messageId,
parentMessageId,
chatId,
message,
}: {
socketId?: string;
userIdsToNotify: string[];
messageId: string;
parentMessageId: string;
chatId: string;
message: IMessageDocument;
})
| 496 | } |
| 497 | |
| 498 | function unreadMessageAdded({ |
| 499 | socketId, |
| 500 | userIdsToNotify, |
| 501 | messageId, |
| 502 | parentMessageId, |
| 503 | chatId, |
| 504 | message, |
| 505 | }: { |
| 506 | socketId?: string; |
| 507 | userIdsToNotify: string[]; |
| 508 | messageId: string; |
| 509 | parentMessageId: string; |
| 510 | chatId: string; |
| 511 | message: IMessageDocument; |
| 512 | }) { |
| 513 | const socket = getSocket(socketId); |
| 514 | if (socket) { |
| 515 | userIdsToNotify.forEach((userId) => { |
| 516 | const roomName = `user-${userId}`; |
| 517 | socket.to(roomName).emit('unreadByUserMessageEvent', { |
| 518 | actionType: 'added', |
| 519 | messageId, |
| 520 | userId, |
| 521 | parentMessageId, |
| 522 | chatId, |
| 523 | message, |
| 524 | }); |
| 525 | }); |
| 526 | } |
| 527 | } |
| 528 | |
| 529 | function unreadMessageDeleted({ |
| 530 | socketId, |
no test coverage detected