mirror of https://github.com/oxen-io/session-ios
You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
69 lines
2.3 KiB
Swift
69 lines
2.3 KiB
Swift
7 years ago
|
//
|
||
|
// Copyright (c) 2018 Open Whisper Systems. All rights reserved.
|
||
|
//
|
||
|
|
||
|
import Foundation
|
||
|
import PromiseKit
|
||
|
|
||
|
@objc(SSKRotateSignedPreKeyOperation)
|
||
|
public class RotateSignedPreKeyOperation: OWSOperation {
|
||
|
private var tsAccountManager: TSAccountManager {
|
||
|
return TSAccountManager.sharedInstance()
|
||
|
}
|
||
|
|
||
|
private var accountManager: AccountManager {
|
||
|
return AccountManager.shared
|
||
|
}
|
||
|
|
||
|
private var primaryStorage: OWSPrimaryStorage {
|
||
|
return OWSPrimaryStorage.shared()
|
||
|
}
|
||
|
|
||
|
public override func run() {
|
||
|
Logger.debug("")
|
||
|
|
||
|
guard tsAccountManager.isRegistered() else {
|
||
|
Logger.debug("skipping - not registered")
|
||
|
return
|
||
|
}
|
||
|
|
||
|
let signedPreKeyRecord: SignedPreKeyRecord = self.primaryStorage.generateRandomSignedRecord()
|
||
|
|
||
|
firstly {
|
||
|
self.primaryStorage.storeSignedPreKey(signedPreKeyRecord.id, signedPreKeyRecord: signedPreKeyRecord)
|
||
|
return self.accountManager.setSignedPreKey(signedPreKeyRecord)
|
||
|
}.then(on: DispatchQueue.global()) { () -> Void in
|
||
|
Logger.info("Successfully uploaded signed PreKey")
|
||
|
signedPreKeyRecord.markAsAcceptedByService()
|
||
|
self.primaryStorage.setCurrentSignedPrekeyId(signedPreKeyRecord.id)
|
||
|
|
||
|
TSPreKeyManager.clearPreKeyUpdateFailureCount()
|
||
|
TSPreKeyManager.clearSignedPreKeyRecords()
|
||
|
}.then { () -> Void in
|
||
|
Logger.debug("done")
|
||
|
self.reportSuccess()
|
||
|
}.catch { error in
|
||
|
self.reportError(error)
|
||
|
}.retainUntilComplete()
|
||
|
}
|
||
|
|
||
|
override public func didFail(error: Error) {
|
||
|
switch error {
|
||
|
case let networkManagerError as NetworkManagerError:
|
||
|
guard !networkManagerError.isNetworkError else {
|
||
|
Logger.debug("don't report SPK rotation failure w/ network error")
|
||
|
return
|
||
|
}
|
||
|
|
||
|
guard networkManagerError.statusCode >= 400 && networkManagerError.statusCode <= 599 else {
|
||
|
Logger.debug("don't report SPK rotation failure w/ non application error")
|
||
|
return
|
||
|
}
|
||
|
|
||
|
TSPreKeyManager.incrementPreKeyUpdateFailureCount()
|
||
|
default:
|
||
|
Logger.debug("don't report SPK rotation failure w/ non NetworkManager error: \(error)")
|
||
|
}
|
||
|
}
|
||
|
}
|