From 3b5ef29047e18fc286a282ca345dd2d0c387f015 Mon Sep 17 00:00:00 2001 From: Nicholas Tinsley Date: Fri, 27 Oct 2023 18:32:35 -0400 Subject: [PATCH] Update IncomingMessage in benchmark. --- .../signal/benchmark/setup/TestMessages.kt | 27 +++++++++++-------- 1 file changed, 16 insertions(+), 11 deletions(-) diff --git a/app/src/benchmark/java/org/signal/benchmark/setup/TestMessages.kt b/app/src/benchmark/java/org/signal/benchmark/setup/TestMessages.kt index 1a46b261de..85eec172cd 100644 --- a/app/src/benchmark/java/org/signal/benchmark/setup/TestMessages.kt +++ b/app/src/benchmark/java/org/signal/benchmark/setup/TestMessages.kt @@ -2,9 +2,10 @@ package org.signal.benchmark.setup import org.thoughtcrime.securesms.attachments.PointerAttachment import org.thoughtcrime.securesms.database.AttachmentTable +import org.thoughtcrime.securesms.database.MessageType import org.thoughtcrime.securesms.database.SignalDatabase import org.thoughtcrime.securesms.database.TestDbUtils -import org.thoughtcrime.securesms.mms.IncomingMediaMessage +import org.thoughtcrime.securesms.mms.IncomingMessage import org.thoughtcrime.securesms.mms.OutgoingMessage import org.thoughtcrime.securesms.mms.QuoteModel import org.thoughtcrime.securesms.recipients.Recipient @@ -65,7 +66,8 @@ object TestMessages { return insert } fun insertIncomingTextMessage(other: Recipient, body: String, timestamp: Long? = null) { - val message = IncomingMediaMessage( + val message = IncomingMessage( + type = MessageType.NORMAL, from = other.id, body = body, sentTimeMillis = timestamp ?: System.currentTimeMillis(), @@ -73,10 +75,11 @@ object TestMessages { receivedTimeMillis = timestamp ?: System.currentTimeMillis() ) - SignalDatabase.messages.insertSecureDecryptedMessageInbox(message, SignalDatabase.threads.getOrCreateThreadIdFor(other)).get().messageId + SignalDatabase.messages.insertMessageInbox(message, SignalDatabase.threads.getOrCreateThreadIdFor(other)).get().messageId } fun insertIncomingQuoteTextMessage(other: Recipient, body: String, quote: QuoteModel, timestamp: Long?) { - val message = IncomingMediaMessage( + val message = IncomingMessage( + type = MessageType.NORMAL, from = other.id, body = body, sentTimeMillis = timestamp ?: System.currentTimeMillis(), @@ -90,28 +93,30 @@ object TestMessages { val attachments: List = (0 until attachmentCount).map { imageAttachment() } - val message = IncomingMediaMessage( + val message = IncomingMessage( + type = MessageType.NORMAL, from = other.id, sentTimeMillis = timestamp ?: System.currentTimeMillis(), serverTimeMillis = timestamp ?: System.currentTimeMillis(), receivedTimeMillis = timestamp ?: System.currentTimeMillis(), attachments = PointerAttachment.forPointers(Optional.of(attachments)) ) - return insertIncomingMediaMessage(recipient = other, message = message, failed = failed) + return insertIncomingMessage(recipient = other, message = message, failed = failed) } fun insertIncomingVoiceMessage(other: Recipient, timestamp: Long? = null): Long { - val message = IncomingMediaMessage( + val message = IncomingMessage( + type = MessageType.NORMAL, from = other.id, sentTimeMillis = timestamp ?: System.currentTimeMillis(), serverTimeMillis = timestamp ?: System.currentTimeMillis(), receivedTimeMillis = timestamp ?: System.currentTimeMillis(), attachments = PointerAttachment.forPointers(Optional.of(Collections.singletonList(voiceAttachment()) as List)) ) - return insertIncomingMediaMessage(recipient = other, message = message, failed = false) + return insertIncomingMessage(recipient = other, message = message, failed = false) } - private fun insertIncomingMediaMessage(recipient: Recipient, message: IncomingMediaMessage, failed: Boolean = false): Long { + private fun insertIncomingMessage(recipient: Recipient, message: IncomingMessage, failed: Boolean = false): Long { val id = insertIncomingMessage(recipient = recipient, message = message) if (failed) { setMessageMediaFailed(id) @@ -122,8 +127,8 @@ object TestMessages { return id } - private fun insertIncomingMessage(recipient: Recipient, message: IncomingMediaMessage): Long { - return SignalDatabase.messages.insertSecureDecryptedMessageInbox(message, SignalDatabase.threads.getOrCreateThreadIdFor(recipient)).get().messageId + private fun insertIncomingMessage(recipient: Recipient, message: IncomingMessage): Long { + return SignalDatabase.messages.insertMessageInbox(message, SignalDatabase.threads.getOrCreateThreadIdFor(recipient)).get().messageId } private fun setMessageMediaFailed(messageId: Long) {