summary refs log tree commit diff
path: root/synapse/events/snapshot.py
diff options
context:
space:
mode:
authorErik Johnston <erikj@jki.re>2018-07-23 17:52:45 +0100
committerGitHub <noreply@github.com>2018-07-23 17:52:45 +0100
commitf559119de0009cfa1d396358eb8c788ccc9da53b (patch)
tree0ee4c637318472f350e0f951ecac96ff1646b108 /synapse/events/snapshot.py
parentMerge pull request #3582 from matrix-org/erikj/fixup_stateless (diff)
parentComments (diff)
downloadsynapse-f559119de0009cfa1d396358eb8c788ccc9da53b.tar.xz
Merge pull request #3584 from matrix-org/erikj/use_cached
Only get cached state from context in persist_event
Diffstat (limited to 'synapse/events/snapshot.py')
-rw-r--r--synapse/events/snapshot.py14
1 files changed, 14 insertions, 0 deletions
diff --git a/synapse/events/snapshot.py b/synapse/events/snapshot.py
index a59064b416..189212b0fa 100644
--- a/synapse/events/snapshot.py
+++ b/synapse/events/snapshot.py
@@ -163,6 +163,9 @@ class EventContext(object):
         context._prev_state_id = input["prev_state_id"]
         context._event_type = input["event_type"]
         context._event_state_key = input["event_state_key"]
+
+        context._current_state_ids = None
+        context._prev_state_ids = None
         context._fetching_state_deferred = None
 
         context.state_group = input["state_group"]
@@ -214,6 +217,17 @@ class EventContext(object):
 
         defer.returnValue(self._prev_state_ids)
 
+    def get_cached_current_state_ids(self):
+        """Gets the current state IDs if we have them already cached.
+
+        Returns:
+            dict[(str, str), str]|None: Returns None if we haven't cached the
+            state or if state_group is None, which happens when the associated
+            event is an outlier.
+        """
+
+        return self._current_state_ids
+
     @defer.inlineCallbacks
     def _fill_out_state(self, store):
         """Called to populate the _current_state_ids and _prev_state_ids