summary refs log tree commit diff
path: root/synapse/storage
diff options
context:
space:
mode:
authorMark Haines <mark.haines@matrix.org>2016-03-02 17:26:20 +0000
committerMark Haines <mark.haines@matrix.org>2016-03-02 17:26:20 +0000
commit2223204ebaf7624f4d640f2c56d3a4eb7ff6d98e (patch)
tree764f70995e5d2cd7968560cd7e8bce19c038d0dd /synapse/storage
parentAdd a stream for push rule updates (diff)
downloadsynapse-2223204ebaf7624f4d640f2c56d3a4eb7ff6d98e.tar.xz
Hook push rules up to the replication API
Diffstat (limited to 'synapse/storage')
-rw-r--r--synapse/storage/push_rule.py6
1 files changed, 6 insertions, 0 deletions
diff --git a/synapse/storage/push_rule.py b/synapse/storage/push_rule.py
index f3ebd49492..e034024108 100644
--- a/synapse/storage/push_rule.py
+++ b/synapse/storage/push_rule.py
@@ -412,6 +412,12 @@ class PushRuleStore(SQLBaseStore):
             "get_all_push_rule_updates", get_all_push_rule_updates_txn
         )
 
+    def get_push_rules_stream_token(self):
+        """Get the position of the push rules stream.
+        Returns a pair of a stream id for the push_rules stream and the
+        room stream ordering it corresponds to."""
+        return self._push_rules_stream_id_gen.get_max_token()
+
 
 class RuleNotFoundException(Exception):
     pass