pengyuthon/odoo_source
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[REF] mail: move mail.activity/updated to new service

Browse Source 
Part of task-3265211

Part-of: odoo/odoo#129583
This commit is contained in:
Sébastien Theys
2023-07-27 20:32:31 +02:00
parent 95190bb8cf
commit 3cfe5200b2
2 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
addons/mail/static/src/core/common/messaging_service.js
-8
View File
@@ -130,14 +130,6 @@ export class Messaging {
handleNotification(notifications) {
for (const notif of notifications) {
switch (notif.type) {
case "mail.activity/updated":
if (notif.payload.activity_created) {
this.store.activityCounter++;
}
if (notif.payload.activity_deleted) {
this.store.activityCounter--;
}
break;
case "mail.record/insert":
this._handleNotificationRecordInsert(notif);
break;
addons/mail/static/src/core/web/mail_core_web_service.js
+10 -1
View File
@@ -7,6 +7,7 @@ import { registry } from "@web/core/registry";
export class MailCoreWeb {
constructor(env, services) {
Object.assign(this, {
busService: services.bus_service,
rpc: services.rpc,
});
/** @type {import("@mail/core/common/message_service").MessageService} */
@@ -34,12 +35,20 @@ export class MailCoreWeb {
(n1, n2) => n2.lastMessage.id - n1.lastMessage.id
);
});
this.busService.subscribe("mail.activity/updated", (payload) => {
if (payload.activity_created) {
this.store.activityCounter++;
}
if (payload.activity_deleted) {
this.store.activityCounter--;
}
});
});
}
}
export const mailCoreWeb = {
dependencies: ["mail.message", "mail.messaging", "mail.store", "rpc"],
dependencies: ["bus_service", "mail.message", "mail.messaging", "mail.store", "rpc"],
start(env, services) {
const mailCoreWeb = reactive(new MailCoreWeb(env, services));
mailCoreWeb.setup();