hueso/gajim-plugins
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[omemo] Sanitize BLOBs in signed_prekeys table

Browse Source
This commit is contained in:
lovetox
2020-05-23 10:54:50 +02:00
parent 84a572b223
commit a98729fd9d
1 changed files with 24 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
omemo/backend/liteaxolotlstore.py
View File

@@ -147,7 +147,7 @@ class LiteAxolotlStore(AxolotlStore):
create_db_sql = """
BEGIN TRANSACTION;
%s
PRAGMA user_version=11;
PRAGMA user_version=12;
END TRANSACTION;
""" % (create_tables)
self._con.executescript(create_db_sql)
@@ -347,6 +347,29 @@ class LiteAxolotlStore(AxolotlStore):
self._con.execute('PRAGMA user_version=11')
self._con.commit()
if self.user_version() < 12:
# Sanitize invalid BLOBs from the python2 days
query_keys = '''SELECT _id,
prekey_id,
timestamp,
CAST(record as BLOB) as record
FROM signed_prekeys'''
rows = self._con.execute(query_keys).fetchall()
delete = 'DELETE FROM signed_prekeys'
self._con.execute(delete)
insert = '''INSERT INTO signed_prekeys (
_id, prekey_id, timestamp, record)
VALUES (?, ?, ?, ?)'''
for row in rows:
try:
self._con.execute(insert, row)
except Exception as error:
self._log.warning(error)
self._con.execute('PRAGMA user_version=12')
self._con.commit()
def loadSignedPreKey(self, signedPreKeyId):
query = 'SELECT record FROM signed_prekeys WHERE prekey_id = ?'
result = self._con.execute(query, (signedPreKeyId, )).fetchone()