Merge pull request #954 from matrix-org/markjh/even_more_fixes

Fix a couple of bugs in the transaction and keyring code
matrix-org · Jul 27, 2016 · 09d3181 · 09d3181
2 parents c63b169 + 87ffd21
commit 09d3181
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 9 deletions.
diff --git a/synapse/crypto/keyring.py b/synapse/crypto/keyring.py
@@ -275,14 +275,15 @@ def do_iterations():
                     for server_name, groups in missing_groups.items()
                 }
 
-            for group in missing_groups.values():
-                group_id_to_deferred[group.group_id].errback(SynapseError(
-                    401,
-                    "No key for %s with id %s" % (
-                        group.server_name, group.key_ids,
-                    ),
-                    Codes.UNAUTHORIZED,
-                ))
+            for groups in missing_groups.values():
+                for group in groups:
+                    group_id_to_deferred[group.group_id].errback(SynapseError(
+                        401,
+                        "No key for %s with id %s" % (
+                            group.server_name, group.key_ids,
+                        ),
+                        Codes.UNAUTHORIZED,
+                    ))
 
         def on_err(err):
             for deferred in group_id_to_deferred.values():

diff --git a/synapse/storage/transactions.py b/synapse/storage/transactions.py
@@ -24,6 +24,7 @@
 
 import itertools
 import logging
+import ujson as json
 
 logger = logging.getLogger(__name__)
 
@@ -101,7 +102,7 @@ def _get_received_txn_response(self, txn, transaction_id, origin):
         )
 
         if result and result["response_code"]:
-            return result["response_code"], result["response_json"]
+            return result["response_code"], json.loads(str(result["response_json"]))
         else:
             return None