mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2024-11-29 15:39:00 +03:00
Code Issues Projects Releases Packages Wiki Activity

Fix bug where we didn't correctly pull out the event_id of the deletion

Browse source
This commit is contained in:
Erik Johnston 2014-09-24 13:29:20 +01:00
parent 4e79b09dd9
commit 1e6c5b205c
2 changed files with 8 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
synapse/storage/__init__.py
View file

@ -263,13 +263,17 @@ class DataStore(RoomMemberStore, RoomStore,
@defer.inlineCallbacks
def get_current_state(self, room_id, event_type=None, state_key=""):
del_sql = (
"SELECT event_id FROM deletions WHERE deletes = e.event_id"
)
sql = (
"SELECT e.*, (%(deleted)s) AS deleted FROM events as e "
"INNER JOIN current_state_events as c ON e.event_id = c.event_id "
"INNER JOIN state_events as s ON e.event_id = s.event_id "
"WHERE c.room_id = ? "
) % {
"deleted": "e.event_id IN (SELECT deletes FROM deletions)",
"deleted": del_sql,
}
if event_type:

5
synapse/storage/_base.py
View file

@ -403,9 +403,10 @@ class SQLBaseStore(object):
return events
def _has_been_deleted_txn(self, txn, event):
sql = "SELECT * FROM deletions WHERE deletes = ?"
sql = "SELECT event_id FROM deletions WHERE deletes = ?"
txn.execute(sql, (event.event_id,))
return len(txn.fetchall()) > 0
result = txn.fetchone()
return result[0] if result else None
class Table(object):