diff --git a/api/src/chat/services/chat.service.ts b/api/src/chat/services/chat.service.ts index ec7b69e6..7220562f 100644 --- a/api/src/chat/services/chat.service.ts +++ b/api/src/chat/services/chat.service.ts @@ -47,6 +47,14 @@ export class ChatService { private readonly attachmentService: AttachmentService, ) {} + broadcastSendedMessages(event: EventWrapper) { + this.websocketGateway.broadcast( + event.getSender(), + event.getEventType(), + event._adapter.raw, + ); + } + /** * Ends a given conversation (sets active to false) * @@ -268,6 +276,7 @@ export class ChatService { // Already existing user profile // Exec lastvisit hook this.eventEmitter.emit('hook:user:lastvisit', subscriber); + this.broadcastSendedMessages(event); } this.websocketGateway.broadcastSubscriberUpdate(subscriber);