mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2024-12-14 11:57:44 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

In get_recent_events_for_room, get the full event json rather than just the event_ids so we don't have to do so many db queries

Browse source
This commit is contained in:
Erik Johnston 2015-01-22 13:58:25 +00:00
parent 33d2d82f6d
commit 03c0da9f65
1 changed files with 14 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
synapse/storage/stream.py
View file

@ -269,8 +269,11 @@ class StreamStore(SQLBaseStore):
# TODO (erikj): Handle compressed feedback
sql = (
"SELECT stream_ordering, topological_ordering, event_id FROM events "
"WHERE room_id = ? AND stream_ordering <= ? AND outlier = 0 "
"SELECT stream_ordering, topological_ordering, "
"internal_metadata, json, r.event_id FROM events as e "
"LEFT JOIN event_json as ej ON e.event_id = ej.event_id "
"LEFT JOIN redactions as r ON e.event_id = r.redacts "
"WHERE e.room_id = ? AND stream_ordering <= ? AND outlier = 0 "
"ORDER BY topological_ordering DESC, stream_ordering DESC LIMIT ? "
)
@ -295,11 +298,15 @@ class StreamStore(SQLBaseStore):
else:
token = (end_token, end_token)
events = self._get_events_txn(
txn,
[r["event_id"] for r in rows],
get_prev_content=True
)
events = [
self._get_event_from_row_txn(
txn,
r["internal_metadata"],
r["json"],
r["event_id"],
)
for r in rows
]
return events, token