Clean more

pull/19/head
Niels Andriesse 6 years ago
parent dac9b28162
commit 08aac18384

@ -158,9 +158,9 @@ static NSTimeInterval launchStartedAt;
return AppEnvironment.shared.legacyNotificationActionHandler; return AppEnvironment.shared.legacyNotificationActionHandler;
} }
- (LKFriendRequestExpirationJob *)lokiFriendRequestExpireJob - (LKFriendRequestExpirationJob *)lokiFriendRequestExpirationJob
{ {
return SSKEnvironment.shared.lokiFriendRequestExpireJob; return SSKEnvironment.shared.lokiFriendRequestExpirationJob;
} }
#pragma mark - #pragma mark -
@ -689,7 +689,7 @@ static NSTimeInterval launchStartedAt;
[self.disappearingMessagesJob startIfNecessary]; [self.disappearingMessagesJob startIfNecessary];
// Start Loki friend request expire job // Start Loki friend request expire job
[self.lokiFriendRequestExpireJob startIfNecessary]; [self.lokiFriendRequestExpirationJob startIfNecessary];
[self enableBackgroundRefreshIfNecessary]; [self enableBackgroundRefreshIfNecessary];
@ -1327,7 +1327,7 @@ static NSTimeInterval launchStartedAt;
[self.profileManager ensureLocalProfileCached]; [self.profileManager ensureLocalProfileCached];
// Start Loki friend request expire job // Start Loki friend request expire job
[self.lokiFriendRequestExpireJob startIfNecessary]; [self.lokiFriendRequestExpirationJob startIfNecessary];
// For non-legacy users, read receipts are on by default. // For non-legacy users, read receipts are on by default.
[self.readReceiptManager setAreReadReceiptsEnabled:YES]; [self.readReceiptManager setAreReadReceiptsEnabled:YES];

@ -127,8 +127,8 @@ NS_ASSUME_NONNULL_BEGIN
attachmentDownloads:attachmentDownloads]]; attachmentDownloads:attachmentDownloads]];
// Loki // Loki
LKFriendRequestExpirationJob *lokiFriendRequestExpireJob = [[LKFriendRequestExpirationJob alloc] initWithPrimaryStorage:primaryStorage]; LKFriendRequestExpirationJob *lokiFriendRequestExpirationJob = [[LKFriendRequestExpirationJob alloc] initWithPrimaryStorage:primaryStorage];
SSKEnvironment.shared.lokiFriendRequestExpireJob = lokiFriendRequestExpireJob; SSKEnvironment.shared.lokiFriendRequestExpirationJob = lokiFriendRequestExpirationJob;
appSpecificSingletonBlock(); appSpecificSingletonBlock();

@ -90,7 +90,7 @@ NS_ASSUME_NONNULL_BEGIN
_incomingMessageFinder = [[OWSIncomingMessageFinder alloc] initWithPrimaryStorage:primaryStorage]; _incomingMessageFinder = [[OWSIncomingMessageFinder alloc] initWithPrimaryStorage:primaryStorage];
// Loki: Add observation for new session // Loki: Add observation for new session
[NSNotificationCenter.defaultCenter addObserver:self selector:@selector(onNewSessionAdopted:) name:kNSNotificationName_SessionAdopted object:nil]; [NSNotificationCenter.defaultCenter addObserver:self selector:@selector(handleNewSessionAdopted:) name:kNSNotificationName_SessionAdopted object:nil];
OWSSingletonAssert(); OWSSingletonAssert();
@ -1013,15 +1013,15 @@ NS_ASSUME_NONNULL_BEGIN
* ================ * ================
*/ */
/// Loki: Archive all our sessions // Loki: Archive all our session
/// Ref: SignalServiceKit/Loki/Docs/SessionReset.md // Ref: SignalServiceKit/Loki/Docs/SessionReset.md
[self.primaryStorage archiveAllSessionsForContact:envelope.source protocolContext:transaction]; [self.primaryStorage archiveAllSessionsForContact:envelope.source protocolContext:transaction];
/// Loki: Set our session reset state // Loki: Set our session reset state
thread.sessionResetState = TSContactThreadSessionResetStateRequestReceived; thread.sessionResetState = TSContactThreadSessionResetStateRequestReceived;
[thread saveWithTransaction:transaction]; [thread saveWithTransaction:transaction];
/// Loki: Send an empty message to trigger the session reset code for both parties // Loki: Send an empty message to trigger the session reset code for both parties
LKEphemeralMessage *emptyMessage = [LKEphemeralMessage createEmptyOutgoingMessageInThread:thread]; LKEphemeralMessage *emptyMessage = [LKEphemeralMessage createEmptyOutgoingMessageInThread:thread];
[self.messageSenderJobQueue addMessage:emptyMessage transaction:transaction]; [self.messageSenderJobQueue addMessage:emptyMessage transaction:transaction];
@ -1699,7 +1699,7 @@ NS_ASSUME_NONNULL_BEGIN
# pragma mark - Loki Session # pragma mark - Loki Session
- (void)onNewSessionAdopted:(NSNotification *)notification { - (void)handleNewSessionAdopted:(NSNotification *)notification {
NSString *pubKey = notification.userInfo[kNSNotificationKey_ContactPubKey]; NSString *pubKey = notification.userInfo[kNSNotificationKey_ContactPubKey];
if (pubKey.length == 0) { return; } if (pubKey.length == 0) { return; }

@ -26,9 +26,7 @@ NS_ASSUME_NONNULL_BEGIN
@class TSNetworkManager; @class TSNetworkManager;
@class TSSocketManager; @class TSSocketManager;
@class YapDatabaseConnection; @class YapDatabaseConnection;
@class LKFriendRequestExpirationJob; // Loki
// Loki
@class LKFriendRequestExpirationJob;
@protocol ContactsManagerProtocol; @protocol ContactsManagerProtocol;
@protocol NotificationsProtocol; @protocol NotificationsProtocol;
@ -113,10 +111,7 @@ NS_ASSUME_NONNULL_BEGIN
@property (atomic, readonly) YapDatabaseConnection *sessionStoreDBConnection; @property (atomic, readonly) YapDatabaseConnection *sessionStoreDBConnection;
@property (atomic, readonly) YapDatabaseConnection *migrationDBConnection; @property (atomic, readonly) YapDatabaseConnection *migrationDBConnection;
@property (atomic, readonly) YapDatabaseConnection *analyticsDBConnection; @property (atomic, readonly) YapDatabaseConnection *analyticsDBConnection;
@property (nonatomic) LKFriendRequestExpirationJob *lokiFriendRequestExpirationJob; // Loki
// Loki
@property (nonatomic, readonly) LKFriendRequestExpirationJob *lokiFriendRequestExpireJob;
- (void)setLokiFriendRequestExpireJob:(LKFriendRequestExpirationJob *)lokiFriendRequestExpireJob;
- (BOOL)isComplete; - (BOOL)isComplete;

@ -37,9 +37,6 @@ static SSKEnvironment *sharedSSKEnvironment;
@property (nonatomic) id<OWSTypingIndicators> typingIndicators; @property (nonatomic) id<OWSTypingIndicators> typingIndicators;
@property (nonatomic) OWSAttachmentDownloads *attachmentDownloads; @property (nonatomic) OWSAttachmentDownloads *attachmentDownloads;
// Loki
@property (nonatomic) LKFriendRequestExpirationJob *lokiFriendRequestExpireJob;
@end @end
#pragma mark - #pragma mark -
@ -199,12 +196,12 @@ static SSKEnvironment *sharedSSKEnvironment;
} }
} }
- (void)setLokiFriendRequestExpireJob:(LKFriendRequestExpirationJob *)lokiFriendRequestExpireJob { - (void)setLokiFriendRequestExpirationJob:(LKFriendRequestExpirationJob *)lokiFriendRequestExpirationJob {
@synchronized(self) { @synchronized(self) {
OWSAssertDebug(lokiFriendRequestExpireJob); OWSAssertDebug(lokiFriendRequestExpirationJob);
OWSAssertDebug(!_lokiFriendRequestExpireJob); OWSAssertDebug(_lokiFriendRequestExpirationJob == nil);
_lokiFriendRequestExpireJob = lokiFriendRequestExpireJob; _lokiFriendRequestExpirationJob = lokiFriendRequestExpirationJob;
} }
} }

@ -214,8 +214,7 @@ void VerifyRegistrationsForPrimaryStorage(OWSStorage *storage)
[OWSMediaGalleryFinder asyncRegisterDatabaseExtensionsWithPrimaryStorage:self]; [OWSMediaGalleryFinder asyncRegisterDatabaseExtensionsWithPrimaryStorage:self];
[TSDatabaseView asyncRegisterLazyRestoreAttachmentsDatabaseView:self]; [TSDatabaseView asyncRegisterLazyRestoreAttachmentsDatabaseView:self];
[SSKJobRecordFinder asyncRegisterDatabaseExtensionObjCWithStorage:self]; [SSKJobRecordFinder asyncRegisterDatabaseExtensionObjCWithStorage:self];
[LKFriendRequestExpirationMessageFinder asyncRegisterDatabaseExtensions:self]; // Loki
[LKFriendRequestExpirationMessageFinder asyncRegisterDatabaseExtensions:self];
[self.database [self.database
flushExtensionRequestsWithCompletionQueue:dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0) flushExtensionRequestsWithCompletionQueue:dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0)

Loading…
Cancel
Save