paulmataruso/zulip
1
0
Fork 0
mirror of https://github.com/zulip/zulip.git synced 2025-11-04 05:53:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

events: Update subscriber list on peer_remove for unsubscribed stream.

Browse Source 
We update the subscriber list on peer_remove event for unsubscribed
streams also.
This commit is contained in:
sahil839
2020-08-31 20:12:16 +05:30
committed by Tim Abbott
parent 709edd29d4
commit af9b153ee3
2 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
zerver/lib/events.py
View File

@@ -727,7 +727,7 @@ def apply_event(state: Dict[str, Any],
elif event['op'] == 'peer_remove':
stream_ids = set(event["stream_ids"])
user_ids = set(event["user_ids"])
for sub_dict in [state["subscriptions"]]:
for sub_dict in [state["subscriptions"], state['unsubscribed']]:
for sub in sub_dict:
if sub["stream_id"] in stream_ids:
subscribers = set(sub["subscribers"]) - user_ids

16
zerver/tests/test_events.py
View File

@@ -1844,7 +1844,8 @@ class SubscribeActionTest(BaseAction):
stream = get_stream("test_stream", self.user_profile.realm)
# Now remove the first user, to test the normal unsubscribe flow
# Now remove the first user, to test the normal unsubscribe flow and
# 'peer_remove' event for subscribed streams.
action = lambda: bulk_remove_subscriptions(
[self.example_user('othello')],
[stream],
@@ -1872,6 +1873,19 @@ class SubscribeActionTest(BaseAction):
'test_stream',
)
self.subscribe(self.example_user("iago"), "test_stream")
# Remove the user to test 'peer_remove' event flow for unsubscribed stream.
action = lambda: bulk_remove_subscriptions(
[self.example_user('iago')],
[stream],
get_client("website"))
events = self.verify_action(
action,
include_subscribers=include_subscribers,
state_change_expected=include_subscribers)
check_subscription_peer_remove('events[0]', events[0])
# Now resubscribe a user, to make sure that works on a vacated stream
action = lambda: self.subscribe(self.example_user("hamlet"), "test_stream")
events = self.verify_action(