|
|
|
@ -1,5 +1,5 @@
|
|
|
|
|
//
|
|
|
|
|
// Copyright (c) 2017 Open Whisper Systems. All rights reserved.
|
|
|
|
|
// Copyright (c) 2018 Open Whisper Systems. All rights reserved.
|
|
|
|
|
//
|
|
|
|
|
|
|
|
|
|
#import "OWSRecipientIdentity.h"
|
|
|
|
@ -103,6 +103,37 @@ OWSSignalServiceProtosVerifiedState OWSVerificationStateToProtoState(OWSVerifica
|
|
|
|
|
}];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
- (void)saveWithTransaction:(YapDatabaseReadWriteTransaction *)transaction
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(transaction.connection == [OWSRecipientIdentity dbReadWriteConnection]);
|
|
|
|
|
|
|
|
|
|
[super saveWithTransaction:transaction];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
- (void)removeWithTransaction:(YapDatabaseReadWriteTransaction *)transaction
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(transaction.connection == [OWSRecipientIdentity dbReadWriteConnection]);
|
|
|
|
|
|
|
|
|
|
[super removeWithTransaction:transaction];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
- (void)touchWithTransaction:(YapDatabaseReadWriteTransaction *)transaction
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(transaction.connection == [OWSRecipientIdentity dbReadWriteConnection]);
|
|
|
|
|
|
|
|
|
|
[super touchWithTransaction:transaction];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
+ (nullable instancetype)fetchObjectWithUniqueID:(NSString *)uniqueID
|
|
|
|
|
transaction:(YapDatabaseReadTransaction *)transaction
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(transaction.connection == [OWSRecipientIdentity dbReadConnection]);
|
|
|
|
|
|
|
|
|
|
return [super fetchObjectWithUniqueID:uniqueID transaction:transaction];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#pragma mark - Database Connections
|
|
|
|
|
|
|
|
|
|
+ (YapDatabaseConnection *)dbReadConnection
|
|
|
|
|
{
|
|
|
|
|
return self.dbReadWriteConnection;
|
|
|
|
@ -128,33 +159,14 @@ OWSSignalServiceProtosVerifiedState OWSVerificationStateToProtoState(OWSVerifica
|
|
|
|
|
return sharedDBConnection;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
- (void)saveWithTransaction:(YapDatabaseReadWriteTransaction *)transaction
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(transaction.connection == [OWSRecipientIdentity dbReadWriteConnection]);
|
|
|
|
|
|
|
|
|
|
[super saveWithTransaction:transaction];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
- (void)removeWithTransaction:(YapDatabaseReadWriteTransaction *)transaction
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(transaction.connection == [OWSRecipientIdentity dbReadWriteConnection]);
|
|
|
|
|
|
|
|
|
|
[super removeWithTransaction:transaction];
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
- (void)touchWithTransaction:(YapDatabaseReadWriteTransaction *)transaction
|
|
|
|
|
- (YapDatabaseConnection *)dbReadConnection
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(transaction.connection == [OWSRecipientIdentity dbReadWriteConnection]);
|
|
|
|
|
|
|
|
|
|
[super touchWithTransaction:transaction];
|
|
|
|
|
return OWSRecipientIdentity.dbReadConnection;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
+ (nullable instancetype)fetchObjectWithUniqueID:(NSString *)uniqueID
|
|
|
|
|
transaction:(YapDatabaseReadTransaction *)transaction
|
|
|
|
|
- (YapDatabaseConnection *)dbReadWriteConnection
|
|
|
|
|
{
|
|
|
|
|
OWSAssert(transaction.connection == [OWSRecipientIdentity dbReadConnection]);
|
|
|
|
|
|
|
|
|
|
return [super fetchObjectWithUniqueID:uniqueID transaction:transaction];
|
|
|
|
|
return OWSRecipientIdentity.dbReadWriteConnection;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#pragma mark - debug
|
|
|
|
|