linphone-iphone/Linphone/UI/Main/Viewmodel/AccountModel.swift
2025-01-09 16:15:34 +01:00

282 lines
9.7 KiB
Swift

/*
* Copyright (c) 2010-2024 Belledonne Communications SARL.
*
* This file is part of Linphone
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
import Foundation
import linphonesw
import SwiftUI
import Combine
class AccountModel: ObservableObject {
static let TAG = "[AccountModel]"
let account: Account
@Published var humanReadableRegistrationState: String = ""
@Published var summary: String = ""
@Published var registrationStateAssociatedUIColor: Color = .clear
@Published var isRegistrered: Bool = false
@Published var notificationsCount: Int = 0
@Published var isDefaultAccount: Bool = false
@Published var displayName: String = ""
@Published var address: String = ""
@Published var avatarModel: ContactAvatarModel?
@Published var photoAvatarModel: String?
@Published var displayNameAvatar: String = ""
@Published var usernaneAvatar: String = ""
@Published var imagePathAvatar: URL?
@Published var devices: [AccountDeviceModel] = []
private var accountDelegate: AccountDelegate?
private var coreDelegate: CoreDelegate?
private var accountManagerServices: AccountManagerServices?
private var requestDelegate: AccountManagerServicesRequestDelegate?
init(account: Account, core: Core) {
self.account = account
accountDelegate = AccountDelegateStub(onRegistrationStateChanged: { (_: Account, _: RegistrationState, _: String) in
self.update()
})
account.addDelegate(delegate: accountDelegate!)
coreDelegate = CoreDelegateStub(onCallStateChanged: { (_: Core, _: Call, _: Call.State, _: String) in
self.computeNotificationsCount()
}, onMessagesReceived: { (_: Core, _: ChatRoom, _: [ChatMessage]) in
self.computeNotificationsCount()
}, onChatRoomRead: { (_: Core, _: ChatRoom) in
self.computeNotificationsCount()
})
core.addDelegate(delegate: coreDelegate!)
CoreContext.shared.doOnCoreQueue { _ in
self.update()
}
}
deinit {
if let delegate = accountDelegate {
account.removeDelegate(delegate: delegate)
}
if let delegate = coreDelegate {
CoreContext.shared.doOnCoreQueue { core in
core.removeDelegate(delegate: delegate)
}
}
}
private func update() {
let state = account.state
var isDefault: Bool = false
if let defaultAccount = account.core?.defaultAccount {
isDefault = (defaultAccount == account)
}
let displayName = account.displayName()
let address = account.params?.identityAddress?.asString()
self.requestDevicesList()
let displayNameTmp = account.params?.identityAddress?.displayName ?? ""
let usernaneAvatarTmp = account.contactAddress?.username ?? ""
var photoAvatarModelTmp = ""
let preferences = UserDefaults.standard
let photoAvatarModelKey = "photo_avatar_model" + usernaneAvatarTmp
if preferences.object(forKey: photoAvatarModelKey) == nil {
preferences.set(photoAvatarModelKey, forKey: photoAvatarModelKey)
} else {
photoAvatarModelTmp = preferences.string(forKey: photoAvatarModelKey)!
}
DispatchQueue.main.async { [self] in
switch state {
case .Cleared, .None:
humanReadableRegistrationState = "drawer_menu_account_connection_status_cleared".localized()
summary = "manage_account_status_cleared_summary".localized()
registrationStateAssociatedUIColor = .orangeWarning600
case .Progress:
humanReadableRegistrationState = "drawer_menu_account_connection_status_progress".localized()
summary = "manage_account_status_progress_summary".localized()
registrationStateAssociatedUIColor = .greenSuccess500
case .Failed:
humanReadableRegistrationState = "drawer_menu_account_connection_status_failed".localized()
summary = "manage_account_status_failed_summary".localized()
registrationStateAssociatedUIColor = .redDanger500
case .Ok:
humanReadableRegistrationState = "drawer_menu_account_connection_status_connected".localized()
summary = "manage_account_status_connected_summary".localized()
registrationStateAssociatedUIColor = .greenSuccess500
case .Refreshing:
humanReadableRegistrationState = "drawer_menu_account_connection_status_refreshing".localized()
summary = "manage_account_status_progress_summary".localized()
registrationStateAssociatedUIColor = .grayMain2c500
}
isRegistrered = state == .Ok
isDefaultAccount = isDefault
self.displayName = displayName
address.map {self.address = $0}
photoAvatarModel = photoAvatarModelTmp
displayNameAvatar = displayNameTmp
usernaneAvatar = usernaneAvatarTmp
imagePathAvatar = getImagePath()
}
}
private func computeNotificationsCount() {
let count = account.unreadChatMessageCount + account.missedCallsCount
DispatchQueue.main.async { [self] in
notificationsCount = count
}
}
func refreshRegiter() {
CoreContext.shared.doOnCoreQueue { _ in
self.account.refreshRegister()
}
}
func getImagePath() -> URL {
let imagePath = FileManager.default.urls(for: .documentDirectory, in: .userDomainMask).first!.appendingPathComponent(
photoAvatarModel ?? "Error"
)
return imagePath
}
func requestDevicesList() {
if account.params != nil && account.params!.identityAddress != nil, let identityAddress = account.params!.identityAddress {
Log.info(
"\(AccountModel.TAG) Request devices list for identity address \(identityAddress.asStringUriOnly())"
)
CoreContext.shared.doOnCoreQueue { core in
do {
self.accountManagerServices = try core.createAccountManagerServices()
if self.accountManagerServices != nil {
self.accountManagerServices!.language = Locale.current.identifier
do {
let request = try self.accountManagerServices!.createGetDevicesListRequest(sipIdentity: identityAddress)
self.addDelegate(request: request)
} catch {
print("\(AccountModel.TAG) Failed to create request: \(error.localizedDescription)")
}
}
} catch {
}
}
}
}
func addDelegate(request: AccountManagerServicesRequest) {
self.requestDelegate = AccountManagerServicesRequestDelegateStub(
onRequestSuccessful: { (request: AccountManagerServicesRequest, data: String) in
Log.info("\(AccountModel.TAG) Request \(request) was successful, data is \(data)")
}, onRequestError: { (request: AccountManagerServicesRequest, statusCode: Int, errorMessage: String, parameterErrors: Dictionary?) in
Log.error(
"\(AccountModel.TAG) Request \(request) returned an error with status code \(statusCode) and message \(errorMessage)"
)
// TODO Display Error Toast
}, onDevicesListFetched: { (request: AccountManagerServicesRequest, accountDevices: [AccountDevice]) in
Log.info("\(AccountModel.TAG) Fetched \(accountDevices.count) devices for our account")
var devicesList: [AccountDeviceModel] = []
accountDevices.forEach { accountDevice in
devicesList.append(AccountDeviceModel(accountDevice: accountDevice))
}
request.removeDelegate(delegate: self.requestDelegate!)
DispatchQueue.main.async {
self.devices = devicesList
}
}
)
request.addDelegate(delegate: self.requestDelegate!)
request.submit()
}
func removeDevice(deviceIndex: Int) {
let removedDevice = self.devices[deviceIndex].accountDevice
self.devices.remove(at: deviceIndex)
if account.params != nil && account.params!.identityAddress != nil, let identityAddress = account.params!.identityAddress {
Log.info(
"\(AccountModel.TAG) Delete device for identity address \(identityAddress.asStringUriOnly())"
)
CoreContext.shared.doOnCoreQueue { core in
do {
self.accountManagerServices = try core.createAccountManagerServices()
if self.accountManagerServices != nil {
self.accountManagerServices!.language = Locale.current.identifier
do {
let request = try self.accountManagerServices!.createDeleteDeviceRequest(sipIdentity: identityAddress, device: removedDevice)
self.addDelegate(request: request)
} catch {
print("\(AccountModel.TAG) Failed to create request: \(error.localizedDescription)")
}
}
} catch {
}
}
}
}
func logout() {
CoreContext.shared.doOnCoreQueue { core in
Log.info("Account \(self.account.displayName()) has been removed")
core.removeAccount(account: self.account)
}
}
}
class AccountDeviceModel: ObservableObject {
let accountDevice: AccountDevice
@Published var deviceName: String = ""
@Published var lastDate: String = ""
@Published var lastTime: String = ""
@Published var isMobileDevice: Bool = true
init(accountDevice: AccountDevice) {
self.accountDevice = accountDevice
self.deviceName = accountDevice.name ?? ""
let timeInterval = TimeInterval(accountDevice.lastUpdateTimestamp ?? 0)
let dateTmp = Date(timeIntervalSince1970: timeInterval)
let dateFormat = DateFormatter()
dateFormat.dateFormat = Locale.current.identifier == "fr_FR" ? "dd/MM/YYYY" : "MM/dd/YYYY"
let date = dateFormat.string(from: dateTmp)
let dateFormatBis = DateFormatter()
dateFormatBis.dateFormat = "HH:mm"
let time = dateFormatBis.string(from: dateTmp)
self.lastDate = date
self.lastTime = time
self.isMobileDevice = accountDevice.userAgent.contains("LinphoneAndroid") || accountDevice.userAgent.contains(
"LinphoneiOS"
)
}
}