Fix thread_image_id column type

mautrix_instagram/db/upgrade/v00_latest_revision.py

@@ -18,7 +18,7 @@ from mautrix.util.async_db import Connection, Scheme
 from . import upgrade_table
 
 
-@upgrade_table.register(description="Latest revision", upgrades_to=11)
+@upgrade_table.register(description="Latest revision", upgrades_to=13)
 async def upgrade_latest(conn: Connection, scheme: Scheme) -> None:
     await conn.execute(
         """CREATE TABLE portal (
@@ -36,6 +36,7 @@ async def upgrade_latest(conn: Connection, scheme: Scheme) -> None:
             next_batch_id                       TEXT,
             historical_base_insertion_event_id  TEXT,
             cursor                              TEXT,
+            thread_image_id                     BIGINT,
             PRIMARY KEY (thread_id, receiver)
         )"""
     )

mautrix_instagram/db/upgrade/v13_fix_portal_thread_image_id.py

@@ -0,0 +1,24 @@
+# mautrix-instagram - A Matrix-Instagram puppeting bridge.
+# Copyright (C) 2023 Tulir Asokan
+#
+# This program is free software: you can redistribute it and/or modify
+# it under the terms of the GNU Affero General Public License as published by
+# the Free Software Foundation, either version 3 of the License, or
+# (at your option) any later version.
+#
+# This program is distributed in the hope that it will be useful,
+# but WITHOUT ANY WARRANTY; without even the implied warranty of
+# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+# GNU Affero General Public License for more details.
+#
+# You should have received a copy of the GNU Affero General Public License
+# along with this program.  If not, see <https://www.gnu.org/licenses/>.
+from mautrix.util.async_db import Connection, Scheme
+
+from . import upgrade_table
+
+
+@upgrade_table.register(description="Fix column to portal to track group thread image ID")
+async def upgrade_v13(conn: Connection, scheme: Scheme) -> None:
+    if scheme in (Scheme.POSTGRES, Scheme.COCKROACH):
+        await conn.execute("ALTER TABLE portal ALTER COLUMN thread_image_id TYPE BIGINT")