mirror of
https://github.com/zulip/zulip.git
synced 2025-11-11 09:27:43 +00:00
e111a2f9a5
This needs to be deployed to both staging and prod at the same off-peak time (and the schema migration run). At the time it is deployed, we need to make a few changes directly in the database: (1) UPDATE django_content_type set app_label='zerver' where app_label='zephyr'; (2) UPDATE south_migrationhistory set app_name='zerver' where app_name='zephyr'; (imported from commit eb3fd719571740189514ef0b884738cb30df1320)
29 lines
964 B
Python
29 lines
964 B
Python
from __future__ import absolute_import
|
|
|
|
import time
|
|
|
|
from collections import defaultdict
|
|
|
|
from django.core.management.base import BaseCommand
|
|
|
|
from zerver.lib.queue import SimpleQueueClient
|
|
from zerver.lib.actions import handle_missedmessage_emails
|
|
|
|
class Command(BaseCommand):
|
|
def handle(self, *args, **options):
|
|
q = SimpleQueueClient()
|
|
while True:
|
|
missed_events = q.drain_queue("missedmessage_emails", json=True)
|
|
by_recipient = defaultdict(list)
|
|
|
|
for event in missed_events:
|
|
print "Received missed message event: %s" % (event,)
|
|
by_recipient[event['user_profile_id']].append(event)
|
|
|
|
for user_profile_id, events in by_recipient.items():
|
|
handle_missedmessage_emails(user_profile_id, events)
|
|
|
|
# Aggregate all messages received every 2 minutes to let someone finish sending a batch
|
|
# of messages
|
|
time.sleep(2 * 60)
|