|
|
|
|
@ -5,29 +5,118 @@
|
|
|
|
|
#import "OWSReadReceiptManager.h"
|
|
|
|
|
#import "OWSMessageSender.h"
|
|
|
|
|
#import "OWSReadReceipt.h"
|
|
|
|
|
#import "OWSReadReceiptsMessage.h"
|
|
|
|
|
#import "OWSReadReceiptsForLinkedDevicesMessage.h"
|
|
|
|
|
#import "OWSReadReceiptsForSenderMessage.h"
|
|
|
|
|
#import "OWSSignalServiceProtos.pb.h"
|
|
|
|
|
#import "TSContactThread.h"
|
|
|
|
|
#import "TSDatabaseView.h"
|
|
|
|
|
#import "TSIncomingMessage.h"
|
|
|
|
|
#import "TSStorageManager.h"
|
|
|
|
|
#import "TextSecureKitEnv.h"
|
|
|
|
|
#import "Threading.h"
|
|
|
|
|
|
|
|
|
|
NS_ASSUME_NONNULL_BEGIN
|
|
|
|
|
|
|
|
|
|
@interface TSRecipientReadReceipt : TSYapDatabaseObject
|
|
|
|
|
|
|
|
|
|
@property (nonatomic, readonly) uint64_t timestamp;
|
|
|
|
|
@property (nonatomic, readonly) NSSet<NSString *> *recipientIds;
|
|
|
|
|
|
|
|
|
|
@end
|
|
|
|
|
|
|
|
|
|
#pragma mark -
|
|
|
|
|
|
|
|
|
|
@implementation TSRecipientReadReceipt
|
|
|
|
|
|
|
|
|
|
- (instancetype)initWithTimestamp:(uint64_t)timestamp
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(timestamp > 0);
|
|
|
|
|
|
|
|
|
|
self = [super initWithUniqueId:[TSRecipientReadReceipt uniqueIdForTimestamp:timestamp]];
|
|
|
|
|
|
|
|
|
|
if (self) {
|
|
|
|
|
_timestamp = timestamp;
|
|
|
|
|
_recipientIds = [NSSet set];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return self;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
+ (NSString *)uniqueIdForTimestamp:(uint64_t)timestamp
|
|
|
|
|
{
|
|
|
|
|
return [NSString stringWithFormat:@"%llu", timestamp];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
- (void)addRecipientId:(NSString *)recipientId
|
|
|
|
|
{
|
|
|
|
|
NSMutableSet<NSString *> *recipientIdsCopy = [self.recipientIds mutableCopy];
|
|
|
|
|
[recipientIdsCopy addObject:recipientId];
|
|
|
|
|
_recipientIds = [recipientIdsCopy copy];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
+ (void)addRecipientId:(NSString *)recipientId
|
|
|
|
|
timestamp:(uint64_t)timestamp
|
|
|
|
|
transaction:(YapDatabaseReadWriteTransaction *)transaction
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(transaction);
|
|
|
|
|
|
|
|
|
|
TSRecipientReadReceipt *_Nullable recipientReadReceipt =
|
|
|
|
|
[transaction objectForKey:[self uniqueIdForTimestamp:timestamp] inCollection:[self collection]];
|
|
|
|
|
if (!recipientReadReceipt) {
|
|
|
|
|
recipientReadReceipt = [[TSRecipientReadReceipt alloc] initWithTimestamp:timestamp];
|
|
|
|
|
}
|
|
|
|
|
[recipientReadReceipt addRecipientId:recipientId];
|
|
|
|
|
[recipientReadReceipt saveWithTransaction:transaction];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
+ (nullable NSSet<NSString *> *)recipientIdsForTimestamp:(uint64_t)timestamp
|
|
|
|
|
transaction:(YapDatabaseReadWriteTransaction *)transaction
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(transaction);
|
|
|
|
|
|
|
|
|
|
TSRecipientReadReceipt *_Nullable recipientReadReceipt =
|
|
|
|
|
[transaction objectForKey:[self uniqueIdForTimestamp:timestamp] inCollection:[self collection]];
|
|
|
|
|
return recipientReadReceipt.recipientIds;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
+ (void)removeRecipientIdsForTimestamp:(uint64_t)timestamp transaction:(YapDatabaseReadWriteTransaction *)transaction
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(transaction);
|
|
|
|
|
|
|
|
|
|
[transaction removeObjectForKey:[self uniqueIdForTimestamp:timestamp] inCollection:[self collection]];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@end
|
|
|
|
|
|
|
|
|
|
#pragma mark -
|
|
|
|
|
|
|
|
|
|
NSString *const OWSReadReceiptManagerCollection = @"OWSReadReceiptManagerCollection";
|
|
|
|
|
NSString *const OWSReadReceiptManagerAreReadReceiptsEnabled = @"areReadReceiptsEnabled";
|
|
|
|
|
|
|
|
|
|
@interface OWSReadReceiptManager ()
|
|
|
|
|
|
|
|
|
|
@property (nonatomic, readonly) TSStorageManager *storageManager;
|
|
|
|
|
@property (nonatomic, readonly) OWSMessageSender *messageSender;
|
|
|
|
|
|
|
|
|
|
@property (nonatomic, readonly) YapDatabaseConnection *dbConnection;
|
|
|
|
|
|
|
|
|
|
// A map of "thread unique id"-to-"read receipt" for read receipts that
|
|
|
|
|
// we will send to our linked devices.
|
|
|
|
|
//
|
|
|
|
|
// Should only be accessed while synchronized on the OWSReadReceiptManager.
|
|
|
|
|
@property (nonatomic, readonly) NSMutableDictionary<NSString *, OWSReadReceipt *> *toLinkedDevicesReadReceiptMap;
|
|
|
|
|
|
|
|
|
|
// A map of "recipient id"-to-"timestamp list" for read receipts that
|
|
|
|
|
// we will send to senders.
|
|
|
|
|
//
|
|
|
|
|
// Should only be accessed while synchronized on the OWSReadReceiptManager.
|
|
|
|
|
@property (nonatomic, readonly) NSMutableDictionary<NSString *, NSMutableSet<NSNumber *> *> *toSenderReadReceiptMap;
|
|
|
|
|
|
|
|
|
|
// Should only be accessed while synchronized on the OWSReadReceiptManager.
|
|
|
|
|
@property (nonatomic) BOOL isProcessing;
|
|
|
|
|
|
|
|
|
|
// Should only be accessed while synchronized on the OWSReadReceiptManager.
|
|
|
|
|
@property (nonatomic) NSNumber *areReadReceiptsEnabledCached;
|
|
|
|
|
|
|
|
|
|
@end
|
|
|
|
|
|
|
|
|
|
#pragma mark -
|
|
|
|
|
@ -47,11 +136,13 @@ NS_ASSUME_NONNULL_BEGIN
|
|
|
|
|
- (instancetype)initDefault
|
|
|
|
|
{
|
|
|
|
|
OWSMessageSender *messageSender = [TextSecureKitEnv sharedEnv].messageSender;
|
|
|
|
|
TSStorageManager *storageManager = [TSStorageManager sharedManager];
|
|
|
|
|
|
|
|
|
|
return [self initWithMessageSender:messageSender];
|
|
|
|
|
return [self initWithMessageSender:messageSender storageManager:storageManager];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
- (instancetype)initWithMessageSender:(OWSMessageSender *)messageSender
|
|
|
|
|
storageManager:(TSStorageManager *)storageManager
|
|
|
|
|
{
|
|
|
|
|
self = [super init];
|
|
|
|
|
|
|
|
|
|
@ -60,8 +151,10 @@ NS_ASSUME_NONNULL_BEGIN
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
_messageSender = messageSender;
|
|
|
|
|
_dbConnection = storageManager.newDatabaseConnection;
|
|
|
|
|
|
|
|
|
|
_toLinkedDevicesReadReceiptMap = [NSMutableDictionary new];
|
|
|
|
|
_toSenderReadReceiptMap = [NSMutableDictionary new];
|
|
|
|
|
|
|
|
|
|
OWSSingletonAssert();
|
|
|
|
|
|
|
|
|
|
@ -95,6 +188,8 @@ NS_ASSUME_NONNULL_BEGIN
|
|
|
|
|
@synchronized(self)
|
|
|
|
|
{
|
|
|
|
|
if ([TSDatabaseView hasPendingViewRegistrations]) {
|
|
|
|
|
DDLogInfo(
|
|
|
|
|
@"%@ Deferring read receipt processing due to pending database view registrations.", self.tag);
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
if (self.isProcessing) {
|
|
|
|
|
@ -122,51 +217,239 @@ NS_ASSUME_NONNULL_BEGIN
|
|
|
|
|
{
|
|
|
|
|
@synchronized(self)
|
|
|
|
|
{
|
|
|
|
|
DDLogVerbose(@"%@ Processing read receipts.", self.tag);
|
|
|
|
|
|
|
|
|
|
self.isProcessing = NO;
|
|
|
|
|
|
|
|
|
|
NSArray<OWSReadReceipt *> *readReceiptsToSend = [self.toLinkedDevicesReadReceiptMap allValues];
|
|
|
|
|
NSArray<OWSReadReceipt *> *readReceiptsForLinkedDevices = [self.toLinkedDevicesReadReceiptMap allValues];
|
|
|
|
|
[self.toLinkedDevicesReadReceiptMap removeAllObjects];
|
|
|
|
|
if (readReceiptsToSend.count > 0) {
|
|
|
|
|
OWSReadReceiptsMessage *message = [[OWSReadReceiptsMessage alloc] initWithReadReceipts:readReceiptsToSend];
|
|
|
|
|
if (readReceiptsForLinkedDevices.count > 0) {
|
|
|
|
|
OWSReadReceiptsForLinkedDevicesMessage *message =
|
|
|
|
|
[[OWSReadReceiptsForLinkedDevicesMessage alloc] initWithReadReceipts:readReceiptsForLinkedDevices];
|
|
|
|
|
|
|
|
|
|
dispatch_async(dispatch_get_main_queue(), ^{
|
|
|
|
|
[self.messageSender sendMessage:message
|
|
|
|
|
success:^{
|
|
|
|
|
DDLogInfo(@"%@ Successfully sent %zd read receipt to linked devices.",
|
|
|
|
|
self.tag,
|
|
|
|
|
readReceiptsToSend.count);
|
|
|
|
|
readReceiptsForLinkedDevices.count);
|
|
|
|
|
}
|
|
|
|
|
failure:^(NSError *error) {
|
|
|
|
|
DDLogError(@"%@ Failed to send read receipt to linked devices with error: %@", self.tag, error);
|
|
|
|
|
}];
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
NSArray<OWSReadReceipt *> *readReceiptsToSend = [self.toLinkedDevicesReadReceiptMap allValues];
|
|
|
|
|
[self.toLinkedDevicesReadReceiptMap removeAllObjects];
|
|
|
|
|
if (self.toSenderReadReceiptMap.count > 0) {
|
|
|
|
|
for (NSString *recipientId in self.toSenderReadReceiptMap) {
|
|
|
|
|
NSSet<NSNumber *> *timestamps = self.toSenderReadReceiptMap[recipientId];
|
|
|
|
|
OWSAssert(timestamps.count > 0);
|
|
|
|
|
|
|
|
|
|
TSThread *thread = [TSContactThread getOrCreateThreadWithContactId:recipientId];
|
|
|
|
|
OWSReadReceiptsForSenderMessage *message =
|
|
|
|
|
[[OWSReadReceiptsForSenderMessage alloc] initWithThread:thread
|
|
|
|
|
messageTimestamps:timestamps.allObjects];
|
|
|
|
|
|
|
|
|
|
dispatch_async(dispatch_get_main_queue(), ^{
|
|
|
|
|
[self.messageSender sendMessage:message
|
|
|
|
|
success:^{
|
|
|
|
|
DDLogInfo(@"%@ Successfully sent %zd read receipts to sender.",
|
|
|
|
|
self.tag,
|
|
|
|
|
readReceiptsToSend.count);
|
|
|
|
|
}
|
|
|
|
|
failure:^(NSError *error) {
|
|
|
|
|
DDLogError(@"%@ Failed to send read receipts to sender with error: %@", self.tag, error);
|
|
|
|
|
}];
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
[self.toSenderReadReceiptMap removeAllObjects];
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
- (void)messageWasReadLocally:(TSIncomingMessage *)message;
|
|
|
|
|
#pragma mark - Mark as Read Locally
|
|
|
|
|
|
|
|
|
|
- (void)markAsReadLocallyBeforeTimestamp:(uint64_t)timestamp thread:(TSThread *)thread
|
|
|
|
|
{
|
|
|
|
|
@synchronized(self)
|
|
|
|
|
{
|
|
|
|
|
NSString *threadUniqueId = message.uniqueThreadId;
|
|
|
|
|
OWSAssert(threadUniqueId.length > 0);
|
|
|
|
|
OWSAssert(thread);
|
|
|
|
|
|
|
|
|
|
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
|
|
|
|
|
[self.dbConnection readWriteWithBlock:^(YapDatabaseReadWriteTransaction *transaction) {
|
|
|
|
|
NSMutableArray<id<OWSReadTracking>> *interactions = [NSMutableArray new];
|
|
|
|
|
|
|
|
|
|
[[TSDatabaseView unseenDatabaseViewExtension:transaction]
|
|
|
|
|
enumerateRowsInGroup:thread.uniqueId
|
|
|
|
|
usingBlock:^(NSString *collection,
|
|
|
|
|
NSString *key,
|
|
|
|
|
id object,
|
|
|
|
|
id metadata,
|
|
|
|
|
NSUInteger index,
|
|
|
|
|
BOOL *stop) {
|
|
|
|
|
|
|
|
|
|
if (![object conformsToProtocol:@protocol(OWSReadTracking)]) {
|
|
|
|
|
OWSFail(
|
|
|
|
|
@"Expected to conform to OWSReadTracking: object with class: %@ collection: %@ "
|
|
|
|
|
@"key: %@",
|
|
|
|
|
[object class],
|
|
|
|
|
collection,
|
|
|
|
|
key);
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
id<OWSReadTracking> possiblyRead = (id<OWSReadTracking>)object;
|
|
|
|
|
|
|
|
|
|
if (possiblyRead.timestampForSorting > timestamp) {
|
|
|
|
|
*stop = YES;
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
OWSAssert(!possiblyRead.read);
|
|
|
|
|
if (!possiblyRead.read) {
|
|
|
|
|
[interactions addObject:possiblyRead];
|
|
|
|
|
}
|
|
|
|
|
}];
|
|
|
|
|
|
|
|
|
|
if (interactions.count < 1) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
DDLogError(@"Marking %zd messages as read.", interactions.count);
|
|
|
|
|
for (id<OWSReadTracking> possiblyRead in interactions) {
|
|
|
|
|
[possiblyRead markAsReadWithTransaction:transaction sendReadReceipt:YES updateExpiration:YES];
|
|
|
|
|
}
|
|
|
|
|
}];
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
NSString *messageAuthorId = message.messageAuthorId;
|
|
|
|
|
OWSAssert(messageAuthorId.length > 0);
|
|
|
|
|
- (void)messageWasReadLocally:(TSIncomingMessage *)message
|
|
|
|
|
{
|
|
|
|
|
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
|
|
|
|
|
@synchronized(self)
|
|
|
|
|
{
|
|
|
|
|
NSString *threadUniqueId = message.uniqueThreadId;
|
|
|
|
|
OWSAssert(threadUniqueId.length > 0);
|
|
|
|
|
|
|
|
|
|
NSString *messageAuthorId = message.messageAuthorId;
|
|
|
|
|
OWSAssert(messageAuthorId.length > 0);
|
|
|
|
|
|
|
|
|
|
OWSReadReceipt *newReadReceipt =
|
|
|
|
|
[[OWSReadReceipt alloc] initWithSenderId:messageAuthorId timestamp:message.timestamp];
|
|
|
|
|
|
|
|
|
|
OWSReadReceipt *_Nullable oldReadReceipt = self.toLinkedDevicesReadReceiptMap[threadUniqueId];
|
|
|
|
|
if (oldReadReceipt && oldReadReceipt.timestamp > newReadReceipt.timestamp) {
|
|
|
|
|
// If there's an existing read receipt for the same thread with
|
|
|
|
|
// a newer timestamp, discard the new read receipt.
|
|
|
|
|
DDLogVerbose(@"%@ Ignoring redundant read receipt for linked devices.", self.tag);
|
|
|
|
|
} else {
|
|
|
|
|
DDLogVerbose(@"%@ Enqueuing read receipt for linked devices.", self.tag);
|
|
|
|
|
self.toLinkedDevicesReadReceiptMap[threadUniqueId] = newReadReceipt;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
OWSReadReceipt *newReadReceipt =
|
|
|
|
|
[[OWSReadReceipt alloc] initWithSenderId:messageAuthorId timestamp:message.timestamp];
|
|
|
|
|
if ([self areReadReceiptsEnabled]) {
|
|
|
|
|
DDLogVerbose(@"%@ Enqueuing read receipt for sender.", self.tag);
|
|
|
|
|
NSMutableSet<NSNumber *> *_Nullable timestamps = self.toSenderReadReceiptMap[messageAuthorId];
|
|
|
|
|
if (!timestamps) {
|
|
|
|
|
timestamps = [NSMutableSet new];
|
|
|
|
|
self.toSenderReadReceiptMap[messageAuthorId] = timestamps;
|
|
|
|
|
}
|
|
|
|
|
[timestamps addObject:@(message.timestamp)];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
OWSReadReceipt *_Nullable oldReadReceipt = self.toLinkedDevicesReadReceiptMap[threadUniqueId];
|
|
|
|
|
if (oldReadReceipt && oldReadReceipt.timestamp > newReadReceipt.timestamp) {
|
|
|
|
|
// If there's an existing read receipt for the same thread with
|
|
|
|
|
// a newer timestamp, discard the new read receipt.
|
|
|
|
|
return;
|
|
|
|
|
[self scheduleProcessing];
|
|
|
|
|
}
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
self.toLinkedDevicesReadReceiptMap[threadUniqueId] = newReadReceipt;
|
|
|
|
|
#pragma mark - Read Receipts From Recipient
|
|
|
|
|
|
|
|
|
|
[self scheduleProcessing];
|
|
|
|
|
- (void)processReadReceiptsFromRecipient:(OWSSignalServiceProtosReceiptMessage *)receiptMessage
|
|
|
|
|
envelope:(OWSSignalServiceProtosEnvelope *)envelope
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(receiptMessage);
|
|
|
|
|
OWSAssert(envelope);
|
|
|
|
|
OWSAssert(receiptMessage.type == OWSSignalServiceProtosReceiptMessageTypeRead);
|
|
|
|
|
|
|
|
|
|
if (![self areReadReceiptsEnabled]) {
|
|
|
|
|
DDLogInfo(@"%@ Ignoring incoming receipt message as read receipts are disabled.", self.tag);
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
NSString *recipientId = envelope.source;
|
|
|
|
|
OWSAssert(recipientId.length > 0);
|
|
|
|
|
|
|
|
|
|
PBArray *timestamps = receiptMessage.timestamp;
|
|
|
|
|
|
|
|
|
|
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
|
|
|
|
|
[self.dbConnection readWriteWithBlock:^(YapDatabaseReadWriteTransaction *transaction) {
|
|
|
|
|
for (int i = 0; i < timestamps.count; i++) {
|
|
|
|
|
UInt64 timestamp = [timestamps uint64AtIndex:i];
|
|
|
|
|
|
|
|
|
|
NSArray<TSOutgoingMessage *> *messages
|
|
|
|
|
= (NSArray<TSOutgoingMessage *> *)[TSInteraction interactionsWithTimestamp:timestamp
|
|
|
|
|
ofClass:[TSOutgoingMessage class]
|
|
|
|
|
withTransaction:transaction];
|
|
|
|
|
OWSAssert(messages.count <= 1);
|
|
|
|
|
if (messages.count > 0) {
|
|
|
|
|
// TODO: We might also need to "mark as read by recipient" any older messages
|
|
|
|
|
// from us in that thread. Or maybe this state should hang on the thread?
|
|
|
|
|
for (TSOutgoingMessage *message in messages) {
|
|
|
|
|
[message updateWithReadRecipientId:recipientId transaction:transaction];
|
|
|
|
|
}
|
|
|
|
|
} else {
|
|
|
|
|
// Persist the read receipts so that we can apply them to outgoing messages
|
|
|
|
|
// that we learn about later through sync messages.
|
|
|
|
|
[TSRecipientReadReceipt addRecipientId:recipientId timestamp:timestamp transaction:transaction];
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}];
|
|
|
|
|
});
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
- (void)updateOutgoingMessageFromLinkedDevice:(TSOutgoingMessage *)message
|
|
|
|
|
transaction:(YapDatabaseReadWriteTransaction *)transaction
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(message);
|
|
|
|
|
OWSAssert(transaction);
|
|
|
|
|
|
|
|
|
|
NSSet<NSString *> *_Nullable recipientIds =
|
|
|
|
|
[TSRecipientReadReceipt recipientIdsForTimestamp:message.timestamp transaction:transaction];
|
|
|
|
|
if (!recipientIds) {
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
OWSAssert(recipientIds.count > 0);
|
|
|
|
|
for (NSString *recipientId in recipientIds) {
|
|
|
|
|
[message updateWithReadRecipientId:recipientId transaction:transaction];
|
|
|
|
|
}
|
|
|
|
|
[TSRecipientReadReceipt removeRecipientIdsForTimestamp:message.timestamp transaction:transaction];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#pragma mark - Settings
|
|
|
|
|
|
|
|
|
|
- (BOOL)areReadReceiptsEnabled
|
|
|
|
|
{
|
|
|
|
|
@synchronized(self)
|
|
|
|
|
{
|
|
|
|
|
if (!self.areReadReceiptsEnabledCached) {
|
|
|
|
|
// Default to NO.
|
|
|
|
|
self.areReadReceiptsEnabledCached =
|
|
|
|
|
@([self.dbConnection boolForKey:OWSReadReceiptManagerAreReadReceiptsEnabled
|
|
|
|
|
inCollection:OWSReadReceiptManagerCollection]);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return [self.areReadReceiptsEnabledCached boolValue];
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
- (void)setAreReadReceiptsEnabled:(BOOL)value
|
|
|
|
|
{
|
|
|
|
|
DDLogInfo(@"%@ areReadReceiptsEnabled: %d.", self.tag, value);
|
|
|
|
|
|
|
|
|
|
@synchronized(self)
|
|
|
|
|
{
|
|
|
|
|
[self.dbConnection setBool:value
|
|
|
|
|
forKey:OWSReadReceiptManagerAreReadReceiptsEnabled
|
|
|
|
|
inCollection:OWSReadReceiptManagerCollection];
|
|
|
|
|
self.areReadReceiptsEnabledCached = @(value);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
Matthew Chen
8 years ago