diff --git a/SignalMessaging/utils/ThreadUtil.m b/SignalMessaging/utils/ThreadUtil.m index df8193e17..f2cad6cf6 100644 --- a/SignalMessaging/utils/ThreadUtil.m +++ b/SignalMessaging/utils/ThreadUtil.m @@ -85,11 +85,11 @@ typedef void (^BuildOutgoingMessageCompletionBlock)(TSOutgoingMessage *savedMess #pragma mark - Durable Message Enqueue -// Loki: TODO We may change this? + (TSOutgoingMessage *)enqueueAcceptFriendRequestMessageInThread:(TSThread *)thread { TSOutgoingMessage *message = [TSOutgoingMessage createEmptyOutgoingMessageInThread:thread]; - [self.dbConnection asyncReadWriteWithBlock:^(YapDatabaseReadWriteTransaction *_Nonnull transaction) { + [self.dbConnection asyncReadWriteWithBlock:^(YapDatabaseReadWriteTransaction *transaction) { + [message saveWithTransaction:transaction]; [self.messageSenderJobQueue addMessage:message transaction:transaction]; }]; return message; diff --git a/SignalServiceKit/src/Messages/OWSMessageSender.m b/SignalServiceKit/src/Messages/OWSMessageSender.m index c374a513e..73f7146bf 100644 --- a/SignalServiceKit/src/Messages/OWSMessageSender.m +++ b/SignalServiceKit/src/Messages/OWSMessageSender.m @@ -1065,7 +1065,7 @@ NSString *const OWSMessageSenderRateLimitedException = @"RateLimitedException"; NSArray *validMessageTypes = @[ @(TSEncryptedWhisperMessageType), @(TSPreKeyWhisperMessageType), @(TSFriendRequestMessageType) ]; hasValidMessageType = [validMessageTypes containsObject:messageType]; - /* Loki: Original code: + /* Loki: Original code hasValidMessageType = ([messageType isEqualToNumber:@(TSEncryptedWhisperMessageType)] || [messageType isEqualToNumber:@(TSPreKeyWhisperMessageType)]); */ @@ -1552,7 +1552,7 @@ NSString *const OWSMessageSenderRateLimitedException = @"RateLimitedException"; // Loki: Since we don't support multi-device sending yet, just send it to the primary device NSMutableArray *deviceIds = [NSMutableArray arrayWithObject:@(OWSDevicePrimaryDeviceId)]; - /* Loki: Original code: + /* Loki: Original code NSMutableArray *deviceIds = [recipient.devices mutableCopy]; */