From 84a572b2237ac977ec9d1e8abd21bef91e4068e7 Mon Sep 17 00:00:00 2001
From: lovetox <philipp@hoerist.com>
Date: Sat, 23 May 2020 10:52:20 +0200
Subject: [PATCH] [omemo] Sanitize BLOBs in prekeys table

---
 omemo/backend/liteaxolotlstore.py | 25 ++++++++++++++++++++++++-
 1 file changed, 24 insertions(+), 1 deletion(-)

diff --git a/omemo/backend/liteaxolotlstore.py b/omemo/backend/liteaxolotlstore.py
index 99c4359..52bfde9 100644
--- a/omemo/backend/liteaxolotlstore.py
+++ b/omemo/backend/liteaxolotlstore.py
@@ -147,7 +147,7 @@ class LiteAxolotlStore(AxolotlStore):
             create_db_sql = """
                 BEGIN TRANSACTION;
                 %s
-                PRAGMA user_version=10;
+                PRAGMA user_version=11;
                 END TRANSACTION;
                 """ % (create_tables)
             self._con.executescript(create_db_sql)
@@ -324,6 +324,29 @@ class LiteAxolotlStore(AxolotlStore):
             self._con.execute('PRAGMA user_version=10')
             self._con.commit()
 
+        if self.user_version() < 11:
+            # Sanitize invalid BLOBs from the python2 days
+            query_keys = '''SELECT _id,
+                            prekey_id,
+                            sent_to_server,
+                            CAST(record as BLOB) as record
+                            FROM prekeys'''
+            rows = self._con.execute(query_keys).fetchall()
+
+            delete = 'DELETE FROM prekeys'
+            self._con.execute(delete)
+
+            insert = '''INSERT INTO prekeys (
+                        _id, prekey_id, sent_to_server, 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=11')
+            self._con.commit()
+
     def loadSignedPreKey(self, signedPreKeyId):
         query = 'SELECT record FROM signed_prekeys WHERE prekey_id = ?'
         result = self._con.execute(query, (signedPreKeyId, )).fetchone()