From 91c331c185d84f363141fc9ed7f4f9e694cd0a73 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?S=C3=A9bastien=20Theys?= Date: Mon, 17 Jul 2023 09:42:50 +0000 Subject: [PATCH] [REF] mail: move discuss.channel/transient_message to discuss folder Part of task-3265211 Part-of: odoo/odoo#128593 --- .../mail/static/src/core/common/messaging_service.js | 10 ---------- .../discuss/core/common/discuss_core_common_service.js | 9 +++++++++ 2 files changed, 9 insertions(+), 10 deletions(-) diff --git a/addons/mail/static/src/core/common/messaging_service.js b/addons/mail/static/src/core/common/messaging_service.js index c79a1ddbcc7..12583d370fb 100644 --- a/addons/mail/static/src/core/common/messaging_service.js +++ b/addons/mail/static/src/core/common/messaging_service.js @@ -166,16 +166,6 @@ export class Messaging { case "mail.record/insert": this._handleNotificationRecordInsert(notif); break; - case "discuss.channel/transient_message": { - const channel = - this.store.threads[createLocalId("discuss.channel", notif.payload.res_id)]; - const message = this.messageService.createTransient( - Object.assign(notif.payload, { body: markup(notif.payload.body) }) - ); - channel.messages.push(message); - channel.transientMessages.push(message); - break; - } case "mail.link.preview/delete": { const { id, message_id } = notif.payload; diff --git a/addons/mail/static/src/discuss/core/common/discuss_core_common_service.js b/addons/mail/static/src/discuss/core/common/discuss_core_common_service.js index 1135a7e8388..50eb827e234 100644 --- a/addons/mail/static/src/discuss/core/common/discuss_core_common_service.js +++ b/addons/mail/static/src/discuss/core/common/discuss_core_common_service.js @@ -85,6 +85,15 @@ export class DiscussCoreCommon { this._handleNotificationNewMessage(notif); } }); + this.busService.subscribe("discuss.channel/transient_message", (payload) => { + const channel = + this.store.threads[createLocalId("discuss.channel", payload.res_id)]; + const message = this.messageService.createTransient( + Object.assign(payload, { body: markup(payload.body) }) + ); + channel.messages.push(message); + channel.transientMessages.push(message); + }); this.busService.start(); }); }