linphone-ios/Linphone/UI/Main/Conversations/ViewModel/ConversationsListViewModel.swift

/*
 * Copyright (c) 2010-2023 Belledonne Communications SARL.
 *
 * This file is part of linphone-iphone
 *
 * 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 Combine

class ConversationsListViewModel: ObservableObject {
	
	private var coreContext = CoreContext.shared
	private var contactsManager = ContactsManager.shared
	
	private var mCoreSuscriptions = Set<AnyCancellable?>()
	
	@Published var conversationsList: [ConversationModel] = []
	@Published var unreadMessages: Int = 0
	
	var selectedConversation: ConversationModel?
	
	init() {
		computeChatRoomsList(filter: "")
		addConversationDelegate()
	}
	
	func computeChatRoomsList(filter: String) {
		coreContext.doOnCoreQueue { core in
			let account = core.defaultAccount
			let chatRooms = account?.chatRooms != nil ? account!.chatRooms : core.chatRooms
			
			var conversationsListTmp: [ConversationModel] = []
			
			chatRooms.forEach { chatRoom in
				if chatRoom.hasCapability(mask: ChatRoom.Capabilities.OneToOne.rawValue) {
				}
				
				if filter.isEmpty {
					let model = ConversationModel(chatRoom: chatRoom)
					conversationsListTmp.append(model)
				}
			}
			
			if !self.conversationsList.isEmpty {
				for (index, element) in conversationsListTmp.enumerated() {
					if index > 0 && index < self.conversationsList.count && element.id != self.conversationsList[index].id {
						DispatchQueue.main.async {
							self.conversationsList[index] = element
						}
					}
				}
				
				DispatchQueue.main.async {
					self.conversationsList[0] = conversationsListTmp.first!
				}
			} else {
				DispatchQueue.main.async {
					self.conversationsList = conversationsListTmp
				}
			}
			
			self.updateUnreadMessagesCount()
		}
	}
	
	func addConversationDelegate() {
		coreContext.doOnCoreQueue { core in
			self.mCoreSuscriptions.insert(core.publisher?.onChatRoomStateChanged?.postOnMainQueue { (cbValue: (core: Core, chatRoom: ChatRoom, state: ChatRoom.State)) in
				//Log.info("[ConversationsListViewModel] Conversation [${LinphoneUtils.getChatRoomId(chatRoom)}] state changed [$state]")
				switch cbValue.state {
				case ChatRoom.State.Created:
					let model = ConversationModel(chatRoom: cbValue.chatRoom)
					self.addChatRoom(cbChatRoom: model)
				case ChatRoom.State.Deleted:
					self.computeChatRoomsList(filter: "")
					//ToastViewModel.shared.toastMessage = "toast_conversation_deleted"
					//ToastViewModel.shared.displayToast = true
				default:
					break
				}
			})
			
			self.mCoreSuscriptions.insert(core.publisher?.onMessageSent?.postOnMainQueue { _ in
				self.computeChatRoomsList(filter: "")
			})
			
			self.mCoreSuscriptions.insert(core.publisher?.onMessagesReceived?.postOnMainQueue { _ in
				self.computeChatRoomsList(filter: "")
			})
		}
	}
	
	func addChatRoom(cbChatRoom: ConversationModel) {
		Log.info("[ConversationsListViewModel] Re-ordering conversations")
		var sortedList: [ConversationModel] = []
		sortedList.append(cbChatRoom)
		sortedList.append(contentsOf: self.conversationsList)
		
		DispatchQueue.main.asyncAfter(deadline: .now() + 0.1) {
			self.conversationsList = sortedList.sorted { $0.lastUpdateTime > $1.lastUpdateTime }
		}
		
		updateUnreadMessagesCount()
	}
	
	func reorderChatRooms() {
		Log.info("[ConversationsListViewModel] Re-ordering conversations")
		var sortedList: [ConversationModel] = []
		sortedList.append(contentsOf: conversationsList)
		
		DispatchQueue.main.asyncAfter(deadline: .now() + 0.1) {
			self.conversationsList = sortedList.sorted { $0.lastUpdateTime > $1.lastUpdateTime }
		}
		
		updateUnreadMessagesCount()
	}
	
	func updateUnreadMessagesCount() {
		coreContext.doOnCoreQueue { core in
			let account = core.defaultAccount
			if account != nil {
				let count = account?.unreadChatMessageCount != nil ? account!.unreadChatMessageCount : core.unreadChatMessageCount
				
				DispatchQueue.main.async {
					self.unreadMessages = count
				}
			} else {
				DispatchQueue.main.async {
					self.unreadMessages = 0
				}
			}
		}
	}
	
	func getContentTextMessage(message: ChatMessage) -> String {
		var fromAddressFriend = message.fromAddress != nil
		? contactsManager.getFriendWithAddress(address: message.fromAddress!)?.name ?? nil
		: nil
		
		if !message.isOutgoing && message.chatRoom != nil && !message.chatRoom!.hasCapability(mask: ChatRoom.Capabilities.OneToOne.rawValue) {
			if fromAddressFriend == nil {
				if message.fromAddress!.displayName != nil {
					fromAddressFriend = message.fromAddress!.displayName! + ": "
				} else if message.fromAddress!.username != nil {
					fromAddressFriend = message.fromAddress!.username! + ": "
				} else {
					fromAddressFriend = ""
				}
			} else {
				fromAddressFriend! += ": "
			}
			
		} else {
			fromAddressFriend = nil
		}
		
		return (fromAddressFriend ?? "") + (message.contents.first(where: {$0.isText == true})?.utf8Text ?? (message.contents.first(where: {$0.isFile == true || $0.isFileTransfer == true})?.name ?? ""))
	}
	
	func getCallTime(startDate: time_t) -> String {
		let timeInterval = TimeInterval(startDate)
		
		let myNSDate = Date(timeIntervalSince1970: timeInterval)
		
		if Calendar.current.isDateInToday(myNSDate) {
			let formatter = DateFormatter()
			formatter.dateFormat = Locale.current.identifier == "fr_FR" ? "HH:mm" : "h:mm a"
			return formatter.string(from: myNSDate)
		} else if Calendar.current.isDateInYesterday(myNSDate) {
			let formatter = DateFormatter()
			formatter.dateFormat = Locale.current.identifier == "fr_FR" ? "HH:mm" : "h:mm a"
			return "Yesterday"
		} else if Calendar.current.isDate(myNSDate, equalTo: .now, toGranularity: .year) {
			let formatter = DateFormatter()
			formatter.dateFormat = Locale.current.identifier == "fr_FR" ? "dd/MM" : "MM/dd"
			return formatter.string(from: myNSDate)
		} else {
			let formatter = DateFormatter()
			formatter.dateFormat = Locale.current.identifier == "fr_FR" ? "dd/MM/yy" : "MM/dd/yy"
			return formatter.string(from: myNSDate)
		}
	}
	
	func refreshContactAvatarModel() {
		conversationsList.forEach { conversationModel in
			conversationModel.refreshAvatarModel()
		}
	}
}