mirrors/signal-desktop
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages 2 Wiki Activity Actions

In calls migration, skip old calls without a callId sooner

Browse source
This commit is contained in:
Jamie Kyle 2023-08-09 09:33:43 -07:00 committed by GitHub
parent e20fa41fd5
commit da35ffada6
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
ts/sql/migrations/87-calls-history-table.ts
View file

@ -31,7 +31,7 @@ export default function updateToSchemaVersion87(
db.transaction(() => { db.transaction(() => {
const ourUuid = getOurUuid(db); const ourUuid = getOurUuid(db);
const [modifySchema] = sql` const [createTable] = sql`
DROP TABLE IF EXISTS callsHistory; DROP TABLE IF EXISTS callsHistory;
CREATE TABLE callsHistory ( CREATE TABLE callsHistory (
@ -58,21 +58,14 @@ export default function updateToSchemaVersion87(
timestamp DESC, timestamp DESC,
status status
); );
DROP INDEX IF EXISTS messages_call;
ALTER TABLE messages
DROP COLUMN callId;
ALTER TABLE messages
ADD COLUMN callId TEXT;
ALTER TABLE messages
DROP COLUMN callMode;
`; `;
db.exec(modifySchema); db.exec(createTable);
const [selectQuery] = sql` const [selectQuery] = sql`
SELECT * FROM messages WHERE type = 'call-history'; SELECT * FROM messages
WHERE type = 'call-history'
AND callId IS NOT NULL; -- Older messages don't have callId
`; `;
const rows = db.prepare(selectQuery).all(); const rows = db.prepare(selectQuery).all();
@ -202,6 +195,19 @@ export default function updateToSchemaVersion87(
db.prepare(updateQuery).run(updateParams); db.prepare(updateQuery).run(updateParams);
} }
const [updateMessagesTable] = sql`
DROP INDEX IF EXISTS messages_call;
ALTER TABLE messages
DROP COLUMN callId;
ALTER TABLE messages
ADD COLUMN callId TEXT;
ALTER TABLE messages
DROP COLUMN callMode;
`;
db.exec(updateMessagesTable);
db.pragma('user_version = 87'); db.pragma('user_version = 87');
})(); })();