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

[IMP] mail: add group chat feature

Browse Source 
task-2360934

closes odoo/odoo#75633

Signed-off-by: Alexandre Kühn (aku) <aku@odoo.com>
This commit is contained in:
Julien Giannone
2021-08-26 17:25:06 +00:00
committed by Sébastien Theys
parent 806a8db35b
commit 845bb6cc93
15 changed files with 520 additions and 154 deletions
Download Patch File Download Diff File Expand all files Collapse all files
addons/mail/models/mail_channel.py
+23 -4
View File
@@ -39,9 +39,10 @@ class Channel(models.Model):
name = fields.Char('Name', required=True, translate=True)
active = fields.Boolean(default=True, help="Set active to false to hide the channel without removing it.")
channel_type = fields.Selection([
('chat', 'Chat Discussion'),
('channel', 'Channel')],
string='Channel Type', default='channel')
('chat', 'Chat'),
('channel', 'Channel'),
('group', 'Group')],
string='Channel Type', default='channel', help="Chat is private and unique between 2 persons. Group is private among invited persons. Channel can be freely joined (depending on its configuration).")
is_chat = fields.Boolean(string='Is a chat', compute='_compute_is_chat')
description = fields.Text('Description')
image_128 = fields.Image("Image", max_width=128, max_height=128, default=_get_default_image)
@@ -630,6 +631,8 @@ class Channel(models.Model):
"""
if self.env.user.partner_id.id not in partners_to:
partners_to.append(self.env.user.partner_id.id)
if len(partners_to) > 2:
raise UserError(_("A chat should not be created with more than 2 persons. Create a group instead."))
# determine type according to the number of partner in the channel
self.flush()
self.env.cr.execute("""
@@ -889,6 +892,22 @@ class Channel(models.Model):
self.env['bus.bus'].sendone((self._cr.dbname, 'res.partner', self.env.user.partner_id.id), channel_info)
return channel_info
@api.model
def create_group(self, partners_to):
""" Create a group channel.
:param partners_to : list of res.partner ids to add to the conversation
:returns: channel_info of the created channel
:rtype: dict
"""
channel = self.create({
'channel_last_seen_partner_ids': [Command.create({'partner_id': partner_id}) for partner_id in partners_to],
'channel_type': 'group',
'name': '', # default name is computed client side from the list of members
'public': 'private',
})
channel._broadcast(partners_to)
return channel.channel_info()[0]
@api.model
def get_mention_suggestions(self, search, limit=8):
""" Return 'limit'-first channels' id, name and public fields such that the name matches a
@@ -988,7 +1007,7 @@ class Channel(models.Model):
return msg
def execute_command_leave(self, **kwargs):
if self.channel_type == 'channel':
if self.channel_type in ('channel', 'group'):
self.action_unfollow()
else:
self.channel_pin(self.uuid, False)
addons/mail/models/res_partner.py
+2 -2
View File
@@ -135,9 +135,9 @@ class Partner(models.Model):
"""Returns the channels of the partner."""
self.ensure_one()
channels = self.env['mail.channel']
# get the channels
# get the channels and groups
channels |= self.env['mail.channel'].search([
('channel_type', '=', 'channel'),
('channel_type', 'in', ('channel', 'group')),
('channel_partner_ids', 'in', [self.id]),
])
# get the pinned direct messages
addons/mail/static/src/components/channel_invitation_form/channel_invitation_form.xml
+4 -4
View File
@@ -5,11 +5,11 @@
<div class="o_ChannelInvitationForm d-flex flex-column" t-ref="channelInvitationForm">
<h3 class="mx-3 mt-3 mb-2">Invite people</h3>
<div class="mx-3 my-2">
<input type="text" t-att-value="channelInvitationForm.searchTerm" placeholder="Type the name of a person" t-on-input="channelInvitationForm.onInputSearch" t-ref="searchInput"/>
<input class="o_ChannelInvitationForm_searchInput" type="text" t-att-value="channelInvitationForm.searchTerm" placeholder="Type the name of a person" t-on-input="channelInvitationForm.onInputSearch" t-ref="searchInput"/>
</div>
<div class="d-flex flex-column flex-grow-1 mx-0 py-2 overflow-auto">
<t t-foreach="channelInvitationForm.selectablePartners" t-as="selectablePartner" t-key="selectablePartner.localId">
<div class="o_ChannelInvitationForm_selectablePartner d-flex align-items-center px-3 py-1" t-on-click="channelInvitationForm.onClickSelectablePartner.bind(channelInvitationForm, selectablePartner)">
<div class="o_ChannelInvitationForm_selectablePartner d-flex align-items-center px-3 py-1" t-on-click="channelInvitationForm.onClickSelectablePartner.bind(channelInvitationForm, selectablePartner)" t-att-data-partner-id="selectablePartner.id">
<div class="o_ChannelInvitationForm_selectablePartnerAvatarContainer flex-shrink-0 position-relative">
<img class="o_ChannelInvitationForm_selectablePartnerAvatar w-100 h-100 rounded-circle" t-att-src="selectablePartner.avatarUrl" alt="Avatar"/>
<t t-if="selectablePartner.im_status and selectablePartner.im_status !== 'im_partner'">
@@ -27,7 +27,7 @@
<t t-esc="selectablePartner.nameOrDisplayName"/>
</span>
<div class="o_ChannelInvitationForm_selectablePartnerNameSelectionSeparator flex-grow-1 flex-shrink-0"/>
<input class="flex-shrink-0" type="checkbox" t-att-checked="channelInvitationForm.selectedPartners.includes(selectablePartner) ? 'checked' : undefined" t-on-input="channelInvitationForm.onInputPartnerCheckbox.bind(channelInvitationForm, selectablePartner)" t-ref="selection-status"/>
<input class="o_ChannelInvitationForm_selectablePartnerCheckbox flex-shrink-0" type="checkbox" t-att-checked="channelInvitationForm.selectedPartners.includes(selectablePartner) ? 'checked' : undefined" t-on-input="channelInvitationForm.onInputPartnerCheckbox.bind(channelInvitationForm, selectablePartner)" t-ref="selection-status"/>
</div>
</t>
<t t-if="channelInvitationForm.selectablePartners.length === 0">
@@ -52,7 +52,7 @@
</div>
</t>
<div class="mx-3 mt-2 mb-3">
<button class="btn btn-primary w-100" t-att-disabled="channelInvitationForm.selectedPartners.length === 0" t-on-click="channelInvitationForm.onClickInvite">
<button class="o_ChannelInvitationForm_inviteButton btn btn-primary w-100" t-att-disabled="channelInvitationForm.selectedPartners.length === 0" t-on-click="channelInvitationForm.onClickInvite">
<t t-esc="channelInvitationForm.inviteButtonText"/>
</button>
</div>
addons/mail/static/src/components/channel_invitation_form/tests/channel_invitation_form_tests.js
+152
View File
@@ -0,0 +1,152 @@
/** @odoo-module **/
import {
afterEach,
afterNextRender,
beforeEach,
start,
} from '@mail/utils/test_utils';
QUnit.module('mail', {}, function () {
QUnit.module('components', {}, function () {
QUnit.module('channel_invitation_form', {}, function () {
QUnit.module('channel_invitation_form_tests.js', {
beforeEach() {
beforeEach(this);
this.start = async params => {
const { env, widget } = await start(Object.assign({}, params, {
autoOpenDiscuss: true,
data: this.data,
hasDiscuss: true,
}));
this.env = env;
this.widget = widget;
};
},
afterEach() {
afterEach(this);
},
});
QUnit.test('should display the channel invitation form after clicking on the invite button of a chat', async function (assert) {
assert.expect(1);
this.data['res.partner'].records.push({
id: 11,
email: "testpartner@odoo.com",
name: "TestPartner",
});
this.data['res.users'].records.push({
partner_id: 11,
});
this.data['mail.channel'].records.push({
channel_type: 'chat',
id: 13,
members: [this.data.currentPartnerId, 11],
public: 'private',
});
await this.start({
discuss: {
context: {
active_id: 13,
},
},
});
await afterNextRender(() => document.querySelector(`.o_ThreadViewTopbar_inviteButton`).click());
assert.containsOnce(
document.body,
'.o_ChannelInvitationForm',
"should display the channel invitation form after clicking on the invite button of a chat"
);
});
QUnit.test('should be able to search for a new user to invite from an existing chat', async function (assert) {
assert.expect(1);
this.data['res.partner'].records.push({
id: 11,
email: "testpartner@odoo.com",
name: "TestPartner",
});
this.data['res.partner'].records.push({
id: 12,
email: "testpartner2@odoo.com",
name: "TestPartner2",
});
this.data['res.users'].records.push({
partner_id: 11,
});
this.data['res.users'].records.push({
partner_id: 12,
});
this.data['mail.channel'].records.push({
channel_type: 'chat',
id: 13,
members: [this.data.currentPartnerId, 11],
public: 'private',
});
await this.start({
discuss: {
context: {
active_id: 13,
},
},
});
await afterNextRender(() => document.querySelector(`.o_ThreadViewTopbar_inviteButton`).click());
await afterNextRender(() => document.execCommand('insertText', false, "TestPartner2"));
assert.strictEqual(
document.querySelector(`.o_ChannelInvitationForm_selectablePartnerName`).textContent,
"TestPartner2",
"should display 'TestPartner2' as it matches search term",
);
});
QUnit.test('should be able to create a new group chat from an existing chat', async function (assert) {
assert.expect(1);
this.data['res.partner'].records.push({
id: 11,
email: "testpartner@odoo.com",
name: "TestPartner",
});
this.data['res.partner'].records.push({
id: 12,
email: "testpartner2@odoo.com",
name: "TestPartner2",
});
this.data['res.users'].records.push({
partner_id: 11,
});
this.data['res.users'].records.push({
partner_id: 12,
});
this.data['mail.channel'].records.push({
channel_type: 'chat',
id: 13,
members: [this.data.currentPartnerId, 11],
public: 'private',
});
await this.start({
discuss: {
context: {
active_id: 13,
},
},
});
await afterNextRender(() => document.querySelector(`.o_ThreadViewTopbar_inviteButton`).click());
await afterNextRender(() => document.execCommand('insertText', false, "TestPartner2"));
document.querySelector(`.o_ChannelInvitationForm_selectablePartnerCheckbox`).click();
await afterNextRender(() => document.querySelector(`.o_ChannelInvitationForm_inviteButton`).click());
await afterNextRender(() => document.querySelector(`.o_ChannelInvitationForm_inviteButton`).click());
assert.strictEqual(
document.querySelector(`.o_ThreadViewTopbar_threadName`).textContent,
'Mitchell Admin, TestPartner, TestPartner2',
"should have created a new group chat with the existing chat members and the selected user",
);
});
});
});
});
addons/mail/static/src/components/discuss/tests/discuss_pinned_tests.js
+4 -8
View File
@@ -77,8 +77,8 @@ QUnit.test('sidebar: pinned channel 2: open pinned channel', async function (ass
);
});
QUnit.test('sidebar: pinned channel 3: open pinned channel and unpin it', async function (assert) {
assert.expect(7);
QUnit.test('sidebar: pinned channel 3: open channel and leave it', async function (assert) {
assert.expect(6);
// channel that is expected to be found in the sidebar
// with a random unique id that will be referenced in the test
@@ -95,9 +95,6 @@ QUnit.test('sidebar: pinned channel 3: open pinned channel and unpin it', async
"The right id is sent to the server to remove"
);
}
if (args.method === 'channel_fold') {
assert.step('channel_fold');
}
return this._super(...arguments);
},
});
@@ -111,16 +108,15 @@ QUnit.test('sidebar: pinned channel 3: open pinned channel and unpin it', async
threadGeneral.localId
}"]`).click()
);
assert.verifySteps([], "neither channel_fold nor action_unfollow are called yet");
assert.verifySteps([], "action_unfollow is not called yet");
await afterNextRender(() =>
document.querySelector('.o_DiscussSidebarCategoryItem_commandLeave').click()
);
assert.verifySteps(
[
'channel_fold',
'action_unfollow'
],
"both channel_fold and action_unfollow have been called when unpinning a channel"
"action_unfollow has been called when leaving a channel"
);
assert.containsNone(
document.body,
addons/mail/static/src/components/thread_icon/thread_icon.xml
+3
View File
@@ -37,6 +37,9 @@
<div class="o_ThreadIcon_noImStatus fa fa-question-circle" title="No IM status available"/>
</t>
</t>
<t t-elif="thread.channel_type === 'group'">
<div class="o_ThreadIcon fa fa-users" title="Grouped Chat"/>
</t>
<t t-elif="thread.model === 'mail.box'">
<t t-if="thread === messaging.inbox">
<div class="o_ThreadIcon_mailboxInbox fa fa-inbox"/>
addons/mail/static/src/components/thread_view_topbar/thread_view_topbar.scss
+1
View File
@@ -55,6 +55,7 @@
}
.o_ThreadViewTopbar_threadName {
max-width: map-get($sizes, 75);
&:not(.o-isMouseOverThreadName) {
border-color: transparent; // presence of border even if invisible to prevent flicker
addons/mail/static/src/components/thread_view_topbar/thread_view_topbar.xml
+2 -2
View File
@@ -10,7 +10,7 @@
<div class="o_ThreadViewTopbar_title d-flex flex-grow-1 align-self-center align-items-center">
<t t-if="threadViewTopBar.thread">
<t t-if="!threadViewTopBar.isEditingThreadName">
<div class="o_ThreadViewTopbar_threadName flex-shrink-0 mw-75 px-1 text-truncate lead font-weight-bold" t-att-title="threadViewTopBar.thread.displayName" t-on-click="threadViewTopBar.onClickTopbarThreadName" t-on-mouseenter="threadViewTopBar.onMouseEnterTopBarThreadName" t-on-mouseleave="threadViewTopBar.onMouseLeaveTopBarThreadName" t-att-class="{ 'o-isMouseOverThreadName': threadViewTopBar.isMouseOverThreadName }">
<div class="o_ThreadViewTopbar_threadName flex-shrink-0 px-1 text-truncate lead font-weight-bold" t-att-title="threadViewTopBar.thread.displayName" t-on-click="threadViewTopBar.onClickTopbarThreadName" t-on-mouseenter="threadViewTopBar.onMouseEnterTopBarThreadName" t-on-mouseleave="threadViewTopBar.onMouseLeaveTopBarThreadName" t-att-class="{ 'o-isMouseOverThreadName': threadViewTopBar.isMouseOverThreadName }">
<t t-esc="threadViewTopBar.thread.displayName"/>
</div>
</t>
@@ -19,7 +19,7 @@
</t>
</t>
<t t-if="!threadViewTopBar.thread">
<div class="o_ThreadViewTopbar_threadName flex-shrink-0 mw-75 px-1 text-truncate lead font-weight-bold">
<div class="o_ThreadViewTopbar_threadName flex-shrink-0 px-1 text-truncate lead font-weight-bold">
Discuss
</div>
</t>
addons/mail/static/src/models/channel_invitation_form/channel_invitation_form.js
+33 -9
View File
@@ -34,14 +34,32 @@ function factory(dependencies) {
* @param {MouseEvent} ev
*/
async onClickInvite(ev) {
await this.env.services.rpc(({
model: 'mail.channel',
method: 'add_members',
args: [this.thread.id],
kwargs: {
partner_ids: this.selectedPartners.map(partner => partner.id),
},
}));
if (this.thread.channel_type === 'chat') {
const channelData = await this.env.services.rpc(({
model: 'mail.channel',
method: 'create_group',
kwargs: {
partners_to: [...new Set([
this.messaging.currentPartner.id,
...this.thread.members.map(member => member.id),
...this.selectedPartners.map(partner => partner.id),
])],
},
}));
const channel = this.messaging.models['mail.thread'].insert(
this.messaging.models['mail.thread'].convertData(channelData)
);
channel.open();
} else {
await this.env.services.rpc(({
model: 'mail.channel',
method: 'add_members',
args: [[this.thread.id]],
kwargs: {
partner_ids: this.selectedPartners.map(partner => partner.id),
},
}));
}
this.update({
searchTerm: "",
selectedPartners: unlinkAll(),
@@ -148,9 +166,15 @@ function factory(dependencies) {
* @returns {string}
*/
_computeInviteButtonText() {
if (!this.thread || this.thread.channel_type !== 'channel') {
if (!this.thread) {
return clear();
}
switch (this.thread.channel_type) {
case 'chat':
return this.env._t("Create group chat");
case 'group':
return this.env._t("Invite to group chat");
}
return this.env._t("Invite to Channel");
}
addons/mail/static/src/models/discuss_sidebar_category_item/discuss_sidebar_category_item.js
+39 -4
View File
@@ -38,6 +38,7 @@ function factory(dependencies) {
_computeAvatarUrl() {
switch (this.channelType) {
case 'channel':
case 'group':
return `/web/image/mail.channel/${this.channelId}/image_128`;
case 'chat':
return this.channel.correspondent.avatarUrl;
@@ -64,6 +65,7 @@ function factory(dependencies) {
case 'channel':
return this.channel.message_needaction_counter;
case 'chat':
case 'group':
return this.channel.localMessageUnreadCounter;
}
}
@@ -73,9 +75,11 @@ function factory(dependencies) {
* @returns {boolean}
*/
_computeHasLeaveCommand() {
return this.channelType === 'channel' &&
return (
['channel', 'group'].includes(this.channelType) &&
!this.channel.message_needaction_counter &&
!this.channel.group_based_subscription;
!this.channel.group_based_subscription
);
}
/**
@@ -121,6 +125,7 @@ function factory(dependencies) {
switch (this.channelType) {
case 'channel':
case 'chat':
case 'group':
return true;
}
}
@@ -144,10 +149,13 @@ function factory(dependencies) {
*/
async onClickCommandLeave(ev) {
ev.stopPropagation();
if (this.channel.creator === this.messaging.currentUser) {
if (this.channel.channel_type !== 'group' && this.channel.creator === this.messaging.currentUser) {
await this._askAdminConfirmation();
}
this.channel.unsubscribe();
if (this.channel.channel_type === 'group') {
await this._askLeaveGroupConfirmation();
}
this.channel.leave();
}
/**
@@ -201,6 +209,33 @@ function factory(dependencies) {
);
});
}
/**
* @private
* @returns {Promise}
*/
_askLeaveGroupConfirmation() {
return new Promise(resolve => {
Dialog.confirm(this,
this.env._t("You are about to leave this group conversation and will no longer have access to it unless you are invited again. Are you sure you want to continue?"),
{
buttons: [
{
text: this.env._t("Leave"),
classes: 'btn-primary',
close: true,
click: resolve
},
{
text: this.env._t("Discard"),
close: true
}
]
}
);
});
}
}
DiscussSidebarCategoryItem.fields = {
addons/mail/static/src/models/messaging_initializer/messaging_initializer.js
+1 -1
View File
@@ -241,7 +241,7 @@ function factory(dependencies) {
newItemPlaceholderText: this.env._t("Find or start a conversation..."),
serverStateKey: 'is_discuss_sidebar_category_chat_open',
sortComputeMethod: 'last_action',
supportedChannelTypes: ['chat'],
supportedChannelTypes: ['chat', 'group'],
}),
});
}
addons/mail/static/src/models/thread/thread.js
+7 -7
View File
@@ -1210,6 +1210,9 @@ function factory(dependencies) {
if (this.channel_type === 'chat' && this.correspondent) {
return this.custom_channel_name || this.correspondent.nameOrDisplayName;
}
if (this.channel_type === 'group') {
return this.name || this.members.map(partner => partner.nameOrDisplayName).join(', ');
}
return this.name;
}
@@ -1226,10 +1229,7 @@ function factory(dependencies) {
* @returns {boolean}
*/
_computeHasInviteFeature() {
if (this.model !== 'mail.channel') {
return false;
}
return this.channel_type === 'channel';
return this.model === 'mail.channel';
}
/**
@@ -1248,7 +1248,7 @@ function factory(dependencies) {
* @returns {boolean}
*/
_computeIsChannelDescriptionChangeable() {
return this.model === 'mail.channel' && this.channel_type === 'channel';
return this.model === 'mail.channel' && ['channel', 'group'].includes(this.channel_type);
}
/**
@@ -1258,7 +1258,7 @@ function factory(dependencies) {
_computeIsChannelRenamable() {
return (
this.model === 'mail.channel' &&
['chat', 'channel'].includes(this.channel_type)
['chat', 'channel', 'group'].includes(this.channel_type)
);
}
@@ -1267,7 +1267,7 @@ function factory(dependencies) {
* @returns {boolean}
*/
_computeHasMemberListFeature() {
return this.model === 'mail.channel' && ['channel'].includes(this.channel_type);
return this.model === 'mail.channel' && ['channel', 'group'].includes(this.channel_type);
}
/**
addons/mail/static/src/models/thread_view_topbar/thread_view_topbar.js
+4 -1
View File
@@ -294,6 +294,9 @@ function factory(dependencies) {
if (newName && this.thread.channel_type === 'channel' && newName !== this.thread.name) {
this.thread.rename(newName);
}
if (this.thread.channel_type === 'group' && newName !== this.thread.name) {
this.thread.rename(newName);
}
}
/**
@@ -305,7 +308,7 @@ function factory(dependencies) {
isEditingThreadDescription: false,
pendingThreadDescription: clear(),
});
if (this.thread.channel_type === 'channel' && newDescription !== this.thread.description) {
if (newDescription !== this.thread.description) {
this.thread.changeDescription(newDescription);
}
}
addons/mail/static/tests/helpers/mock_server.js
+72
View File
@@ -200,6 +200,10 @@ MockServer.include({
const name = args.args[1] || args.kwargs.name;
return this._mockMailChannelChannelSetCustomName(ids, name);
}
if (args.model === 'mail.channel' && args.method === 'create_group') {
const partners_to = args.args[0] || args.kwargs.partners_to;
return this._mockMailChannelCreateGroup(partners_to);
}
if (args.model === 'mail.channel' && args.method === 'execute_command_leave') {
return this._mockMailChannelExecuteCommandLeave(args);
}
@@ -270,6 +274,12 @@ MockServer.include({
const limit = args.args[1] || args.kwargs.limit;
return this._mockResPartnerImSearch(name, limit);
}
if (args.model === 'res.partner' && args.method === 'search_for_channel_invite') {
const search_term = args.args[0] || args.kwargs.search_term;
const channel_id = args.args[1] || args.kwargs.channel_id;
const limit = args.args[2] || args.kwargs.limit;
return this._mockResPartnerSearchForChannelInvite(search_term, channel_id, limit);
}
// mail.thread methods (can work on any model)
if (args.method === 'message_subscribe') {
const ids = args.args[0];
@@ -875,6 +885,26 @@ MockServer.include({
]);
this._mockMailChannel_broadcast([channel.id], [this.currentPartnerId]);
},
/**
* Simulates the `/mail/create_group` route.
*
* @private
* @param {integer[]} partners_to
* @returns {Object}
*/
async _mockMailChannelCreateGroup(partners_to) {
const partners = this._getRecords('res.partner', [['id', 'in', partners_to]]);
const id = this._mockCreate('mail.channel', {
channel_type: 'group',
is_pinned: true,
members: [[6, 0, partners.map(partner => partner.id)]],
name: '',
public: 'private',
state: 'open',
});
this._mockMailChannel_broadcast(id, partners.map(partner => partner.id));
return this._mockMailChannelChannelInfo([id])[0];
},
/**
* Simulates `execute_command_leave` on `mail.channel`.
*
@@ -1841,6 +1871,48 @@ MockServer.include({
}
]));
},
/**
* Simulates `search_for_channel_invite` on `res.partner`.
*
* @private
* @param {string} [search_term='']
* @param {integer} [channel_id]
* @param {integer} [limit=30]
* @returns {Object[]}
*/
_mockResPartnerSearchForChannelInvite(search_term, channel_id, limit = 30) {
search_term = search_term.toLowerCase(); // simulates ILIKE
// simulates domain with relational parts (not supported by mock server)
const matchingPartners = [...this._mockResPartnerMailPartnerFormat(
this._getRecords('res.users', [])
.filter(user => {
const partner = this._getRecords('res.partner', [['id', '=', user.partner_id]])[0];
// user must have a partner
if (!partner) {
return false;
}
// not current partner
if (partner.id === this.currentPartnerId) {
return false;
}
// no name is considered as return all
if (!search_term) {
return true;
}
if (partner.name && partner.name.toLowerCase().includes(search_term)) {
return true;
}
return false;
})
.map(user => user.partner_id)
).values()];
const count = matchingPartners.length;
matchingPartners.length = Math.min(count, limit);
return {
count,
partners: matchingPartners
};
},
/**
* Simulates `_message_fetch_failed` on `res.partner`.
*
addons/test_discuss_full/tests/test_performance.py
+173 -112
View File
@@ -62,25 +62,27 @@ class TestDiscussFullPerformance(TransactionCase):
self.env['mail.channel'].search([('id', '!=', channel_general.id)]).unlink()
user_root = self.env.ref('base.user_root')
# create public channels
channel_public_1 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_create(name='public 1', privacy='public')['id'])
channel_public_1.add_members((self.users[0] + self.users[2] + self.users[3] + self.users[4] + self.users[8]).partner_id.ids)
channel_public_2 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_create(name='public 2', privacy='public')['id'])
channel_public_2.add_members((self.users[0] + self.users[2] + self.users[4] + self.users[7] + self.users[9]).partner_id.ids)
channel_channel_public_1 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_create(name='public 1', privacy='public')['id'])
channel_channel_public_1.add_members((self.users[0] + self.users[2] + self.users[3] + self.users[4] + self.users[8]).partner_id.ids)
channel_channel_public_2 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_create(name='public 2', privacy='public')['id'])
channel_channel_public_2.add_members((self.users[0] + self.users[2] + self.users[4] + self.users[7] + self.users[9]).partner_id.ids)
# create groups channels
channel_group_1 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_create(name='group 1', privacy='groups')['id'])
channel_group_1.add_members((self.users[0] + self.users[2] + self.users[3] + self.users[6] + self.users[12]).partner_id.ids)
channel_group_2 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_create(name='group 2', privacy='groups')['id'])
channel_group_2.add_members((self.users[0] + self.users[2] + self.users[6] + self.users[7] + self.users[13]).partner_id.ids)
channel_channel_group_1 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_create(name='group 1', privacy='groups')['id'])
channel_channel_group_1.add_members((self.users[0] + self.users[2] + self.users[3] + self.users[6] + self.users[12]).partner_id.ids)
channel_channel_group_2 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_create(name='group 2', privacy='groups')['id'])
channel_channel_group_2.add_members((self.users[0] + self.users[2] + self.users[6] + self.users[7] + self.users[13]).partner_id.ids)
# create private channels
channel_private_1 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_create(name='private 1', privacy='private')['id'])
channel_private_1.add_members((self.users[0] + self.users[2] + self.users[3] + self.users[5] + self.users[10]).partner_id.ids)
channel_private_2 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_create(name='private 2', privacy='private')['id'])
channel_private_2.add_members((self.users[0] + self.users[2] + self.users[5] + self.users[7] + self.users[11]).partner_id.ids)
channel_channel_private_1 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_create(name='private 1', privacy='private')['id'])
channel_channel_private_1.add_members((self.users[0] + self.users[2] + self.users[3] + self.users[5] + self.users[10]).partner_id.ids)
channel_channel_private_2 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_create(name='private 2', privacy='private')['id'])
channel_channel_private_2.add_members((self.users[0] + self.users[2] + self.users[5] + self.users[7] + self.users[11]).partner_id.ids)
# create chats
channel_dm_1 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_get((self.users[0] + self.users[14]).partner_id.ids)['id'])
channel_dm_2 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_get((self.users[0] + self.users[15]).partner_id.ids)['id'])
channel_dm_3 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_get((self.users[0] + self.users[2]).partner_id.ids)['id'])
channel_dm_4 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_get((self.users[0] + self.users[3]).partner_id.ids)['id'])
channel_chat_1 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_get((self.users[0] + self.users[14]).partner_id.ids)['id'])
channel_chat_2 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_get((self.users[0] + self.users[15]).partner_id.ids)['id'])
channel_chat_3 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_get((self.users[0] + self.users[2]).partner_id.ids)['id'])
channel_chat_4 = self.env['mail.channel'].browse(self.env['mail.channel'].channel_get((self.users[0] + self.users[3]).partner_id.ids)['id'])
# create groups
channel_group_1 = self.env['mail.channel'].browse(self.env['mail.channel'].create_group((self.users[0] + self.users[12]).partner_id.ids)['id'])
# create livechats
im_livechat_channel = self.env['im_livechat.channel'].sudo().create({'name': 'support', 'user_ids': [Command.link(self.users[0].id)]})
self.users[0].im_status = 'online' # make available for livechat (ignore leave)
@@ -90,10 +92,11 @@ class TestDiscussFullPerformance(TransactionCase):
channel_livechat_2.with_user(self.env.ref('base.public_user')).sudo().message_post(body="test")
# add needaction
self.users[0].notification_type = 'inbox'
message = channel_public_1.message_post(body='test', message_type='comment', author_id=self.users[2].partner_id.id, partner_ids=self.users[0].partner_id.ids)
message = channel_channel_public_1.message_post(body='test', message_type='comment', author_id=self.users[2].partner_id.id, partner_ids=self.users[0].partner_id.ids)
# add star
message.toggle_message_starred()
self.maxDiff = None
self.users[0].flush()
self.users[0].invalidate_cache()
with self.assertQueryCount(emp=48):
@@ -129,19 +132,19 @@ class TestDiscussFullPerformance(TransactionCase):
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_public_1.id,
'id': channel_channel_public_1.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_public_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': next(res['message_id'] for res in channel_public_1._channel_last_message_ids()),
'last_interest_dt': channel_channel_public_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': next(res['message_id'] for res in channel_channel_public_1._channel_last_message_ids()),
'message_needaction_counter': 1,
'memberCount': 5,
'message_unread_counter': 0,
'name': 'public 1',
'public': 'public',
'seen_message_id': next(res['message_id'] for res in channel_public_1._channel_last_message_ids()),
'seen_message_id': next(res['message_id'] for res in channel_channel_public_1._channel_last_message_ids()),
'state': 'open',
'uuid': channel_public_1.uuid,
'uuid': channel_channel_public_1.uuid,
},
{
'channel_type': 'channel',
@@ -149,19 +152,19 @@ class TestDiscussFullPerformance(TransactionCase):
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_public_2.id,
'id': channel_channel_public_2.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_public_2.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': next(res['message_id'] for res in channel_public_2._channel_last_message_ids()),
'last_interest_dt': channel_channel_public_2.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': next(res['message_id'] for res in channel_channel_public_2._channel_last_message_ids()),
'memberCount': 5,
'message_needaction_counter': 0,
'message_unread_counter': 0,
'name': 'public 2',
'public': 'public',
'seen_message_id': next(res['message_id'] for res in channel_public_2._channel_last_message_ids()),
'seen_message_id': next(res['message_id'] for res in channel_channel_public_2._channel_last_message_ids()),
'state': 'open',
'uuid': channel_public_2.uuid,
'uuid': channel_channel_public_2.uuid,
},
{
'channel_type': 'channel',
@@ -169,90 +172,148 @@ class TestDiscussFullPerformance(TransactionCase):
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_channel_group_1.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_channel_group_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': next(res['message_id'] for res in channel_channel_group_1._channel_last_message_ids()),
'memberCount': 5,
'message_needaction_counter': 0,
'message_unread_counter': 0,
'name': 'group 1',
'public': 'groups',
'seen_message_id': next(res['message_id'] for res in channel_channel_group_1._channel_last_message_ids()),
'state': 'open',
'uuid': channel_channel_group_1.uuid,
},
{
'channel_type': 'channel',
'create_uid': self.env.user.id,
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_channel_group_2.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_channel_group_2.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': next(res['message_id'] for res in channel_channel_group_2._channel_last_message_ids()),
'memberCount': 5,
'message_needaction_counter': 0,
'message_unread_counter': 0,
'name': 'group 2',
'public': 'groups',
'seen_message_id': next(res['message_id'] for res in channel_channel_group_2._channel_last_message_ids()),
'state': 'open',
'uuid': channel_channel_group_2.uuid,
},
{
'channel_type': 'channel',
'create_uid': self.env.user.id,
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_channel_private_1.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_channel_private_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': next(res['message_id'] for res in channel_channel_private_1._channel_last_message_ids()),
'memberCount': 5,
'message_needaction_counter': 0,
'message_unread_counter': 0,
'name': 'private 1',
'public': 'private',
'seen_message_id': next(res['message_id'] for res in channel_channel_private_1._channel_last_message_ids()),
'state': 'open',
'uuid': channel_channel_private_1.uuid,
},
{
'channel_type': 'channel',
'create_uid': self.env.user.id,
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_channel_private_2.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_channel_private_2.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': next(res['message_id'] for res in channel_channel_private_2._channel_last_message_ids()),
'memberCount': 5,
'message_needaction_counter': 0,
'message_unread_counter': 0,
'name': 'private 2',
'public': 'private',
'seen_message_id': next(res['message_id'] for res in channel_channel_private_2._channel_last_message_ids()),
'state': 'open',
'uuid': channel_channel_private_2.uuid,
},
{
'channel_type': 'group',
'create_uid': self.env.user.id,
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_group_1.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_group_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': next(res['message_id'] for res in channel_group_1._channel_last_message_ids()),
'memberCount': 5,
'last_message_id': False,
'memberCount': 2,
'members': [
{
'active': True,
'display_name': 'Ernest Employee',
'email': 'e.e@example.com',
'id': self.users[0].partner_id.id,
'im_status': 'leave_offline',
'is_internal_user': True,
'name': 'Ernest Employee',
'out_of_office_date_end': self.leaves.filtered(lambda l: l.employee_id.user_id == self.users[0]).date_to.strftime(DEFAULT_SERVER_DATE_FORMAT),
'user_id': self.users[0].id,
},
{
'active': True,
'display_name': 'test12',
'email': False,
'id': self.users[12].partner_id.id,
'im_status': 'leave_offline',
'is_internal_user': True,
'name': 'test12',
'out_of_office_date_end': self.leaves.filtered(lambda l: l.employee_id.user_id == self.users[12]).date_to.strftime(DEFAULT_SERVER_DATE_FORMAT),
'user_id': self.users[12].id,
},
],
'message_needaction_counter': 0,
'message_unread_counter': 0,
'name': 'group 1',
'public': 'groups',
'seen_message_id': next(res['message_id'] for res in channel_group_1._channel_last_message_ids()),
'name': '',
'public': 'private',
'seen_message_id': False,
'seen_partners_info': [
{
'fetched_message_id': False,
'id': channel_group_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).id,
'partner_id': self.users[0].partner_id.id,
'seen_message_id': False,
},
{
'fetched_message_id': False,
'id': channel_group_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[12].partner_id).id,
'partner_id': self.users[12].partner_id.id,
'seen_message_id': False,
}
],
'state': 'open',
'uuid': channel_group_1.uuid,
},
{
'channel_type': 'channel',
'create_uid': self.env.user.id,
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_group_2.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_group_2.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': next(res['message_id'] for res in channel_group_2._channel_last_message_ids()),
'memberCount': 5,
'message_needaction_counter': 0,
'message_unread_counter': 0,
'name': 'group 2',
'public': 'groups',
'seen_message_id': next(res['message_id'] for res in channel_group_2._channel_last_message_ids()),
'state': 'open',
'uuid': channel_group_2.uuid,
},
{
'channel_type': 'channel',
'create_uid': self.env.user.id,
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_private_1.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_private_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': next(res['message_id'] for res in channel_private_1._channel_last_message_ids()),
'memberCount': 5,
'message_needaction_counter': 0,
'message_unread_counter': 0,
'name': 'private 1',
'public': 'private',
'seen_message_id': next(res['message_id'] for res in channel_private_1._channel_last_message_ids()),
'state': 'open',
'uuid': channel_private_1.uuid,
},
{
'channel_type': 'channel',
'create_uid': self.env.user.id,
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_private_2.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_private_2.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': next(res['message_id'] for res in channel_private_2._channel_last_message_ids()),
'memberCount': 5,
'message_needaction_counter': 0,
'message_unread_counter': 0,
'name': 'private 2',
'public': 'private',
'seen_message_id': next(res['message_id'] for res in channel_private_2._channel_last_message_ids()),
'state': 'open',
'uuid': channel_private_2.uuid,
},
{
'channel_type': 'chat',
'create_uid': self.env.user.id,
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_dm_1.id,
'id': channel_chat_1.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_dm_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_interest_dt': channel_chat_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': False,
'memberCount': 2,
'members': [
@@ -286,20 +347,20 @@ class TestDiscussFullPerformance(TransactionCase):
'seen_partners_info': [
{
'fetched_message_id': False,
'id': channel_dm_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).id,
'id': channel_chat_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).id,
'partner_id': self.users[0].partner_id.id,
'seen_message_id': False,
},
{
'fetched_message_id': False,
'id': channel_dm_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[14].partner_id).id,
'id': channel_chat_1.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[14].partner_id).id,
'partner_id': self.users[14].partner_id.id,
'seen_message_id': False,
},
],
'seen_message_id': False,
'state': 'open',
'uuid': channel_dm_1.uuid,
'uuid': channel_chat_1.uuid,
},
{
'channel_type': 'chat',
@@ -307,10 +368,10 @@ class TestDiscussFullPerformance(TransactionCase):
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_dm_2.id,
'id': channel_chat_2.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_dm_2.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_interest_dt': channel_chat_2.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': False,
'memberCount': 2,
'members': [
@@ -344,20 +405,20 @@ class TestDiscussFullPerformance(TransactionCase):
'seen_partners_info': [
{
'fetched_message_id': False,
'id': channel_dm_2.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).id,
'id': channel_chat_2.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).id,
'partner_id': self.users[0].partner_id.id,
'seen_message_id': False,
},
{
'fetched_message_id': False,
'id': channel_dm_2.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[15].partner_id).id,
'id': channel_chat_2.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[15].partner_id).id,
'partner_id': self.users[15].partner_id.id,
'seen_message_id': False,
},
],
'seen_message_id': False,
'state': 'open',
'uuid': channel_dm_2.uuid,
'uuid': channel_chat_2.uuid,
},
{
'channel_type': 'chat',
@@ -365,10 +426,10 @@ class TestDiscussFullPerformance(TransactionCase):
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_dm_3.id,
'id': channel_chat_3.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_dm_3.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_interest_dt': channel_chat_3.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': False,
'memberCount': 2,
'members': [
@@ -402,20 +463,20 @@ class TestDiscussFullPerformance(TransactionCase):
'seen_partners_info': [
{
'fetched_message_id': False,
'id': channel_dm_3.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).id,
'id': channel_chat_3.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).id,
'partner_id': self.users[0].partner_id.id,
'seen_message_id': False,
},
{
'fetched_message_id': False,
'id': channel_dm_3.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[2].partner_id).id,
'id': channel_chat_3.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[2].partner_id).id,
'partner_id': self.users[2].partner_id.id,
'seen_message_id': False,
},
],
'seen_message_id': False,
'state': 'open',
'uuid': channel_dm_3.uuid,
'uuid': channel_chat_3.uuid,
},
{
'channel_type': 'chat',
@@ -423,10 +484,10 @@ class TestDiscussFullPerformance(TransactionCase):
'custom_channel_name': False,
'description': False,
'group_based_subscription': False,
'id': channel_dm_4.id,
'id': channel_chat_4.id,
'is_minimized': False,
'is_pinned': True,
'last_interest_dt': channel_dm_4.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_interest_dt': channel_chat_4.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).last_interest_dt.strftime(DEFAULT_SERVER_DATETIME_FORMAT),
'last_message_id': False,
'memberCount': 2,
'members': [
@@ -460,20 +521,20 @@ class TestDiscussFullPerformance(TransactionCase):
'seen_partners_info': [
{
'fetched_message_id': False,
'id': channel_dm_4.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).id,
'id': channel_chat_4.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[0].partner_id).id,
'partner_id': self.users[0].partner_id.id,
'seen_message_id': False,
},
{
'fetched_message_id': False,
'id': channel_dm_4.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[3].partner_id).id,
'id': channel_chat_4.channel_last_seen_partner_ids.filtered(lambda p: p.partner_id == self.users[3].partner_id).id,
'partner_id': self.users[3].partner_id.id,
'seen_message_id': False,
},
],
'seen_message_id': False,
'state': 'open',
'uuid': channel_dm_4.uuid,
'uuid': channel_chat_4.uuid,
},
{
'channel_type': 'livechat',