/* * 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 . */ import linphonesw import Combine import SwiftUI final class MagicSearchSingleton: ObservableObject { static let shared = MagicSearchSingleton() private var coreContext = CoreContext.shared private var contactsManager = ContactsManager.shared private var magicSearch: MagicSearch! var currentFilter: String = "" var previousFilter: String? var needUpdateLastSearchContacts = false private var limitSearchToLinphoneAccounts = true @Published var allContact = false private var domainDefaultAccount = "" var searchDelegate: MagicSearchDelegate? private var contactLoadedDebounceWorkItem: DispatchWorkItem? func destroyMagicSearch() { magicSearch = nil } private init() { coreContext.doOnCoreQueue { core in self.domainDefaultAccount = core.defaultAccount?.params?.domain ?? "" self.magicSearch = try? core.createMagicSearch() self.magicSearch.limitedSearch = false self.searchDelegate = MagicSearchDelegateStub(onSearchResultsReceived: { (magicSearch: MagicSearch) in print("[MagicSearchSingleton] [onSearchResultsReceived] Received search results") self.needUpdateLastSearchContacts = true var lastSearchFriend: [SearchResult] = [] var lastSearchSuggestions: [SearchResult] = [] magicSearch.lastSearch.forEach { searchResult in if searchResult.friend != nil { if let address = searchResult.address, !lastSearchFriend.contains(where: { $0.address?.weakEqual(address2: address) ?? false }) { lastSearchFriend.append(searchResult) } else if let phoneNumber = searchResult.phoneNumber, !lastSearchFriend.contains(where: { $0.phoneNumber == phoneNumber }) { lastSearchFriend.append(searchResult) } } else { lastSearchSuggestions.append(searchResult) } } lastSearchSuggestions.sort(by: { ($0.address?.asStringUriOnly() ?? "") < ($1.address?.asStringUriOnly() ?? "") }) if let defaultAccount = core.defaultAccount, let contactAddress = defaultAccount.contactAddress { lastSearchSuggestions.removeAll { $0.address?.weakEqual(address2: contactAddress) ?? false } } let sortedLastSearch = lastSearchFriend.sorted(by: { $0.friend!.name!.lowercased().folding(options: .diacriticInsensitive, locale: .current) < $1.friend!.name!.lowercased().folding(options: .diacriticInsensitive, locale: .current) }) var addedAvatarListModel: [ContactAvatarModel] = [] sortedLastSearch.forEach { searchResult in if searchResult.friend != nil { addedAvatarListModel.append( ContactAvatarModel( friend: searchResult.friend!, name: searchResult.friend?.name ?? "", address: searchResult.friend?.address?.clone()?.asStringUriOnly() ?? "", withPresence: true ) ) } } self.contactsManager.avatarListModel.forEach { contactAvatarModel in contactAvatarModel.removeFriendDelegate() } self.updateContacts(sortedLastSearch: sortedLastSearch, lastSearchSuggestions: lastSearchSuggestions, addedAvatarListModel: addedAvatarListModel) }) self.magicSearch.addDelegate(delegate: self.searchDelegate!) } } func updateContacts( sortedLastSearch: [SearchResult], lastSearchSuggestions: [SearchResult], addedAvatarListModel: [ContactAvatarModel] ) { DispatchQueue.main.async { self.contactsManager.lastSearch = sortedLastSearch self.contactsManager.lastSearchSuggestions = lastSearchSuggestions self.contactsManager.avatarListModel.removeAll() self.contactsManager.avatarListModel += addedAvatarListModel // Cancel previous debounce task self.contactLoadedDebounceWorkItem?.cancel() // Schedule new debounce task let workItem = DispatchWorkItem { NotificationCenter.default.post(name: NSNotification.Name("ContactLoaded"), object: nil) } self.contactLoadedDebounceWorkItem = workItem DispatchQueue.main.asyncAfter(deadline: .now() + 0.5, execute: workItem) } } func searchForContacts() { coreContext.doOnCoreQueue { _ in var needResetCache = false if let oldFilter = self.previousFilter { if oldFilter.count > self.currentFilter.count || oldFilter != self.currentFilter { needResetCache = true } } self.previousFilter = self.currentFilter if needResetCache { self.magicSearch.resetSearchCache() } self.magicSearch.getContactsListAsync( filter: self.currentFilter, domain: self.allContact ? "" : self.domainDefaultAccount, sourceFlags: MagicSearch.Source.All.rawValue, aggregation: MagicSearch.Aggregation.Friend) } } }