empathicqubit/Signal-Android
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

Batch update DB upon group receipt.

Browse source
This commit is contained in:
Nicholas 2023-11-02 15:47:31 -04:00 • committed by Greyson Parrelli
parent 99d0ee6725
commit 157777cac1
1 changed files with 29 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
app/src/main/java/org/thoughtcrime/securesms/database/GroupReceiptTable.kt
View file

@ -76,22 +76,46 @@ class GroupReceiptTable(context: Context?, databaseHelper: SignalDatabase?) : Da
}
fun setUnidentified(results: Collection<Pair<RecipientId, Boolean>>, mmsId: Long) {
val mmsMatchPrefix = "$MMS_ID = $mmsId AND"
val unidentifiedQueries = SqlUtil.buildCollectionQuery(
column = RECIPIENT_ID,
values = results.filter { it.second() }.map { it.first().serialize() },
prefix = mmsMatchPrefix
)
val identifiedQueries = SqlUtil.buildCollectionQuery(
column = RECIPIENT_ID,
values = results.filterNot { it.second() }.map { it.first().serialize() },
prefix = mmsMatchPrefix
)
writableDatabase.withinTransaction { db ->
for (result in results) {
unidentifiedQueries.forEach {
db.update(TABLE_NAME)
.values(UNIDENTIFIED to if (result.second()) 1 else 0)
.where("$MMS_ID = ? AND $RECIPIENT_ID = ?", mmsId.toString(), result.first().serialize())
.values(UNIDENTIFIED to 1)
.where(it.where, it.whereArgs)
.run()
}
identifiedQueries.forEach {
db.update(TABLE_NAME)
.values(UNIDENTIFIED to 0)
.where(it.where, it.whereArgs)
.run()
}
}
}
fun setSkipped(recipients: Collection<RecipientId>, mmsId: Long) {
val mmsMatchPrefix = "$MMS_ID = $mmsId AND"
val queries = SqlUtil.buildCollectionQuery(
column = RECIPIENT_ID,
values = recipients.map { it.serialize() },
prefix = mmsMatchPrefix
)
writableDatabase.withinTransaction { db ->
for (recipient in recipients) {
queries.forEach {
db.update(TABLE_NAME)
.values(STATUS to STATUS_SKIPPED)
.where("$MMS_ID = ? AND $RECIPIENT_ID = ?", mmsId.toString(), recipient.serialize())
.where(it.where, it.whereArgs)
.run()
}
}