paulmataruso/zulip
1
0
Fork 0
mirror of https://github.com/zulip/zulip.git synced 2025-11-14 10:57:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

Log message flag changes to our event queues

Browse Source 
(imported from commit 72fcea1a98c6a5be81f32963d51453f4bb12ace0)
This commit is contained in:
Leo Franchi
2013-08-05 17:56:09 -04:00
parent 33f4837570
commit f8b7b54626
1 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
zerver/lib/actions.py
View File

@@ -919,6 +919,15 @@ def update_message_flags(user_profile, operation, flag, messages, all):
elif operation == 'remove': elif operation == 'remove':
count = msgs.update(flags=F('flags').bitand(~flagattr)) count = msgs.update(flags=F('flags').bitand(~flagattr))
event = {'type': 'update_message_flags',
'operation': operation,
'flag': flag,
'messages': messages,
'all': all}
log_event(event)
notice = dict(event=event, users=[user_profile.id])
tornado_callbacks.send_notification(notice)
statsd.incr("flags.%s.%s" % (flag, operation), count) statsd.incr("flags.%s.%s" % (flag, operation), count)
def process_user_presence_event(event): def process_user_presence_event(event):
@@ -1151,6 +1160,10 @@ def do_events_register(user_profile, user_client, apply_markdown=True,
if event_types is None or "referral" in event_types: if event_types is None or "referral" in event_types:
ret['referrals'] = {'granted': user_profile.invites_granted, ret['referrals'] = {'granted': user_profile.invites_granted,
'used': user_profile.invites_used} 'used': user_profile.invites_used}
if event_types is None or "update_message_flags" in event_types:
# There's no initial data for message flag updates, client will
# get any updates during a session from get_events()
pass
# Apply events that came in while we were fetching initial data # Apply events that came in while we were fetching initial data
events = get_user_events(user_profile, queue_id, -1) events = get_user_events(user_profile, queue_id, -1)
@@ -1198,6 +1211,9 @@ def do_events_register(user_profile, user_client, apply_markdown=True,
pass pass
elif event['type'] == "referral": elif event['type'] == "referral":
ret['referrals'] = event['referrals'] ret['referrals'] = event['referrals']
elif event['type'] == "update_message_flags":
# The client will get the message with the updated flags directly
pass
else: else:
raise ValueError("Unexpected event type %s" % (event['type'],)) raise ValueError("Unexpected event type %s" % (event['type'],))