diff --git a/app/src/main/java/org/thoughtcrime/securesms/messages/DataMessageProcessor.kt b/app/src/main/java/org/thoughtcrime/securesms/messages/DataMessageProcessor.kt index dabb158781..397d5ab311 100644 --- a/app/src/main/java/org/thoughtcrime/securesms/messages/DataMessageProcessor.kt +++ b/app/src/main/java/org/thoughtcrime/securesms/messages/DataMessageProcessor.kt @@ -173,6 +173,9 @@ object DataMessageProcessor { } messageId = messageId ?: insertResult?.messageId?.let { MessageId(it) } + if (messageId != null) { + log(envelope.timestamp!!, "Inserted as messageId $messageId") + } if (groupId != null) { val unknownGroup = when (groupProcessResult) { diff --git a/app/src/main/java/org/thoughtcrime/securesms/messages/SyncMessageProcessor.kt b/app/src/main/java/org/thoughtcrime/securesms/messages/SyncMessageProcessor.kt index 5191459d33..ae253ca5a5 100644 --- a/app/src/main/java/org/thoughtcrime/securesms/messages/SyncMessageProcessor.kt +++ b/app/src/main/java/org/thoughtcrime/securesms/messages/SyncMessageProcessor.kt @@ -851,6 +851,7 @@ object SyncMessageProcessor { val threadId = SignalDatabase.threads.getOrCreateThreadIdFor(recipient) val messageId: Long = SignalDatabase.messages.insertMessageOutbox(mediaMessage, threadId, false, GroupReceiptTable.STATUS_UNKNOWN, null) + log(envelopeTimestamp, "Inserted sync message as messageId $messageId") if (recipient.isGroup) { updateGroupReceiptStatus(sent, messageId, recipient.requireGroupId()) @@ -917,7 +918,11 @@ object SyncMessageProcessor { messageId = SignalDatabase.messages.insertMessageOutbox(outgoingTextMessage, threadId, false, null) SignalDatabase.messages.markUnidentified(messageId, sent.isUnidentified(recipient.serviceId.orNull())) } + + log(envelopeTimestamp, "Inserted sync message as messageId $messageId") + SignalDatabase.messages.markAsSent(messageId, true) + if (expiresInMillis > 0) { SignalDatabase.messages.markExpireStarted(messageId, sent.expirationStartTimestamp ?: 0) AppDependencies.expiringMessageManager.scheduleDeletion(messageId, isGroup, sent.expirationStartTimestamp ?: 0, expiresInMillis)