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

Merge pull request #6484 from matrix-org/erikj/port_sync_handler

Browse source 
Port SyncHandler to async/await
This commit is contained in:
Erik Johnston 2019-12-09 11:32:44 +00:00 • committed by GitHub
commit a9b393340f
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
12 changed files with 208 additions and 202 deletions
Download patch file Download diff file Expand all files Collapse all files

2
synapse/storage/data_stores/main/account_data.py
View file

@ -250,7 +250,7 @@ class AccountDataWorkerStore(SQLBaseStore):
user_id, int(stream_id)
)
if not changed:
return {}, {}
return defer.succeed(({}, {}))
return self.db.runInteraction(
"get_updated_account_data_for_user", get_updated_account_data_for_user_txn

4
synapse/storage/data_stores/main/group_server.py
View file

@ -1111,7 +1111,7 @@ class GroupServerStore(SQLBaseStore):
user_id, from_token
)
if not has_changed:
return []
return defer.succeed([])
def _get_groups_changes_for_user_txn(txn):
sql = """
@ -1141,7 +1141,7 @@ class GroupServerStore(SQLBaseStore):
from_token
)
if not has_changed:
return []
return defer.succeed([])
def _get_all_groups_changes_txn(txn):
sql = """