feat: emit message_received acknowledgment upon receipt of new messages
This commit is contained in:
@@ -118,6 +118,15 @@ class SocketService {
|
|||||||
this.listenersAttached = true;
|
this.listenersAttached = true;
|
||||||
|
|
||||||
this.socket.on('new_message', (message: Message) => {
|
this.socket.on('new_message', (message: Message) => {
|
||||||
|
// Auto-ack delivery so sender gets real-time double-tick
|
||||||
|
try {
|
||||||
|
this.socket?.emit('message_received', {
|
||||||
|
messageId: message.id,
|
||||||
|
conversationId: message.conversationId,
|
||||||
|
});
|
||||||
|
} catch {
|
||||||
|
// Ignore ack errors
|
||||||
|
}
|
||||||
this.messageHandlers.forEach((handler) => handler(message));
|
this.messageHandlers.forEach((handler) => handler(message));
|
||||||
});
|
});
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user