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

Optimize markAllCallHistoryReadWithPredicate

Browse source
This commit is contained in:
Jamie Kyle 2024-06-26 13:45:07 -07:00 • committed by GitHub
parent 327db34406
commit f853a42756
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 14 additions and 20 deletions

34
ts/sql/Server.ts
View file

@ -3851,28 +3851,22 @@ async function markAllCallHistoryReadWithPredicate(
? sqlFragment`callsHistory.peerId IS ${target.peerId}` ? sqlFragment`callsHistory.peerId IS ${target.peerId}`
: sqlFragment`TRUE`; : sqlFragment`TRUE`;
const [selectQuery, selectParams] = sql` const [updateQuery, updateParams] = sql`
SELECT callsHistory.callId UPDATE messages
FROM callsHistory SET
WHERE ${predicate} seenStatus = ${SEEN_STATUS_SEEN},
AND callsHistory.timestamp <= ${timestamp} json = json_patch(json, ${jsonPatch})
WHERE id IN (
SELECT id FROM messages
INNER JOIN callsHistory ON callsHistory.callId IS messages.callId
WHERE messages.type IS 'call-history'
AND messages.seenStatus IS ${SEEN_STATUS_UNSEEN}
AND callsHistory.timestamp <= ${timestamp}
AND ${predicate}
)
`; `;
const callIds = db.prepare(selectQuery).pluck().all(selectParams); db.prepare(updateQuery).run(updateParams);
batchMultiVarQuery(db, callIds, ids => {
const idList = sqlJoin(ids.map(id => sqlFragment`${id}`));
const [updateQuery, updateParams] = sql`
UPDATE messages
SET
seenStatus = ${SEEN_STATUS_SEEN},
json = json_patch(json, ${jsonPatch})
WHERE callId IN (${idList});
`;
db.prepare(updateQuery).run(updateParams);
});
})(); })();
} }