paulmataruso/zulip
1
0
Fork 0
mirror of https://github.com/zulip/zulip.git synced 2025-11-18 21:48:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

bulk_access_messages: Use a bulk UserMessage query.

Browse Source 
This removes one of the three queries that runs in a loop with this
bulk access function.
This commit is contained in:
Tim Abbott
2021-05-12 14:13:54 -07:00
committed by Tim Abbott
parent ee780e1f08
commit 4a8dcf14ef
2 changed files with 11 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
zerver/lib/message.py
View File

@@ -729,9 +729,15 @@ def has_message_access(
def bulk_access_messages(user_profile: UserProfile, messages: Sequence[Message]) -> List[Message]:
filtered_messages = []
user_message_set = set(
bulk_access_messages_expect_usermessage(
user_profile.id, [message.id for message in messages]
)
)
for message in messages:
user_message = get_usermessage_by_message_id(user_profile, message.id)
if has_message_access(user_profile, message, has_user_message=user_message is not None):
has_user_message = message.id in user_message_set
if has_message_access(user_profile, message, has_user_message=has_user_message):
filtered_messages.append(message)
return filtered_messages

6
zerver/tests/test_message_flags.py
View File

@@ -1307,7 +1307,7 @@ class MessageAccessTests(ZulipTestCase):
with queries_captured() as queries:
filtered_messages = bulk_access_messages(later_subscribed_user, messages)
self.assert_length(queries, 4)
self.assert_length(queries, 3)
# Message sent before subscribing wouldn't be accessible by later
# subscribed user as stream has protected history
@@ -1318,7 +1318,7 @@ class MessageAccessTests(ZulipTestCase):
with queries_captured() as queries:
filtered_messages = bulk_access_messages(later_subscribed_user, messages)
self.assert_length(queries, 5)
self.assert_length(queries, 4)
# Message sent before subscribing are accessible by 8user as stream
# don't have protected history
@@ -1329,7 +1329,7 @@ class MessageAccessTests(ZulipTestCase):
with queries_captured() as queries:
filtered_messages = bulk_access_messages(unsubscribed_user, messages)
self.assert_length(queries, 8)
self.assert_length(queries, 7)
self.assertEqual(len(filtered_messages), 0)