Signal/Android
1
0
Fork 0
mirror of https://github.com/signalapp/Signal-Android.git synced 2025-12-23 20:48:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Log inserted messageIds.

Browse Source
This commit is contained in:
Greyson Parrelli
2025-06-10 16:51:57 -04:00
parent 2394972620
commit f80d5d54ca
2 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
app/src/main/java/org/thoughtcrime/securesms/messages/DataMessageProcessor.kt
View File

@@ -173,6 +173,9 @@ object DataMessageProcessor {
} }
messageId = messageId ?: insertResult?.messageId?.let { MessageId(it) } messageId = messageId ?: insertResult?.messageId?.let { MessageId(it) }
if (messageId != null) {
log(envelope.timestamp!!, "Inserted as messageId $messageId")
}
if (groupId != null) { if (groupId != null) {
val unknownGroup = when (groupProcessResult) { val unknownGroup = when (groupProcessResult) {

5
app/src/main/java/org/thoughtcrime/securesms/messages/SyncMessageProcessor.kt
View File

@@ -851,6 +851,7 @@ object SyncMessageProcessor {
val threadId = SignalDatabase.threads.getOrCreateThreadIdFor(recipient) val threadId = SignalDatabase.threads.getOrCreateThreadIdFor(recipient)
val messageId: Long = SignalDatabase.messages.insertMessageOutbox(mediaMessage, threadId, false, GroupReceiptTable.STATUS_UNKNOWN, null) val messageId: Long = SignalDatabase.messages.insertMessageOutbox(mediaMessage, threadId, false, GroupReceiptTable.STATUS_UNKNOWN, null)
log(envelopeTimestamp, "Inserted sync message as messageId $messageId")
if (recipient.isGroup) { if (recipient.isGroup) {
updateGroupReceiptStatus(sent, messageId, recipient.requireGroupId()) updateGroupReceiptStatus(sent, messageId, recipient.requireGroupId())
@@ -917,7 +918,11 @@ object SyncMessageProcessor {
messageId = SignalDatabase.messages.insertMessageOutbox(outgoingTextMessage, threadId, false, null) messageId = SignalDatabase.messages.insertMessageOutbox(outgoingTextMessage, threadId, false, null)
SignalDatabase.messages.markUnidentified(messageId, sent.isUnidentified(recipient.serviceId.orNull())) SignalDatabase.messages.markUnidentified(messageId, sent.isUnidentified(recipient.serviceId.orNull()))
} }
log(envelopeTimestamp, "Inserted sync message as messageId $messageId")
SignalDatabase.messages.markAsSent(messageId, true) SignalDatabase.messages.markAsSent(messageId, true)
if (expiresInMillis > 0) { if (expiresInMillis > 0) {
SignalDatabase.messages.markExpireStarted(messageId, sent.expirationStartTimestamp ?: 0) SignalDatabase.messages.markExpireStarted(messageId, sent.expirationStartTimestamp ?: 0)
AppDependencies.expiringMessageManager.scheduleDeletion(messageId, isGroup, sent.expirationStartTimestamp ?: 0, expiresInMillis) AppDependencies.expiringMessageManager.scheduleDeletion(messageId, isGroup, sent.expirationStartTimestamp ?: 0, expiresInMillis)