OpenCloud
/
MatrixSynapse
mirror of https://github.com/matrix-org/synapse
1
0
Fork 0
Code Issues Releases Wiki Activity

Use JSON instead of msgpack

erikj/paginate_sync
Erik Johnston 2016-06-27 13:18:04 +01:00
parent 92c58932d1
commit 4c67e06dfb
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
synapse/types.py
View File

@ -18,7 +18,7 @@ from synapse.api.errors import SynapseError
from collections import namedtuple from collections import namedtuple
from unpaddedbase64 import encode_base64, decode_base64 from unpaddedbase64 import encode_base64, decode_base64
import msgpack import ujson as serializer
Requester = namedtuple("Requester", ["user", "access_token_id", "is_guest"]) Requester = namedtuple("Requester", ["user", "access_token_id", "is_guest"])
@ -127,7 +127,7 @@ class SyncNextBatchToken(
@classmethod @classmethod
def from_string(cls, string): def from_string(cls, string):
try: try:
d = msgpack.loads(decode_base64(string)) d = serializer.loads(decode_base64(string))
pa = d.get("pa", None) pa = d.get("pa", None)
if pa: if pa:
pa = SyncPaginationState.from_dict(pa) pa = SyncPaginationState.from_dict(pa)
@ -139,7 +139,7 @@ class SyncNextBatchToken(
raise SynapseError(400, "Invalid Token") raise SynapseError(400, "Invalid Token")
def to_string(self): def to_string(self):
return encode_base64(msgpack.dumps({ return encode_base64(serializer.dumps({
"t": self.stream_token.to_arr(), "t": self.stream_token.to_arr(),
"pa": self.pagination_state.to_dict() if self.pagination_state else None, "pa": self.pagination_state.to_dict() if self.pagination_state else None,
})) }))