Merge pull request #5220 from matrix-org/erikj/dont_bundle_live_events

Don't bundle aggregations with events in /sync or /events or state queries
This commit is contained in:
Erik Johnston 2019-05-24 10:36:31 +01:00 committed by GitHub
commit d16f5574b6
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
5 changed files with 13 additions and 2 deletions

1
changelog.d/5220.feature Normal file
View file

@ -0,0 +1 @@
Add experimental support for relations (aka reactions and edits).

View file

@ -330,12 +330,13 @@ class EventClientSerializer(object):
) )
@defer.inlineCallbacks @defer.inlineCallbacks
def serialize_event(self, event, time_now, **kwargs): def serialize_event(self, event, time_now, bundle_aggregations=True, **kwargs):
"""Serializes a single event. """Serializes a single event.
Args: Args:
event (EventBase) event (EventBase)
time_now (int): The current time in milliseconds time_now (int): The current time in milliseconds
bundle_aggregations (bool): Whether to bundle in related events
**kwargs: Arguments to pass to `serialize_event` **kwargs: Arguments to pass to `serialize_event`
Returns: Returns:
@ -350,7 +351,7 @@ class EventClientSerializer(object):
# If MSC1849 is enabled then we need to look if thre are any relations # If MSC1849 is enabled then we need to look if thre are any relations
# we need to bundle in with the event # we need to bundle in with the event
if self.experimental_msc1849_support_enabled: if self.experimental_msc1849_support_enabled and bundle_aggregations:
annotations = yield self.store.get_aggregation_groups_for_event( annotations = yield self.store.get_aggregation_groups_for_event(
event_id, event_id,
) )

View file

@ -122,6 +122,9 @@ class EventStreamHandler(BaseHandler):
chunks = yield self._event_serializer.serialize_events( chunks = yield self._event_serializer.serialize_events(
events, time_now, as_client_event=as_client_event, events, time_now, as_client_event=as_client_event,
# We don't bundle "live" events, as otherwise clients
# will end up double counting annotations.
bundle_aggregations=False,
) )
chunk = { chunk = {

View file

@ -166,6 +166,9 @@ class MessageHandler(object):
now = self.clock.time_msec() now = self.clock.time_msec()
events = yield self._event_serializer.serialize_events( events = yield self._event_serializer.serialize_events(
room_state.values(), now, room_state.values(), now,
# We don't bother bundling aggregations in when asked for state
# events, as clients won't use them.
bundle_aggregations=False,
) )
defer.returnValue(events) defer.returnValue(events)

View file

@ -358,6 +358,9 @@ class SyncRestServlet(RestServlet):
def serialize(events): def serialize(events):
return self._event_serializer.serialize_events( return self._event_serializer.serialize_events(
events, time_now=time_now, events, time_now=time_now,
# We don't bundle "live" events, as otherwise clients
# will end up double counting annotations.
bundle_aggregations=False,
token_id=token_id, token_id=token_id,
event_format=event_formatter, event_format=event_formatter,
only_event_fields=only_fields, only_event_fields=only_fields,