Matrix-Mirrors/anonymousland-synapse
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse.git synced 2025-05-03 04:44:52 -04:00
Code Issues Projects Releases Packages Wiki Activity

Add store-and-forward direct-to-device messaging

Browse source
This commit is contained in:
Mark Haines 2016-08-25 17:35:37 +01:00
parent 3e86dcf1c0
commit e993925279
9 changed files with 288 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
synapse/streams/events.py
View file

@ -43,6 +43,7 @@ class EventSources(object):
@defer.inlineCallbacks
def get_current_token(self, direction='f'):
push_rules_key, _ = self.store.get_push_rules_stream_token()
to_device_key = self.store.get_to_device_stream_token()
token = StreamToken(
room_key=(
@ -61,5 +62,6 @@ class EventSources(object):
yield self.sources["account_data"].get_current_key()
),
push_rules_key=push_rules_key,
to_device_key=to_device_key,
)
defer.returnValue(token)