# Part of Odoo. See LICENSE file for full copyright and licensing details.
from dateutil.relativedelta import relativedelta
from unittest.mock import patch, PropertyMock
from odoo import Command, fields
from odoo.tools.misc import limited_field_access_token
from odoo.addons.mail.tests.common import MailCommon
from odoo.addons.mail.tools.discuss import Store
from odoo.tests.common import users, tagged, HttpCase, warmup
@tagged('post_install', '-at_install')
class TestDiscussFullPerformance(HttpCase, MailCommon):
# Queries for _query_count_init_store (in order):
# 1: internalUserGroupId: ref exists
# 5: odoobot format:
# - ref exists
# - fetch res_partner (_read_format/_to_store)
# - _compute_im_status (_read_format/_to_store)
# - _get_on_leave_ids (_compute_im_status override)
# - fetch res_users (_to_store)
# 5: settings:
# - search (_find_or_create_for_user)
# - fetch res_partner (_format_settings: display_name of user_id because classic load)
# - fetch res_users_settings (_format_settings)
# - search res_users_settings_volumes (_format_settings)
# - search res_lang_res_users_settings_rel (_format_settings)
_query_count_init_store = 11
# Queries for _query_count_init_messaging (in order):
# 1: insert res_device_log
# 1: fetch res_company (building ir.rules)
# 1: fetch res_users (for current user, first occurence _init_messaging of mail_bot)
# 4: _get_channels_as_member
# - search channel_ids of current partner (_search_is_member, building member_domain)
# - fetch channel_ids of current partner (active test filtering, _search_is_member)
# - search discuss_channel (member_domain)
# - search discuss_channel (pinned_member_domain)
# 2: _init_messaging (discuss)
# - fetch discuss_channel_member (is_self)
# - _compute_message_unread
# 3: _init_messaging (mail)
# - _bus_last_id
# - _get_needaction_count (inbox counter)
# - starred counter
# 29: _process_request_for_all (discuss):
# - search discuss_channel (channels_domain)
# 28: channel _to_store:
# - _bus_last_id
# - manual query to search discuss_channel_member
# 10: channel member _to_store:
# - fetch discuss_channel_member
# 9: partner _to_store:
# - fetch res_partner (partner _to_store)
# - fetch res_users (_compute_im_status)
# - search bus_presence (_compute_im_status)
# - fetch bus_presence (_compute_im_status)
# - _get_on_leave_ids (_compute_im_status override)
# - search hr_employee (_compute_im_status override)
# - fetch hr_employee (_compute_im_status override)
# - search hr_leave (out_of_office_date_end)
# - fetch res_users (internal user)
# - fetch res_groups (authorizedGroupFullName)
# - fetch ir_module_category (authorizedGroupFullName)
# - search discuss_channel_member (is_member, channel ACL)
# - search ir_attachment (_compute_avatar_128)
# - search group_ids (group_based_subscription)
# - count discuss_channel_member (member_count)
# - _compute_message_needaction
# - search discuss_channel_rtc_session
# 8: rtc session _to_store:
# - fetch discuss_channel_rtc_session
# 7. channel member _to_store:
# - fetch discuss_channel_member
# 6: partner _to_store:
# - fetch res_parter
# - fetch res_users (_compute_im_status)
# - search bus_presence (_compute_im_status)
# - _get_on_leave_ids (_compute_im_status override)
# - search hr_employee (_compute_im_status override)
# - fetch hr_employee (_compute_im_status override)
_query_count_init_messaging = 41
# Queries for _query_count_discuss_channels (in order):
# 1: insert res_device_log
# 1: fetch res_users (for current user: first occurence current persona, _search_is_member)
# 4: _get_channels_as_member
# - search channel_ids of current partner (_search_is_member, building member_domain)
# - fetch channel_ids of current partner (active test filtering, _search_is_member)
# - search discuss_channel (member_domain)
# - search discuss_channel (pinned_member_domain)
# 31: channel _to_store:
# - _bus_last_id
# - manual query to search discuss_channel_member
# 16: channel member _to_store:
# - fetch discuss_channel_member
# 12: partner _to_store:
# - fetch res_partner (partner _to_store)
# - fetch res_users (_compute_im_status)
# - search bus_presence (_compute_im_status)
# - fetch bus_presence (_compute_im_status)
# - _get_on_leave_ids (_compute_im_status override)
# - search hr_employee (_compute_im_status override)
# - fetch hr_employee (_compute_im_status override)
# - search hr_leave (out_of_office_date_end)
# - fetch res_users (internal user)
# - search res_users_settings (livechat username)
# - fetch res_users_settings (livechat username)
# - fetch res_country (livechat override)
# 2: guest _to_store:
# - fetch bus_presence (_compute_im_status)
# - fetch mail_guest
# - im_livechat_channel_rule (is_bot)
# - fetch res_groups (authorizedGroupFullName)
# - fetch ir_module_category (authorizedGroupFullName)
# - search discuss_channel_member (is_member, channel ACL)
# - search ir_attachment (_compute_avatar_128)
# - search group_ids (group_based_subscription)
# - count discuss_channel_member (member_count)
# - _compute_message_needaction
# - _compute_message_unread
# - search discuss_channel_rtc_session
# 2: rtc session _to_store:
# - fetch discuss_channel_rtc_session
# - fetch discuss_channel_member
# - fetch im_livechat_channel
# - fetch country (anonymous_country)
# - _get_last_messages
# 14: message _to_store:
# - search mail_message_schedule
# - fetch mail_message
# - search mail_message_reaction
# - fetch mail_message_reaction
# - search message_attachment_rel
# - search mail_link_preview
# - search mail_message_subtype
# - search mail_message_res_partner_rel
# - search mail_notification
# - fetch mail_notification
# - search mail_tracking_value
# - search mail_message_res_partner_starred_rel
# - search rating_rating
# - _compute_rating_stats
_query_count_discuss_channels = 52
def setUp(self):
super().setUp()
self.maxDiff = None
self.group_user = self.env.ref('base.group_user')
self.password = 'Pl1bhD@2!kXZ'
self.users = self.env['res.users'].create([
{
'email': 'e.e@example.com',
'groups_id': [Command.link(self.group_user.id)],
'login': 'emp',
'name': 'Ernest Employee',
'notification_type': 'inbox',
'odoobot_state': 'disabled',
'password': self.password,
'signature': '--\nErnest',
},
{'name': 'test1', 'login': 'test1', 'password': self.password, 'email': 'test1@example.com', 'country_id': self.env.ref('base.in').id},
{'name': 'test2', 'login': 'test2', 'email': 'test2@example.com'},
{'name': 'test3', 'login': 'test3'},
{'name': 'test4', 'login': 'test4'},
{'name': 'test5', 'login': 'test5'},
{'name': 'test6', 'login': 'test6'},
{'name': 'test7', 'login': 'test7'},
{'name': 'test8', 'login': 'test8'},
{'name': 'test9', 'login': 'test9'},
{'name': 'test10', 'login': 'test10'},
{'name': 'test11', 'login': 'test11'},
{'name': 'test12', 'login': 'test12'},
{'name': 'test13', 'login': 'test13'},
{'name': 'test14', 'login': 'test14'},
{'name': 'test15', 'login': 'test15'},
])
self.employees = self.env['hr.employee'].create([{
'user_id': user.id,
} for user in self.users])
self.leave_type = self.env['hr.leave.type'].create({
'requires_allocation': 'no',
'name': 'Legal Leaves',
'time_type': 'leave',
})
self.leaves = self.env['hr.leave'].create([{
'request_date_from': fields.Datetime.today() + relativedelta(days=-2),
'request_date_to': fields.Datetime.today() + relativedelta(days=2),
'employee_id': employee.id,
'holiday_status_id': self.leave_type.id,
} for employee in self.employees])
self.authenticate(self.users[0].login, self.password)
Channel = self.env["discuss.channel"].with_user(self.users[0])
self.channel_general = self.env.ref('mail.channel_all_employees') # Unfortunately #general cannot be deleted. Assertions below assume data from a fresh db with demo.
self.channel_general.message_ids.unlink() # Remove messages to avoid depending on demo data.
self.channel_general.last_interest_dt = False # Reset state
self.channel_general.channel_member_ids.sudo().last_interest_dt = False # Reset state
self.env['discuss.channel'].sudo().search([('id', '!=', self.channel_general.id)]).unlink()
self.user_root = self.env.ref('base.user_root')
# create public channels
self.channel_channel_public_1 = Channel.channel_create(
name="public channel 1", group_id=None
)
self.channel_channel_public_1.add_members((self.users[0] + self.users[2] + self.users[3] + self.users[4] + self.users[8]).partner_id.ids)
self.channel_channel_public_2 = Channel.channel_create(
name="public channel 2", group_id=None
)
self.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 group-restricted channels
self.channel_channel_group_1 = Channel.channel_create(
name="group restricted channel 1", group_id=self.env.ref("base.group_user").id
)
self.channel_channel_group_1.add_members((self.users[0] + self.users[2] + self.users[3] + self.users[6] + self.users[12]).partner_id.ids)
self.channel_channel_group_2 = Channel.channel_create(
name="group restricted channel 2", group_id=self.env.ref("base.group_user").id
)
self.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 chats
self.channel_chat_1 = Channel.channel_get((self.users[0] + self.users[14]).partner_id.ids)
self.channel_chat_2 = Channel.channel_get((self.users[0] + self.users[15]).partner_id.ids)
self.channel_chat_3 = Channel.channel_get((self.users[0] + self.users[2]).partner_id.ids)
self.channel_chat_4 = Channel.channel_get((self.users[0] + self.users[3]).partner_id.ids)
# create groups
self.channel_group_1 = Channel.create_group((self.users[0] + self.users[12]).partner_id.ids)
# create livechats
self.im_livechat_channel = self.env['im_livechat.channel'].sudo().create({'name': 'support', 'user_ids': [Command.link(self.users[0].id)]})
self.env['bus.presence'].create({'user_id': self.users[0].id, 'status': 'online'}) # make available for livechat (ignore leave)
self.authenticate('test1', self.password)
self.channel_livechat_1 = Channel.browse(
self.make_jsonrpc_request(
"/im_livechat/get_session",
{
"anonymous_name": "anon 1",
"channel_id": self.im_livechat_channel.id,
"previous_operator_id": self.users[0].partner_id.id,
},
)["discuss.channel"][0]["id"]
)
self.channel_livechat_1.with_user(self.users[1]).message_post(body="test")
self.authenticate(None, None)
with patch(
"odoo.http.GeoIP.country_code",
new_callable=PropertyMock(return_value=self.env.ref("base.be").code),
):
self.channel_livechat_2 = Channel.browse(
self.make_jsonrpc_request(
"/im_livechat/get_session",
{
"anonymous_name": "anon 2",
"channel_id": self.im_livechat_channel.id,
"previous_operator_id": self.users[0].partner_id.id,
},
)["discuss.channel"][0]["id"]
)
self.guest = self.channel_livechat_2.channel_member_ids.guest_id.sudo()
self.make_jsonrpc_request("/mail/message/post", {
"post_data": {
"body": "test",
"message_type": "comment",
},
"thread_id": self.channel_livechat_2.id,
"thread_model": "discuss.channel",
}, headers={"Cookie": f"{self.guest._cookie_name}={self.guest._format_auth_cookie()};"})
# add needaction
self.users[0].notification_type = 'inbox'
message_0 = self.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,
)
members = self.channel_channel_public_1.channel_member_ids
member = members.filtered(lambda m: m.partner_id == self.users[0].partner_id).with_user(self.users[0])
member._mark_as_read(message_0.id)
# add star
message_0.toggle_message_starred()
self.env.company.sudo().name = 'YourCompany'
# add folded channel
members = self.channel_chat_1.channel_member_ids
member = members.with_user(self.users[0]).filtered(lambda m: m.is_self)
member.fold_state = "open"
# add call invitation
members = self.channel_channel_group_1.channel_member_ids
member_0 = members.with_user(self.users[0]).filtered(lambda m: m.is_self)
member_2 = members.with_user(self.users[2]).filtered(lambda m: m.is_self)
self.channel_channel_group_1_invited_member = member_0
# sudo: discuss.channel.rtc.session - creating a session in a test file
data = {"channel_id": self.channel_channel_group_1.id, "channel_member_id": member_2.id}
session = self.env["discuss.channel.rtc.session"].sudo().create(data)
member_0.rtc_inviting_session_id = session
# add some reactions with different users on different messages
message_1 = self.channel_general.message_post(
body="test", message_type="comment", author_id=self.users[0].partner_id.id
)
self.authenticate(self.users[0].login, self.password)
self._add_reactions(message_0, ["😊", "😏"])
self._add_reactions(message_1, ["😊"])
self.authenticate(self.users[1].login, self.password)
self._add_reactions(message_0, ["😊", "😏"])
self._add_reactions(message_1, ["😊", "😁"])
self.authenticate(self.users[2].login, self.password)
self._add_reactions(message_0, ["😊", "😁"])
self._add_reactions(message_1, ["😊", "😁", "👍"])
self.env.cr.precommit.run() # trigger the creation of bus.bus records
def _add_reactions(self, message, reactions):
for reaction in reactions:
self.make_jsonrpc_request(
"/mail/message/reaction",
{
"action": "add",
"content": reaction,
"message_id": message.id,
},
)
def _run_test(self, /, *, fn, count, results):
self.authenticate(self.users[0].login, self.password)
self.env["res.lang"]._get_data(code="en_US") # cache language for validation
with self.assertQueryCount(emp=count):
if self.warm:
with self.env.cr._enable_logging():
res = fn()
else:
res = fn()
self.assertEqual(res, results)
@users('emp')
@warmup
def test_10_init_store_data(self):
"""Test performance of `_init_store_data`."""
def test_fn():
store = Store()
self.env["res.users"].with_user(self.users[0])._init_store_data(store)
return store.get_result()
self._run_test(
fn=test_fn,
count=self._query_count_init_store,
results=self._get_init_store_data_result(),
)
@users('emp')
@warmup
def test_20_init_messaging(self):
"""Test performance of `init_messaging`."""
self._run_test(
fn=lambda: self.make_jsonrpc_request("/mail/action", {"init_messaging": {}}),
count=self._query_count_init_messaging,
results=self._get_init_messaging_result(),
)
@users("emp")
@warmup
def test_30_discuss_channels(self):
"""Test performance of `/mail/data` with `channels_as_member=True`."""
self._run_test(
fn=lambda: self.make_jsonrpc_request("/mail/data", {"channels_as_member": True}),
count=self._query_count_discuss_channels,
results=self._get_discuss_channels_result(),
)
def _get_init_store_data_result(self):
"""Returns the result of a call to init_messaging.
The point of having a separate getter is to allow it to be overriden.
"""
xmlid_to_res_id = self.env["ir.model.data"]._xmlid_to_res_id
return {
"res.partner": self._filter_partners_fields(
{
"active": False,
"avatar_128_access_token": limited_field_access_token(
self.user_root.partner_id, "avatar_128"
),
"email": "odoobot@example.com",
"id": self.user_root.partner_id.id,
"im_status": "bot",
"isInternalUser": True,
"is_company": False,
"name": "OdooBot",
"out_of_office_date_end": False,
"userId": self.user_root.id,
"write_date": fields.Datetime.to_string(self.user_root.partner_id.write_date),
},
{
"active": True,
"avatar_128_access_token": limited_field_access_token(
self.users[0].partner_id, "avatar_128"
),
"id": self.users[0].partner_id.id,
"isAdmin": False,
"isInternalUser": True,
"name": "Ernest Employee",
"notification_preference": "inbox",
"signature": self.users[0].signature,
"userId": self.users[0].id,
"write_date": fields.Datetime.to_string(self.users[0].partner_id.write_date),
},
),
"Store": {
"channel_types_with_seen_infos": sorted(["chat", "group", "livechat"]),
"action_discuss_id": xmlid_to_res_id("mail.action_discuss"),
"hasGifPickerFeature": False,
"hasLinkPreviewFeature": True,
"has_access_livechat": False,
"hasMessageTranslationFeature": False,
"internalUserGroupId": self.env.ref("base.group_user").id,
"mt_comment_id": xmlid_to_res_id("mail.mt_comment"),
"odoobot": {"id": self.user_root.partner_id.id, "type": "partner"},
"self": {"id": self.users[0].partner_id.id, "type": "partner"},
"settings": {
"channel_notifications": False,
"mute_until_dt": False,
"id": self.env["res.users.settings"]._find_or_create_for_user(self.users[0]).id,
"is_discuss_sidebar_category_channel_open": True,
"is_discuss_sidebar_category_chat_open": True,
"livechat_lang_ids": [],
"livechat_username": False,
"push_to_talk_key": False,
"use_push_to_talk": False,
"user_id": {"id": self.users[0].id},
"voice_active_duration": 200,
"volumes": [("ADD", [])],
},
},
}
def _get_init_messaging_result(self):
"""Returns the result of a call to init_messaging.
The point of having a separate getter is to allow it to be overriden.
"""
# sudo: bus.bus: reading non-sensitive last id
bus_last_id = self.env["bus.bus"].sudo()._bus_last_id()
return {
"discuss.channel": [
self._expected_result_for_channel(self.channel_channel_group_1),
self._expected_result_for_channel(self.channel_chat_1),
],
"discuss.channel.member": [
self._expected_result_for_channel_member(self.channel_channel_group_1, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_channel_group_1, self.users[2].partner_id),
self._expected_result_for_channel_member(self.channel_chat_1, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_chat_1, self.users[14].partner_id),
],
"discuss.channel.rtc.session": [
self._expected_result_for_rtc_session(self.channel_channel_group_1, self.users[2]),
],
"res.partner": self._filter_partners_fields(
self._expected_result_for_persona(self.users[0]),
self._expected_result_for_persona(self.users[2], only_inviting=True),
self._expected_result_for_persona(self.users[14]),
),
"Store": {
"inbox": {
"counter": 1,
"counter_bus_id": bus_last_id,
"id": "inbox",
"model": "mail.box",
},
"starred":
{
"counter": 1,
"counter_bus_id": bus_last_id,
"id": "starred",
"model": "mail.box",
},
"initChannelsUnreadCounter": 2,
},
}
def _get_discuss_channels_result(self):
"""Returns the result of a call to `/mail/data` with `channels_as_member=True`.
The point of having a separate getter is to allow it to be overriden.
"""
return {
"discuss.channel": [
self._expected_result_for_channel(self.channel_general),
self._expected_result_for_channel(self.channel_channel_public_1),
self._expected_result_for_channel(self.channel_channel_public_2),
self._expected_result_for_channel(self.channel_channel_group_1),
self._expected_result_for_channel(self.channel_channel_group_2),
self._expected_result_for_channel(self.channel_group_1),
self._expected_result_for_channel(self.channel_chat_1),
self._expected_result_for_channel(self.channel_chat_2),
self._expected_result_for_channel(self.channel_chat_3),
self._expected_result_for_channel(self.channel_chat_4),
self._expected_result_for_channel(self.channel_livechat_1),
self._expected_result_for_channel(self.channel_livechat_2),
],
"discuss.channel.member": [
self._expected_result_for_channel_member(self.channel_general, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_channel_public_1, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_channel_public_2, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_channel_group_1, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_channel_group_1, self.users[2].partner_id),
self._expected_result_for_channel_member(self.channel_channel_group_2, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_group_1, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_group_1, self.users[12].partner_id),
self._expected_result_for_channel_member(self.channel_chat_1, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_chat_1, self.users[14].partner_id),
self._expected_result_for_channel_member(self.channel_chat_2, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_chat_2, self.users[15].partner_id),
self._expected_result_for_channel_member(self.channel_chat_3, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_chat_3, self.users[2].partner_id),
self._expected_result_for_channel_member(self.channel_chat_4, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_chat_4, self.users[3].partner_id),
self._expected_result_for_channel_member(self.channel_livechat_1, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_livechat_1, self.users[1].partner_id),
self._expected_result_for_channel_member(self.channel_livechat_2, self.users[0].partner_id),
self._expected_result_for_channel_member(self.channel_livechat_2, guest=True),
],
"discuss.channel.rtc.session": [
self._expected_result_for_rtc_session(self.channel_channel_group_1, self.users[2]),
],
"im_livechat.channel": [
self._expected_result_for_livechat_channel(),
],
"mail.guest": [
self._expected_result_for_persona(guest=True),
],
"mail.message": self._filter_messages_fields(
self._expected_result_for_message(self.channel_general),
self._expected_result_for_message(self.channel_channel_public_1),
self._expected_result_for_message(self.channel_channel_public_2),
self._expected_result_for_message(self.channel_channel_group_1),
self._expected_result_for_message(self.channel_channel_group_2),
self._expected_result_for_message(self.channel_livechat_1),
self._expected_result_for_message(self.channel_livechat_2),
),
"mail.notification": [
self._expected_result_for_notification(self.channel_channel_public_1),
],
"mail.thread": self._filter_threads_fields(
self._expected_result_for_thread(self.channel_general),
self._expected_result_for_thread(self.channel_channel_public_1),
self._expected_result_for_thread(self.channel_channel_public_2),
self._expected_result_for_thread(self.channel_channel_group_1),
self._expected_result_for_thread(self.channel_channel_group_2),
self._expected_result_for_thread(self.channel_livechat_1),
self._expected_result_for_thread(self.channel_livechat_2),
),
"MessageReactions": [
*self._expected_result_for_message_reactions(self.channel_general),
*self._expected_result_for_message_reactions(self.channel_channel_public_1),
],
"res.partner": self._filter_partners_fields(
self._expected_result_for_persona(
self.users[0],
also_livechat=True,
also_notification=True,
),
self._expected_result_for_persona(self.users[2]),
self._expected_result_for_persona(self.users[12]),
self._expected_result_for_persona(self.users[14]),
self._expected_result_for_persona(self.users[15]),
self._expected_result_for_persona(self.users[3]),
self._expected_result_for_persona(self.users[1], also_livechat=True),
),
}
def _expected_result_for_channel(self, channel):
# sudo: bus.bus: reading non-sensitive last id
bus_last_id = self.env["bus.bus"].sudo()._bus_last_id()
members = channel.channel_member_ids
member_0 = members.filtered(lambda m: m.partner_id == self.users[0].partner_id)
member_2 = members.filtered(lambda m: m.partner_id == self.users[2].partner_id)
last_interest_dt = fields.Datetime.to_string(channel.last_interest_dt)
if channel == self.channel_general:
return {
"allow_public_upload": False,
"authorizedGroupFullName": self.group_user.full_name,
"anonymous_country": False,
"anonymous_name": False,
"avatarCacheKey": channel.avatar_cache_key,
"channel_type": "channel",
"custom_channel_name": False,
"fetchChannelInfoState": "fetched",
"id": channel.id,
"from_message_id": False,
"memberCount": len(self.group_user.users),
"create_uid": self.user_root.id,
"defaultDisplayMode": False,
"description": "General announcements for all employees.",
"group_based_subscription": True,
"group_public_id": self.group_user.id,
"invitedMembers": [["ADD", []]],
"is_editable": True,
"is_pinned": True,
"last_interest_dt": last_interest_dt,
"message_needaction_counter": 0,
"message_needaction_counter_bus_id": bus_last_id,
"name": "general",
"parent_channel_id": False,
"rtcSessions": [["ADD", []]],
"custom_notifications": False,
"mute_until_dt": False,
"state": "closed",
"uuid": channel.uuid,
}
if channel == self.channel_channel_public_1:
return {
"allow_public_upload": False,
"authorizedGroupFullName": False,
"anonymous_country": False,
"anonymous_name": False,
"avatarCacheKey": channel.avatar_cache_key,
"channel_type": "channel",
"custom_channel_name": False,
"fetchChannelInfoState": "fetched",
"id": channel.id,
"from_message_id": False,
"memberCount": 5,
"create_uid": self.env.user.id,
"defaultDisplayMode": False,
"description": False,
"group_based_subscription": False,
"group_public_id": False,
"invitedMembers": [["ADD", []]],
"is_editable": True,
"is_pinned": True,
"last_interest_dt": last_interest_dt,
"message_needaction_counter": 1,
"message_needaction_counter_bus_id": bus_last_id,
"name": "public channel 1",
"parent_channel_id": False,
"rtcSessions": [["ADD", []]],
"custom_notifications": False,
"mute_until_dt": False,
"state": "closed",
"uuid": channel.uuid,
}
if channel == self.channel_channel_public_2:
return {
"allow_public_upload": False,
"authorizedGroupFullName": False,
"anonymous_country": False,
"anonymous_name": False,
"avatarCacheKey": channel.avatar_cache_key,
"channel_type": "channel",
"custom_channel_name": False,
"fetchChannelInfoState": "fetched",
"id": channel.id,
"from_message_id": False,
"memberCount": 5,
"create_uid": self.env.user.id,
"defaultDisplayMode": False,
"description": False,
"group_based_subscription": False,
"group_public_id": False,
"invitedMembers": [["ADD", []]],
"is_editable": True,
"is_pinned": True,
"last_interest_dt": last_interest_dt,
"message_needaction_counter": 0,
"message_needaction_counter_bus_id": bus_last_id,
"name": "public channel 2",
"parent_channel_id": False,
"rtcSessions": [["ADD", []]],
"custom_notifications": False,
"mute_until_dt": False,
"state": "closed",
"uuid": channel.uuid,
}
if channel == self.channel_channel_group_1:
return {
"allow_public_upload": False,
"authorizedGroupFullName": self.group_user.full_name,
"anonymous_country": False,
"anonymous_name": False,
"avatarCacheKey": channel.avatar_cache_key,
"channel_type": "channel",
"custom_channel_name": False,
"fetchChannelInfoState": "fetched",
"id": channel.id,
"from_message_id": False,
"memberCount": 5,
"create_uid": self.env.user.id,
"defaultDisplayMode": False,
"description": False,
"group_based_subscription": False,
"group_public_id": self.group_user.id,
"invitedMembers": [["ADD", [member_0.id]]],
"is_editable": True,
"is_pinned": True,
"last_interest_dt": last_interest_dt,
"message_needaction_counter": 0,
"message_needaction_counter_bus_id": bus_last_id,
"name": "group restricted channel 1",
"parent_channel_id": False,
# sudo: discuss.channel.rtc.session - reading a session in a test file
"rtcInvitingSession": member_2.sudo().rtc_session_ids.id,
# sudo: discuss.channel.rtc.session - reading a session in a test file
"rtcSessions": [["ADD", [member_2.sudo().rtc_session_ids.id]]],
"custom_notifications": False,
"mute_until_dt": False,
"state": "closed",
"uuid": channel.uuid,
}
if channel == self.channel_channel_group_2:
return {
"allow_public_upload": False,
"authorizedGroupFullName": self.group_user.full_name,
"anonymous_country": False,
"anonymous_name": False,
"avatarCacheKey": channel.avatar_cache_key,
"channel_type": "channel",
"custom_channel_name": False,
"fetchChannelInfoState": "fetched",
"id": channel.id,
"from_message_id": False,
"memberCount": 5,
"create_uid": self.env.user.id,
"defaultDisplayMode": False,
"description": False,
"group_based_subscription": False,
"group_public_id": self.group_user.id,
"invitedMembers": [["ADD", []]],
"is_editable": True,
"is_pinned": True,
"last_interest_dt": last_interest_dt,
"message_needaction_counter": 0,
"message_needaction_counter_bus_id": bus_last_id,
"name": "group restricted channel 2",
"parent_channel_id": False,
"rtcSessions": [["ADD", []]],
"custom_notifications": False,
"mute_until_dt": False,
"state": "closed",
"uuid": channel.uuid,
}
if channel == self.channel_group_1:
return {
"allow_public_upload": False,
"authorizedGroupFullName": False,
"anonymous_country": False,
"anonymous_name": False,
"avatarCacheKey": channel.avatar_cache_key,
"channel_type": "group",
"custom_channel_name": False,
"fetchChannelInfoState": "fetched",
"id": channel.id,
"from_message_id": False,
"memberCount": 2,
"create_uid": self.env.user.id,
"defaultDisplayMode": False,
"description": False,
"group_based_subscription": False,
"group_public_id": False,
"invitedMembers": [["ADD", []]],
"is_editable": True,
"is_pinned": True,
"last_interest_dt": False,
"message_needaction_counter": 0,
"message_needaction_counter_bus_id": bus_last_id,
"name": "",
"parent_channel_id": False,
"rtcSessions": [["ADD", []]],
"custom_notifications": False,
"mute_until_dt": False,
"state": "closed",
"uuid": channel.uuid,
}
if channel == self.channel_chat_1:
return {
"allow_public_upload": False,
"authorizedGroupFullName": False,
"anonymous_country": False,
"anonymous_name": False,
"avatarCacheKey": channel.avatar_cache_key,
"channel_type": "chat",
"custom_channel_name": False,
"fetchChannelInfoState": "fetched",
"id": channel.id,
"from_message_id": False,
"memberCount": 2,
"create_uid": self.env.user.id,
"defaultDisplayMode": False,
"description": False,
"group_based_subscription": False,
"group_public_id": False,
"invitedMembers": [["ADD", []]],
"is_editable": True,
"is_pinned": True,
"last_interest_dt": False,
"message_needaction_counter": 0,
"message_needaction_counter_bus_id": bus_last_id,
"name": "Ernest Employee, test14",
"parent_channel_id": False,
"rtcSessions": [["ADD", []]],
"custom_notifications": False,
"mute_until_dt": False,
"state": "open",
"uuid": channel.uuid,
}
if channel == self.channel_chat_2:
return {
"allow_public_upload": False,
"authorizedGroupFullName": False,
"anonymous_country": False,
"anonymous_name": False,
"avatarCacheKey": channel.avatar_cache_key,
"channel_type": "chat",
"custom_channel_name": False,
"fetchChannelInfoState": "fetched",
"id": channel.id,
"from_message_id": False,
"memberCount": 2,
"create_uid": self.env.user.id,
"defaultDisplayMode": False,
"description": False,
"group_based_subscription": False,
"group_public_id": False,
"invitedMembers": [["ADD", []]],
"is_editable": True,
"is_pinned": True,
"last_interest_dt": False,
"message_needaction_counter": 0,
"message_needaction_counter_bus_id": bus_last_id,
"name": "Ernest Employee, test15",
"parent_channel_id": False,
"rtcSessions": [["ADD", []]],
"custom_notifications": False,
"mute_until_dt": False,
"state": "closed",
"uuid": channel.uuid,
}
if channel == self.channel_chat_3:
return {
"allow_public_upload": False,
"authorizedGroupFullName": False,
"anonymous_country": False,
"anonymous_name": False,
"avatarCacheKey": channel.avatar_cache_key,
"channel_type": "chat",
"custom_channel_name": False,
"fetchChannelInfoState": "fetched",
"id": channel.id,
"from_message_id": False,
"memberCount": 2,
"create_uid": self.env.user.id,
"defaultDisplayMode": False,
"description": False,
"group_based_subscription": False,
"group_public_id": False,
"invitedMembers": [["ADD", []]],
"is_editable": True,
"is_pinned": True,
"last_interest_dt": False,
"message_needaction_counter": 0,
"message_needaction_counter_bus_id": bus_last_id,
"name": "Ernest Employee, test2",
"parent_channel_id": False,
"rtcSessions": [["ADD", []]],
"custom_notifications": False,
"mute_until_dt": False,
"state": "closed",
"uuid": channel.uuid,
}
if channel == self.channel_chat_4:
return {
"allow_public_upload": False,
"authorizedGroupFullName": False,
"anonymous_country": False,
"anonymous_name": False,
"avatarCacheKey": channel.avatar_cache_key,
"channel_type": "chat",
"custom_channel_name": False,
"fetchChannelInfoState": "fetched",
"id": channel.id,
"from_message_id": False,
"memberCount": 2,
"create_uid": self.env.user.id,
"defaultDisplayMode": False,
"description": False,
"group_based_subscription": False,
"group_public_id": False,
"invitedMembers": [["ADD", []]],
"is_editable": True,
"is_pinned": True,
"last_interest_dt": False,
"message_needaction_counter": 0,
"message_needaction_counter_bus_id": bus_last_id,
"name": "Ernest Employee, test3",
"parent_channel_id": False,
"rtcSessions": [["ADD", []]],
"custom_notifications": False,
"mute_until_dt": False,
"state": "closed",
"uuid": channel.uuid,
}
if channel == self.channel_livechat_1:
return {
"allow_public_upload": False,
"authorizedGroupFullName": False,
"anonymous_country": {
"code": "IN",
"id": self.env.ref("base.in").id,
"name": "India",
},
"anonymous_name": False,
"avatarCacheKey": channel.avatar_cache_key,
"channel_type": "livechat",
"custom_channel_name": False,
"fetchChannelInfoState": "fetched",
"id": channel.id,
"from_message_id": False,
"memberCount": 2,
"create_uid": self.users[1].id,
"defaultDisplayMode": False,
"description": False,
"group_based_subscription": False,
"group_public_id": False,
"invitedMembers": [["ADD", []]],
"is_editable": True,
"is_pinned": True,
"last_interest_dt": last_interest_dt,
"livechatChannel": self.im_livechat_channel.id,
"livechat_active": True,
"message_needaction_counter": 0,
"message_needaction_counter_bus_id": bus_last_id,
"name": "test1 Ernest Employee",
"parent_channel_id": False,
"custom_notifications": False,
"mute_until_dt": False,
"operator": {"id": self.users[0].partner_id.id, "type": "partner"},
"rtcSessions": [["ADD", []]],
"state": "closed",
"uuid": channel.uuid,
}
if channel == self.channel_livechat_2:
return {
"allow_public_upload": False,
"authorizedGroupFullName": False,
"anonymous_country": {
"id": self.env.ref("base.be").id,
"code": "BE",
"name": "Belgium",
},
"anonymous_name": "anon 2",
"avatarCacheKey": channel.avatar_cache_key,
"channel_type": "livechat",
"custom_channel_name": False,
"fetchChannelInfoState": "fetched",
"id": channel.id,
"from_message_id": False,
"memberCount": 2,
"create_uid": self.env.ref("base.public_user").id,
"defaultDisplayMode": False,
"description": False,
"group_based_subscription": False,
"group_public_id": False,
"invitedMembers": [["ADD", []]],
"is_editable": True,
"is_pinned": True,
"last_interest_dt": last_interest_dt,
"livechatChannel": self.im_livechat_channel.id,
"livechat_active": True,
"message_needaction_counter": 0,
"message_needaction_counter_bus_id": bus_last_id,
"name": "anon 2 Ernest Employee",
"custom_notifications": False,
"mute_until_dt": False,
"operator": {"id": self.users[0].partner_id.id, "type": "partner"},
"parent_channel_id": False,
"rtcSessions": [["ADD", []]],
"state": "closed",
"uuid": channel.uuid,
}
return {}
def _expected_result_for_channel_member(self, channel, partner=None, guest=None):
members = channel.channel_member_ids
member_0 = members.filtered(lambda m: m.partner_id == self.users[0].partner_id)
member_0_last_interest_dt = fields.Datetime.to_string(member_0.last_interest_dt)
member_0_last_seen_dt = fields.Datetime.to_string(member_0.last_seen_dt)
member_0_create_date = fields.Datetime.to_string(member_0.create_date)
member_1 = members.filtered(lambda m: m.partner_id == self.users[1].partner_id)
member_2 = members.filtered(lambda m: m.partner_id == self.users[2].partner_id)
member_3 = members.filtered(lambda m: m.partner_id == self.users[3].partner_id)
member_12 = members.filtered(lambda m: m.partner_id == self.users[12].partner_id)
member_14 = members.filtered(lambda m: m.partner_id == self.users[14].partner_id)
member_15 = members.filtered(lambda m: m.partner_id == self.users[15].partner_id)
last_message = channel._get_last_messages()
member_g = members.filtered(lambda m: m.guest_id)
guest = member_g.guest_id
# sudo: bus.bus: reading non-sensitive last id
bus_last_id = self.env["bus.bus"].sudo()._bus_last_id()
if channel == self.channel_general and partner == self.users[0].partner_id:
return {
"create_date": member_0_create_date,
"fetched_message_id": False,
"id": member_0.id,
"last_interest_dt": member_0_last_interest_dt,
"message_unread_counter": 1,
"message_unread_counter_bus_id": bus_last_id,
"last_seen_dt": member_0_last_seen_dt,
"new_message_separator": 0,
"persona": {"id": self.users[0].partner_id.id, "type": "partner"},
"seen_message_id": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_channel_public_1 and partner == self.users[0].partner_id:
return {
"create_date": member_0_create_date,
"fetched_message_id": last_message.id,
"id": member_0.id,
"last_interest_dt": member_0_last_interest_dt,
"message_unread_counter": 0,
"message_unread_counter_bus_id": bus_last_id,
"last_seen_dt": member_0_last_seen_dt,
"new_message_separator": last_message.id + 1,
"persona": {"id": self.users[0].partner_id.id, "type": "partner"},
"seen_message_id": last_message.id,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_channel_public_2 and partner == self.users[0].partner_id:
return {
"create_date": member_0_create_date,
"fetched_message_id": last_message.id,
"id": member_0.id,
"last_interest_dt": member_0_last_interest_dt,
"message_unread_counter": 0,
"message_unread_counter_bus_id": bus_last_id,
"last_seen_dt": member_0_last_seen_dt,
"new_message_separator": last_message.id + 1,
"persona": {"id": self.users[0].partner_id.id, "type": "partner"},
"seen_message_id": last_message.id,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_channel_group_1 and partner == self.users[0].partner_id:
return {
"create_date": member_0_create_date,
"fetched_message_id": last_message.id,
"id": member_0.id,
"last_interest_dt": member_0_last_interest_dt,
"message_unread_counter": 0,
"message_unread_counter_bus_id": bus_last_id,
"last_seen_dt": member_0_last_seen_dt,
"new_message_separator": last_message.id + 1,
"persona": {"id": self.users[0].partner_id.id, "type": "partner"},
"seen_message_id": last_message.id,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_channel_group_1 and partner == self.users[2].partner_id:
return {
"id": member_2.id,
"persona": {"id": self.users[2].partner_id.id, "type": "partner"},
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_channel_group_2 and partner == self.users[0].partner_id:
return {
"create_date": member_0_create_date,
"fetched_message_id": last_message.id,
"id": member_0.id,
"last_interest_dt": member_0_last_interest_dt,
"message_unread_counter": 0,
"message_unread_counter_bus_id": bus_last_id,
"last_seen_dt": member_0_last_seen_dt,
"new_message_separator": last_message.id + 1,
"persona": {"id": self.users[0].partner_id.id, "type": "partner"},
"seen_message_id": last_message.id,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_group_1 and partner == self.users[0].partner_id:
return {
"create_date": member_0_create_date,
"fetched_message_id": False,
"id": member_0.id,
"last_interest_dt": member_0_last_interest_dt,
"message_unread_counter": 0,
"message_unread_counter_bus_id": bus_last_id,
"last_seen_dt": member_0_last_seen_dt,
"new_message_separator": 0,
"persona": {"id": self.users[0].partner_id.id, "type": "partner"},
"seen_message_id": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_group_1 and partner == self.users[12].partner_id:
return {
"create_date": fields.Datetime.to_string(member_12.create_date),
"last_seen_dt": False,
"fetched_message_id": False,
"id": member_12.id,
"persona": {"id": self.users[12].partner_id.id, "type": "partner"},
"seen_message_id": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_chat_1 and partner == self.users[0].partner_id:
return {
"create_date": member_0_create_date,
"fetched_message_id": False,
"id": member_0.id,
"last_interest_dt": member_0_last_interest_dt,
"message_unread_counter": 0,
"message_unread_counter_bus_id": bus_last_id,
"last_seen_dt": member_0_last_seen_dt,
"new_message_separator": 0,
"persona": {"id": self.users[0].partner_id.id, "type": "partner"},
"seen_message_id": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_chat_1 and partner == self.users[14].partner_id:
return {
"create_date": fields.Datetime.to_string(member_14.create_date),
"last_seen_dt": False,
"fetched_message_id": False,
"id": member_14.id,
"persona": {"id": self.users[14].partner_id.id, "type": "partner"},
"seen_message_id": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_chat_2 and partner == self.users[0].partner_id:
return {
"create_date": member_0_create_date,
"fetched_message_id": False,
"id": member_0.id,
"last_interest_dt": member_0_last_interest_dt,
"message_unread_counter": 0,
"message_unread_counter_bus_id": bus_last_id,
"last_seen_dt": member_0_last_seen_dt,
"new_message_separator": 0,
"persona": {"id": self.users[0].partner_id.id, "type": "partner"},
"seen_message_id": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_chat_2 and partner == self.users[15].partner_id:
return {
"create_date": fields.Datetime.to_string(member_15.create_date),
"last_seen_dt": False,
"fetched_message_id": False,
"id": member_15.id,
"persona": {"id": self.users[15].partner_id.id, "type": "partner"},
"seen_message_id": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_chat_3 and partner == self.users[0].partner_id:
return {
"create_date": member_0_create_date,
"fetched_message_id": False,
"id": member_0.id,
"last_interest_dt": member_0_last_interest_dt,
"message_unread_counter": 0,
"message_unread_counter_bus_id": bus_last_id,
"last_seen_dt": member_0_last_seen_dt,
"new_message_separator": 0,
"persona": {"id": self.users[0].partner_id.id, "type": "partner"},
"seen_message_id": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_chat_3 and partner == self.users[2].partner_id:
return {
"create_date": fields.Datetime.to_string(member_2.create_date),
"last_seen_dt": False,
"fetched_message_id": False,
"id": member_2.id,
"persona": {"id": self.users[2].partner_id.id, "type": "partner"},
"seen_message_id": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_chat_4 and partner == self.users[0].partner_id:
return {
"create_date": member_0_create_date,
"fetched_message_id": False,
"id": member_0.id,
"last_interest_dt": member_0_last_interest_dt,
"message_unread_counter": 0,
"message_unread_counter_bus_id": bus_last_id,
"last_seen_dt": member_0_last_seen_dt,
"new_message_separator": 0,
"persona": {"id": self.users[0].partner_id.id, "type": "partner"},
"seen_message_id": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_chat_4 and partner == self.users[3].partner_id:
return {
"create_date": fields.Datetime.to_string(member_3.create_date),
"last_seen_dt": False,
"fetched_message_id": False,
"id": member_3.id,
"persona": {"id": self.users[3].partner_id.id, "type": "partner"},
"seen_message_id": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_livechat_1 and partner == self.users[0].partner_id:
return {
"create_date": member_0_create_date,
"fetched_message_id": False,
"id": member_0.id,
"is_bot": False,
"last_interest_dt": member_0_last_interest_dt,
"message_unread_counter": 0,
"message_unread_counter_bus_id": bus_last_id,
"last_seen_dt": member_0_last_seen_dt,
"new_message_separator": 0,
"persona": {"id": self.users[0].partner_id.id, "type": "partner"},
"seen_message_id": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_livechat_1 and partner == self.users[1].partner_id:
return {
"create_date": fields.Datetime.to_string(member_1.create_date),
"last_seen_dt": fields.Datetime.to_string(member_1.last_seen_dt),
"fetched_message_id": last_message.id,
"id": member_1.id,
"is_bot": False,
"persona": {"id": self.users[1].partner_id.id, "type": "partner"},
"seen_message_id": last_message.id,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_livechat_2 and partner == self.users[0].partner_id:
return {
"create_date": member_0_create_date,
"fetched_message_id": False,
"id": member_0.id,
"is_bot": False,
"last_interest_dt": member_0_last_interest_dt,
"message_unread_counter": 1,
"message_unread_counter_bus_id": bus_last_id,
"last_seen_dt": member_0_last_seen_dt,
"new_message_separator": 0,
"persona": {"id": self.users[0].partner_id.id, "type": "partner"},
"seen_message_id": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
if channel == self.channel_livechat_2 and guest:
return {
"create_date": fields.Datetime.to_string(member_g.create_date),
"last_seen_dt": fields.Datetime.to_string(member_g.last_seen_dt),
"fetched_message_id": last_message.id,
"id": member_g.id,
"is_bot": False,
"persona": {"id": guest.id, "type": "guest"},
"seen_message_id": last_message.id,
"thread": {"id": channel.id, "model": "discuss.channel"},
}
return {}
def _expected_result_for_livechat_channel(self):
return {"id": self.im_livechat_channel.id, "name": "support"}
def _expected_result_for_message(self, channel):
last_message = channel._get_last_messages()
create_date = fields.Datetime.to_string(last_message.create_date)
date = fields.Datetime.to_string(last_message.date)
write_date = fields.Datetime.to_string(last_message.write_date)
user_0 = self.users[0]
user_1 = self.users[1]
user_2 = self.users[2]
user_9 = self.users[9]
user_12 = self.users[12]
user_13 = self.users[13]
members = channel.channel_member_ids
member_g = members.filtered(lambda m: m.guest_id)
guest = member_g.guest_id
if channel == self.channel_general:
return {
"attachment_ids": [],
"author": {"id": user_0.partner_id.id, "type": "partner"},
"body": "test
",
"create_date": create_date,
"date": date,
"default_subject": "general",
"email_from": '"Ernest Employee" ',
"id": last_message.id,
"is_discussion": False,
"is_note": True,
"linkPreviews": [],
"message_type": "comment",
"model": "discuss.channel",
"needaction": False,
"notifications": [],
"parentMessage": False,
"pinned_at": False,
"rating_id": False,
"reactions": [
{"content": "👍", "message": last_message.id},
{"content": "😁", "message": last_message.id},
{"content": "😊", "message": last_message.id},
],
"recipients": [],
"record_name": "general",
"res_id": 1,
"scheduledDatetime": False,
"starred": False,
"subject": False,
"subtype_description": False,
"thread": {"id": channel.id, "model": "discuss.channel"},
"trackingValues": [],
"write_date": write_date,
}
if channel == self.channel_channel_public_1:
return {
"attachment_ids": [],
"author": {"id": user_2.partner_id.id, "type": "partner"},
"body": "test
",
"create_date": create_date,
"date": date,
"default_subject": "public channel 1",
"email_from": '"test2" ',
"id": last_message.id,
"is_discussion": False,
"is_note": True,
"linkPreviews": [],
"message_type": "comment",
"model": "discuss.channel",
"needaction": True,
"notifications": [last_message.notification_ids.id],
"thread": {"id": channel.id, "model": "discuss.channel"},
"parentMessage": False,
"pinned_at": False,
"rating_id": False,
"reactions": [
{"content": "😁", "message": last_message.id},
{"content": "😊", "message": last_message.id},
{"content": "😏", "message": last_message.id},
],
"recipients": [{"id": self.users[0].partner_id.id, "type": "partner"}],
"record_name": "public channel 1",
"res_id": channel.id,
"scheduledDatetime": False,
"starred": True,
"subject": False,
"subtype_description": False,
"trackingValues": [],
"write_date": write_date,
}
if channel == self.channel_channel_public_2:
return {
"attachment_ids": [],
"author": {"id": user_0.partner_id.id, "type": "partner"},
"body": f'',
"create_date": create_date,
"date": date,
"default_subject": "public channel 2",
"email_from": '"Ernest Employee" ',
"id": last_message.id,
"is_discussion": True,
"is_note": False,
"linkPreviews": [],
"message_type": "notification",
"model": "discuss.channel",
"needaction": False,
"notifications": [],
"thread": {"id": channel.id, "model": "discuss.channel"},
"parentMessage": False,
"pinned_at": False,
"rating_id": False,
"reactions": [],
"recipients": [],
"record_name": "public channel 2",
"res_id": channel.id,
"scheduledDatetime": False,
"starred": False,
"subject": False,
"subtype_description": False,
"trackingValues": [],
"write_date": write_date,
}
if channel == self.channel_channel_group_1:
return {
"attachment_ids": [],
"author": {"id": user_0.partner_id.id, "type": "partner"},
"body": f'',
"create_date": create_date,
"date": date,
"default_subject": "group restricted channel 1",
"email_from": '"Ernest Employee" ',
"id": last_message.id,
"is_discussion": True,
"is_note": False,
"linkPreviews": [],
"message_type": "notification",
"model": "discuss.channel",
"needaction": False,
"notifications": [],
"thread": {"id": channel.id, "model": "discuss.channel"},
"parentMessage": False,
"pinned_at": False,
"rating_id": False,
"reactions": [],
"recipients": [],
"record_name": "group restricted channel 1",
"res_id": channel.id,
"scheduledDatetime": False,
"starred": False,
"subject": False,
"subtype_description": False,
"trackingValues": [],
"write_date": write_date,
}
if channel == self.channel_channel_group_2:
return {
"attachment_ids": [],
"author": {"id": user_0.partner_id.id, "type": "partner"},
"body": f'',
"create_date": create_date,
"date": date,
"default_subject": "group restricted channel 2",
"email_from": '"Ernest Employee" ',
"id": last_message.id,
"is_discussion": True,
"is_note": False,
"linkPreviews": [],
"message_type": "notification",
"model": "discuss.channel",
"needaction": False,
"notifications": [],
"thread": {"id": channel.id, "model": "discuss.channel"},
"parentMessage": False,
"pinned_at": False,
"rating_id": False,
"reactions": [],
"recipients": [],
"record_name": "group restricted channel 2",
"res_id": channel.id,
"scheduledDatetime": False,
"starred": False,
"subject": False,
"subtype_description": False,
"trackingValues": [],
"write_date": write_date,
}
if channel == self.channel_livechat_1:
return {
"attachment_ids": [],
"author": {"id": user_1.partner_id.id, "type": "partner"},
"body": "test
",
"create_date": create_date,
"date": date,
"default_subject": "test1 Ernest Employee",
"id": last_message.id,
"is_discussion": False,
"is_note": True,
"linkPreviews": [],
"message_type": "notification",
"model": "discuss.channel",
"needaction": False,
"notifications": [],
"thread": {"id": channel.id, "model": "discuss.channel"},
"parentMessage": False,
"pinned_at": False,
"rating_id": False,
"reactions": [],
"recipients": [],
"record_name": "test1 Ernest Employee",
"res_id": channel.id,
"scheduledDatetime": False,
"starred": False,
"subject": False,
"subtype_description": False,
"trackingValues": [],
"write_date": write_date,
}
if channel == self.channel_livechat_2:
return {
"attachment_ids": [],
"author": {"id": guest.id, "type": "guest"},
"body": "test
",
"create_date": create_date,
"date": date,
"default_subject": "anon 2 Ernest Employee",
"email_from": False,
"id": last_message.id,
"is_discussion": False,
"is_note": True,
"linkPreviews": [],
"message_type": "comment",
"model": "discuss.channel",
"needaction": False,
"notifications": [],
"thread": {"id": channel.id, "model": "discuss.channel"},
"parentMessage": False,
"pinned_at": False,
"rating_id": False,
"reactions": [],
"recipients": [],
"record_name": "anon 2 Ernest Employee",
"res_id": channel.id,
"scheduledDatetime": False,
"starred": False,
"subject": False,
"subtype_description": False,
"trackingValues": [],
"write_date": write_date,
}
return {}
def _expected_result_for_message_reactions(self, channel):
last_message = channel._get_last_messages()
partner_0 = self.users[0].partner_id.id
partner_1 = self.users[1].partner_id.id
partner_2 = self.users[2].partner_id.id
reactions_0 = last_message.sudo().reaction_ids.filtered(lambda r: r.content == "👍")
reactions_1 = last_message.sudo().reaction_ids.filtered(lambda r: r.content == "😁")
reactions_2 = last_message.sudo().reaction_ids.filtered(lambda r: r.content == "😊")
reactions_3 = last_message.sudo().reaction_ids.filtered(lambda r: r.content == "😏")
if channel == self.channel_general:
return [
{
"content": "👍",
"count": 1,
"message": last_message.id,
"sequence": min(reactions_0.ids),
"personas": [{"id": partner_2, "type": "partner"}],
},
{
"content": "😁",
"count": 2,
"message": last_message.id,
"sequence": min(reactions_1.ids),
"personas": [
{"id": partner_2, "type": "partner"},
{"id": partner_1, "type": "partner"},
],
},
{
"content": "😊",
"count": 3,
"message": last_message.id,
"sequence": min(reactions_2.ids),
"personas": [
{"id": partner_2, "type": "partner"},
{"id": partner_1, "type": "partner"},
{"id": partner_0, "type": "partner"},
],
},
]
if channel == self.channel_channel_public_1:
return [
{
"content": "😁",
"count": 1,
"message": last_message.id,
"sequence": min(reactions_1.ids),
"personas": [{"id": partner_2, "type": "partner"}],
},
{
"content": "😊",
"count": 3,
"message": last_message.id,
"sequence": min(reactions_2.ids),
"personas": [
{"id": partner_2, "type": "partner"},
{"id": partner_1, "type": "partner"},
{"id": partner_0, "type": "partner"},
],
},
{
"content": "😏",
"count": 2,
"message": last_message.id,
"sequence": min(reactions_3.ids),
"personas": [
{"id": partner_1, "type": "partner"},
{"id": partner_0, "type": "partner"},
],
},
]
def _expected_result_for_notification(self, channel):
last_message = channel._get_last_messages()
if channel == self.channel_channel_public_1:
return {
"failure_type": False,
"id": last_message.notification_ids.id,
"message": last_message.id,
"notification_status": "sent",
"notification_type": "inbox",
"persona": {"id": self.users[0].partner_id.id, "type": "partner"},
}
return {}
def _expected_result_for_persona(
self,
user=None,
guest=None,
only_inviting=False,
also_livechat=False,
also_notification=False,
):
if user == self.users[0]:
res = {
"active": True,
"avatar_128_access_token": limited_field_access_token(
user.partner_id, "avatar_128"
),
"email": "e.e@example.com",
"id": user.partner_id.id,
"im_status": "online",
"is_company": False,
"isInternalUser": True,
"name": "Ernest Employee",
"out_of_office_date_end": False,
"userId": user.id,
"write_date": fields.Datetime.to_string(user.partner_id.write_date),
}
if also_livechat:
res.update(
{
"country": False,
"is_public": False,
"user_livechat_username": False,
}
)
if also_notification:
res["name"] = "Ernest Employee"
return res
if user == self.users[1]:
res = {
"active": True,
"avatar_128_access_token": limited_field_access_token(
user.partner_id, "avatar_128"
),
"country": {
"code": "IN",
"id": self.env.ref("base.in").id,
"name": "India",
},
"id": user.partner_id.id,
"isInternalUser": True,
"is_company": False,
"is_public": False,
"name": "test1",
"userId": user.id,
"write_date": fields.Datetime.to_string(user.partner_id.write_date),
}
if also_livechat:
res["user_livechat_username"] = False
return res
if user == self.users[2]:
if only_inviting:
return {
"id": user.partner_id.id,
"im_status": "offline",
"name": "test2",
}
return {
"active": True,
"avatar_128_access_token": limited_field_access_token(
user.partner_id, "avatar_128"
),
"email": "test2@example.com",
"id": user.partner_id.id,
"im_status": "offline",
"is_company": False,
"isInternalUser": True,
"name": "test2",
"out_of_office_date_end": False,
"userId": user.id,
"write_date": fields.Datetime.to_string(user.partner_id.write_date),
}
if user == self.users[3]:
return {
"active": True,
"avatar_128_access_token": limited_field_access_token(
user.partner_id, "avatar_128"
),
"email": False,
"id": user.partner_id.id,
"im_status": "offline",
"is_company": False,
"isInternalUser": True,
"name": "test3",
"out_of_office_date_end": False,
"userId": user.id,
"write_date": fields.Datetime.to_string(self.users[3].partner_id.write_date),
}
if user == self.users[12]:
return {
"active": True,
"avatar_128_access_token": limited_field_access_token(
user.partner_id, "avatar_128"
),
"email": False,
"id": user.partner_id.id,
"im_status": "offline",
"is_company": False,
"isInternalUser": True,
"name": "test12",
"out_of_office_date_end": False,
"userId": user.id,
"write_date": fields.Datetime.to_string(user.partner_id.write_date),
}
if user == self.users[14]:
return {
"active": True,
"avatar_128_access_token": limited_field_access_token(
user.partner_id, "avatar_128"
),
"email": False,
"id": user.partner_id.id,
"im_status": "offline",
"is_company": False,
"isInternalUser": True,
"name": "test14",
"out_of_office_date_end": False,
"userId": user.id,
"write_date": fields.Datetime.to_string(user.partner_id.write_date),
}
if user == self.users[15]:
return {
"active": True,
"avatar_128_access_token": limited_field_access_token(
user.partner_id, "avatar_128"
),
"email": False,
"id": user.partner_id.id,
"im_status": "offline",
"is_company": False,
"isInternalUser": True,
"name": "test15",
"out_of_office_date_end": False,
"userId": user.id,
"write_date": fields.Datetime.to_string(user.partner_id.write_date),
}
if guest:
return {
"avatar_128_access_token": limited_field_access_token(self.guest, "avatar_128"),
"id": self.guest.id,
"im_status": "offline",
"name": "Visitor",
"write_date": fields.Datetime.to_string(self.guest.write_date),
}
return {}
def _expected_result_for_rtc_session(self, channel, user):
members = channel.channel_member_ids
member_2 = members.filtered(lambda m: m.partner_id == self.users[2].partner_id)
if channel == self.channel_channel_group_1 and user == self.users[2]:
return {
# sudo: discuss.channel.rtc.session - reading a session in a test file
"channelMember": member_2.id,
"id": member_2.sudo().rtc_session_ids.id,
"isCameraOn": False,
"isDeaf": False,
"isScreenSharingOn": False,
"isSelfMuted": False,
}
return {}
def _expected_result_for_thread(self, channel):
return {
"id": channel.id,
"model": "discuss.channel",
"module_icon": "/mail/static/description/icon.png",
"rating_avg": 0.0,
"rating_count": 0,
}