summary refs log tree commit diff
path: root/synapse/storage/databases/main/pusher.py
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2021-04-22 17:29:20 +0100
committerAndrew Morgan <andrew@amorgan.xyz>2021-04-22 17:29:20 +0100
commit53f6ab1c340fbe9d36945ebb1f24d129a9e6d13a (patch)
treefd25016a959356deef0f83a8df77c4d47730da10 /synapse/storage/databases/main/pusher.py
parentMerge commit '9de6b9411' into anoa/dinsic_release_1_31_0 (diff)
parentProperly raise an exception when the body exceeds the max size. (#9145) (diff)
downloadsynapse-53f6ab1c340fbe9d36945ebb1f24d129a9e6d13a.tar.xz
Merge commit '2b467d0b6' into anoa/dinsic_release_1_31_0
Diffstat (limited to 'synapse/storage/databases/main/pusher.py')
-rw-r--r--synapse/storage/databases/main/pusher.py5
1 files changed, 2 insertions, 3 deletions
diff --git a/synapse/storage/databases/main/pusher.py b/synapse/storage/databases/main/pusher.py

index 77ba9d819e..bc7621b8d6 100644 --- a/synapse/storage/databases/main/pusher.py +++ b/synapse/storage/databases/main/pusher.py
@@ -17,14 +17,13 @@ import logging from typing import TYPE_CHECKING, Any, Dict, Iterable, Iterator, List, Optional, Tuple -from canonicaljson import encode_canonical_json - from synapse.push import PusherConfig, ThrottleParams from synapse.storage._base import SQLBaseStore, db_to_json from synapse.storage.database import DatabasePool from synapse.storage.types import Connection from synapse.storage.util.id_generators import StreamIdGenerator from synapse.types import JsonDict +from synapse.util import json_encoder from synapse.util.caches.descriptors import cached, cachedList if TYPE_CHECKING: @@ -315,7 +314,7 @@ class PusherStore(PusherWorkerStore): "device_display_name": device_display_name, "ts": pushkey_ts, "lang": lang, - "data": bytearray(encode_canonical_json(data)), + "data": json_encoder.encode(data), "last_stream_ordering": last_stream_ordering, "profile_tag": profile_tag, "id": stream_id,