We store pusher data as bytes

erikj/initial_sync_perf
Erik Johnston 2015-04-29 17:43:46 +01:00
parent a6e62cf6d0
commit 472be88674
1 changed files with 2 additions and 2 deletions

View File

@ -53,7 +53,7 @@ class PusherStore(SQLBaseStore):
dataJson = r['data'] dataJson = r['data']
r['data'] = None r['data'] = None
try: try:
r['data'] = json.loads(dataJson) r['data'] = json.loads(str(dataJson).decode("UTF8"))
except: except:
logger.warn("Invalid JSON in data for pusher %d: %s", r['id'], dataJson) logger.warn("Invalid JSON in data for pusher %d: %s", r['id'], dataJson)
pass pass
@ -81,7 +81,7 @@ class PusherStore(SQLBaseStore):
device_display_name=device_display_name, device_display_name=device_display_name,
ts=pushkey_ts, ts=pushkey_ts,
lang=lang, lang=lang,
data=encode_canonical_json(data).decode("UTF-8"), data=encode_canonical_json(data),
), ),
insertion_values=dict( insertion_values=dict(
id=next_id, id=next_id,