mirror of
https://github.com/oxen-io/session-ios.git
synced 2023-12-13 21:30:14 +01:00
9db33a9651
// FREEBIE
103 lines
4.5 KiB
Swift
103 lines
4.5 KiB
Swift
//
|
|
// Copyright (c) 2017 Open Whisper Systems. All rights reserved.
|
|
//
|
|
|
|
import Foundation
|
|
import PromiseKit
|
|
|
|
/**
|
|
* Signal is actually two services - textSecure for messages and red phone (for calls).
|
|
* AccountManager delegates to both.
|
|
*/
|
|
class AccountManager: NSObject {
|
|
let TAG = "[AccountManager]"
|
|
let textSecureAccountManager: TSAccountManager
|
|
let networkManager: TSNetworkManager
|
|
|
|
required init(textSecureAccountManager: TSAccountManager) {
|
|
self.networkManager = textSecureAccountManager.networkManager
|
|
self.textSecureAccountManager = textSecureAccountManager
|
|
}
|
|
|
|
// MARK: registration
|
|
|
|
@objc func register(verificationCode: String) -> AnyPromise {
|
|
return AnyPromise(register(verificationCode: verificationCode))
|
|
}
|
|
|
|
func register(verificationCode: String) -> Promise<Void> {
|
|
return firstly {
|
|
Promise { fulfill, reject in
|
|
if verificationCode.characters.count == 0 {
|
|
let error = OWSErrorWithCodeDescription(.userError,
|
|
NSLocalizedString("REGISTRATION_ERROR_BLANK_VERIFICATION_CODE",
|
|
comment: "alert body during registration"))
|
|
reject(error)
|
|
}
|
|
fulfill()
|
|
}
|
|
}.then {
|
|
Logger.debug("\(self.TAG) verification code looks well formed.")
|
|
return self.registerForTextSecure(verificationCode: verificationCode)
|
|
}.then {
|
|
Logger.debug("\(self.TAG) successfully registered for TextSecure")
|
|
}
|
|
}
|
|
|
|
private func registerForTextSecure(verificationCode: String) -> Promise<Void> {
|
|
return Promise { fulfill, reject in
|
|
self.textSecureAccountManager.verifyAccount(withCode:verificationCode,
|
|
success:fulfill,
|
|
failure:reject)
|
|
}
|
|
}
|
|
|
|
// MARK: Push Tokens
|
|
|
|
func updatePushTokens(pushToken: String, voipToken: String) -> Promise<Void> {
|
|
return firstly {
|
|
return self.updateTextSecurePushTokens(pushToken: pushToken, voipToken: voipToken)
|
|
}.then {
|
|
Logger.info("\(self.TAG) Successfully updated text secure push tokens.")
|
|
// TODO code cleanup - convert to `return Promise(value: nil)` and test
|
|
return Promise { fulfill, _ in
|
|
fulfill()
|
|
}
|
|
}
|
|
}
|
|
|
|
private func updateTextSecurePushTokens(pushToken: String, voipToken: String) -> Promise<Void> {
|
|
return Promise { fulfill, reject in
|
|
self.textSecureAccountManager.registerForPushNotifications(pushToken:pushToken,
|
|
voipToken:voipToken,
|
|
success:fulfill,
|
|
failure:reject)
|
|
}
|
|
}
|
|
|
|
// MARK: Turn Server
|
|
|
|
func getTurnServerInfo() -> Promise<TurnServerInfo> {
|
|
return Promise { fulfill, reject in
|
|
self.networkManager.makeRequest(TurnServerInfoRequest(),
|
|
success: { (task: URLSessionDataTask, responseObject: Any?) in
|
|
guard responseObject != nil else {
|
|
return reject(OWSErrorMakeUnableToProcessServerResponseError())
|
|
}
|
|
|
|
if let responseDictionary = responseObject as? [String: AnyObject] {
|
|
if let turnServerInfo = TurnServerInfo(attributes:responseDictionary) {
|
|
Logger.debug("\(self.TAG) got valid turnserver info")
|
|
return fulfill(turnServerInfo)
|
|
}
|
|
Logger.error("\(self.TAG) unexpected server response:\(responseDictionary)")
|
|
}
|
|
return reject(OWSErrorMakeUnableToProcessServerResponseError())
|
|
},
|
|
failure: { (task: URLSessionDataTask, error: Error) in
|
|
return reject(error)
|
|
})
|
|
}
|
|
}
|
|
|
|
}
|