initial commit 2

4 files changed, 195 insertions, 0 deletions

diff --git a/addons/im_livechat/static/src/models/messaging_initializer/messaging_initializer.js b/addons/im_livechat/static/src/models/messaging_initializer/messaging_initializer.js
new file mode 100644
index 00000000..56e02d9b
--- /dev/null
+++ b/addons/im_livechat/static/src/models/messaging_initializer/messaging_initializer.js
@@ -0,0 +1,33 @@
+odoo.define('im_livechat/static/src/models/messaging_initializer/messaging_initializer.js', function (require) {
+'use strict';
+
+const { registerInstancePatchModel } = require('mail/static/src/model/model_core.js');
+const { executeGracefully } = require('mail/static/src/utils/utils.js');
+
+registerInstancePatchModel('mail.messaging_initializer', 'im_livechat/static/src/models/messaging_initializer/messaging_initializer.js', {
+
+    //----------------------------------------------------------------------
+    // Private
+    //----------------------------------------------------------------------
+
+    /**
+     * @override
+     * @param {Object[]} [param0.channel_livechat=[]]
+     */
+    async _initChannels(initMessagingData) {
+        await this.async(() => this._super(initMessagingData));
+        const { channel_livechat = [] } = initMessagingData;
+        return executeGracefully(channel_livechat.map(data => () => {
+            const channel = this.env.models['mail.thread'].insert(
+                this.env.models['mail.thread'].convertData(data),
+            );
+            // flux specific: channels received at init have to be
+            // considered pinned. task-2284357
+            if (!channel.isPinned) {
+                channel.pin();
+            }
+        }));
+    },
+});
+
+});
diff --git a/addons/im_livechat/static/src/models/messaging_notification_handler/messaging_notification_handler.js b/addons/im_livechat/static/src/models/messaging_notification_handler/messaging_notification_handler.js
new file mode 100644
index 00000000..efae3eed
--- /dev/null
+++ b/addons/im_livechat/static/src/models/messaging_notification_handler/messaging_notification_handler.js
@@ -0,0 +1,42 @@
+odoo.define('im_livechat/static/src/models/messaging_notification_handler/messaging_notification_handler.js', function (require) {
+'use strict';
+
+const { registerInstancePatchModel } = require('mail/static/src/model/model_core.js');
+
+registerInstancePatchModel('mail.messaging_notification_handler', 'im_livechat/static/src/models/messaging_notification_handler/messaging_notification_handler.js', {
+
+    //----------------------------------------------------------------------
+    // Private
+    //----------------------------------------------------------------------
+
+    /**
+     * @override
+     */
+    _handleNotificationChannelTypingStatus(channelId, data) {
+        const { partner_id, partner_name } = data;
+        const channel = this.env.models['mail.thread'].findFromIdentifyingData({
+            id: channelId,
+            model: 'mail.channel',
+        });
+        if (!channel) {
+            return;
+        }
+        let partnerId;
+        let partnerName;
+        if (this.env.messaging.publicPartners.some(publicPartner => publicPartner.id === partner_id)) {
+            // Some shenanigans that this is a typing notification
+            // from public partner.
+            partnerId = channel.correspondent.id;
+            partnerName = channel.correspondent.name;
+        } else {
+            partnerId = partner_id;
+            partnerName = partner_name;
+        }
+        this._super(channelId, Object.assign(data, {
+            partner_id: partnerId,
+            partner_name: partnerName,
+        }));
+    },
+});
+
+});
diff --git a/addons/im_livechat/static/src/models/partner/partner.js b/addons/im_livechat/static/src/models/partner/partner.js
new file mode 100644
index 00000000..7392c8d6
--- /dev/null
+++ b/addons/im_livechat/static/src/models/partner/partner.js
@@ -0,0 +1,23 @@
+odoo.define('im_livechat/static/src/models/partner/partner.js', function (require) {
+'use strict';
+
+const {
+    registerClassPatchModel,
+} = require('mail/static/src/model/model_core.js');
+
+let nextPublicId = -1;
+
+registerClassPatchModel('mail.partner', 'im_livechat/static/src/models/partner/partner.js', {
+
+    //----------------------------------------------------------------------
+    // Public
+    //----------------------------------------------------------------------
+
+    getNextPublicId() {
+        const id = nextPublicId;
+        nextPublicId -= 1;
+        return id;
+    },
+});
+
+});
diff --git a/addons/im_livechat/static/src/models/thread/thread.js b/addons/im_livechat/static/src/models/thread/thread.js
new file mode 100644
index 00000000..745aff78
--- /dev/null
+++ b/addons/im_livechat/static/src/models/thread/thread.js
@@ -0,0 +1,97 @@
+odoo.define('im_livechat/static/src/models/thread/thread.js', function (require) {
+'use strict';
+
+const {
+    registerClassPatchModel,
+    registerInstancePatchModel,
+} = require('mail/static/src/model/model_core.js');
+
+registerClassPatchModel('mail.thread', 'im_livechat/static/src/models/thread/thread.js', {
+
+    //----------------------------------------------------------------------
+    // Public
+    //----------------------------------------------------------------------
+
+    /**
+     * @override
+     */
+    convertData(data) {
+        const data2 = this._super(data);
+        if ('livechat_visitor' in data && data.livechat_visitor) {
+            if (!data2.members) {
+                data2.members = [];
+            }
+            // `livechat_visitor` without `id` is the anonymous visitor.
+            if (!data.livechat_visitor.id) {
+                /**
+                 * Create partner derived from public partner and replace the
+                 * public partner.
+                 *
+                 * Indeed the anonymous visitor is registered as a member of the
+                 * channel as the public partner in the database to avoid
+                 * polluting the contact list with many temporary partners.
+                 *
+                 * But the issue with public partner is that it is the same
+                 * record for every livechat, whereas every correspondent should
+                 * actually have its own visitor name, typing status, etc.
+                 *
+                 * Due to JS being temporary by nature there is no such notion
+                 * of polluting the database, it is therefore acceptable and
+                 * easier to handle one temporary partner per channel.
+                 */
+                data2.members.push(['unlink', this.env.messaging.publicPartners]);
+                const partner = this.env.models['mail.partner'].create(
+                    Object.assign(
+                        this.env.models['mail.partner'].convertData(data.livechat_visitor),
+                        { id: this.env.models['mail.partner'].getNextPublicId() }
+                    )
+                );
+                data2.members.push(['link', partner]);
+                data2.correspondent = [['link', partner]];
+            } else {
+                const partnerData = this.env.models['mail.partner'].convertData(data.livechat_visitor);
+                data2.members.push(['insert', partnerData]);
+                data2.correspondent = [['insert', partnerData]];
+            }
+        }
+        return data2;
+    },
+});
+
+registerInstancePatchModel('mail.thread', 'im_livechat/static/src/models/thread/thread.js', {
+
+    //----------------------------------------------------------------------
+    // Private
+    //----------------------------------------------------------------------
+
+    /**
+     * @override
+     */
+    _computeCorrespondent() {
+        if (this.channel_type === 'livechat') {
+            // livechat correspondent never change: always the public member.
+            return [];
+        }
+        return this._super();
+    },
+    /**
+     * @override
+     */
+    _computeDisplayName() {
+        if (this.channel_type === 'livechat' && this.correspondent) {
+            if (this.correspondent.country) {
+                return `${this.correspondent.nameOrDisplayName} (${this.correspondent.country.name})`;
+            }
+            return this.correspondent.nameOrDisplayName;
+        }
+        return this._super();
+    },
+    /**
+     * @override
+     */
+    _computeIsChatChannel() {
+        return this.channel_type === 'livechat' || this._super();
+    },
+});
+
+});