|
@@ -34,12 +34,13 @@ logger = logging.getLogger(__name__)
|
|
|
|
|
|
|
|
|
@defer.inlineCallbacks
|
|
|
-def send_event_to_master(clock, client, host, port, requester, event, context,
|
|
|
+def send_event_to_master(clock, store, client, host, port, requester, event, context,
|
|
|
ratelimit, extra_users):
|
|
|
"""Send event to be handled on the master
|
|
|
|
|
|
Args:
|
|
|
clock (synapse.util.Clock)
|
|
|
+ store (DataStore)
|
|
|
client (SimpleHttpClient)
|
|
|
host (str): host of master
|
|
|
port (int): port on master listening for HTTP replication
|
|
@@ -53,11 +54,13 @@ def send_event_to_master(clock, client, host, port, requester, event, context,
|
|
|
host, port, event.event_id,
|
|
|
)
|
|
|
|
|
|
+ serialized_context = yield context.serialize(event, store)
|
|
|
+
|
|
|
payload = {
|
|
|
"event": event.get_pdu_json(),
|
|
|
"internal_metadata": event.internal_metadata.get_dict(),
|
|
|
"rejected_reason": event.rejected_reason,
|
|
|
- "context": context.serialize(event),
|
|
|
+ "context": serialized_context,
|
|
|
"requester": requester.serialize(),
|
|
|
"ratelimit": ratelimit,
|
|
|
"extra_users": [u.to_string() for u in extra_users],
|