witine/linphone-ios
1
0
Fork 0
forked from mirrors/linphone-iphone
Code Pull requests Activity

Replace publisher with delegate in ConversationListViewModel

Browse source
This commit is contained in:
QuentinArguillere 2024-09-10 16:49:59 +02:00
parent 17e3633cb6
commit a25441a467
1 changed files with 12 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
Linphone/UI/Main/Conversations/ViewModel/ConversationsListViewModel.swift
View file

@ -22,13 +22,12 @@ import linphonesw
import Combine import Combine
// swiftlint:disable line_length // swiftlint:disable line_length
// swiftlint:disable large_tuple
class ConversationsListViewModel: ObservableObject { class ConversationsListViewModel: ObservableObject {
private var coreContext = CoreContext.shared private var coreContext = CoreContext.shared
private var contactsManager = ContactsManager.shared private var contactsManager = ContactsManager.shared
private var mCoreSuscriptions = Set<AnyCancellable?>() private var coreConversationDelegate: CoreDelegate?
@Published var conversationsList: [ConversationModel] = [] @Published var conversationsList: [ConversationModel] = []
var conversationsListTmp: [ConversationModel] = [] var conversationsListTmp: [ConversationModel] = []
@ -69,11 +68,18 @@ class ConversationsListViewModel: ObservableObject {
let account = core.defaultAccount let account = core.defaultAccount
let chatRoomsCounter = account?.chatRooms != nil ? account!.chatRooms.count : core.chatRooms.count let chatRoomsCounter = account?.chatRooms != nil ? account!.chatRooms.count : core.chatRooms.count
var counter = 0 var counter = 0
self.mCoreSuscriptions.insert(core.publisher?.onChatRoomStateChanged?.postOnCoreQueue { (cbValue: (core: Core, chatRoom: ChatRoom, state: ChatRoom.State)) in
self.coreConversationDelegate = CoreDelegateStub(onMessagesReceived: { (_: Core, _: ChatRoom, _: [ChatMessage]) in
self.computeChatRoomsList(filter: "")
}, onMessageSent: { (_: Core, _: ChatRoom, _: ChatMessage) in
self.computeChatRoomsList(filter: "")
}, onChatRoomRead: { (_: Core, _: ChatRoom) in
self.computeChatRoomsList(filter: "")
}, onChatRoomStateChanged: { (_: Core, chatRoom: ChatRoom, state: ChatRoom.State) in
// Log.info("[ConversationsListViewModel] Conversation [${LinphoneUtils.getChatRoomId(chatRoom)}] state changed [$state]") // Log.info("[ConversationsListViewModel] Conversation [${LinphoneUtils.getChatRoomId(chatRoom)}] state changed [$state]")
switch cbValue.state { switch state {
case ChatRoom.State.Created: case ChatRoom.State.Created:
if !(cbValue.chatRoom.isEmpty && cbValue.chatRoom.hasCapability(mask: ChatRoom.Capabilities.OneToOne.rawValue)) { if !(chatRoom.isEmpty && chatRoom.hasCapability(mask: ChatRoom.Capabilities.OneToOne.rawValue)) {
counter += 1 counter += 1
} }
@ -89,18 +95,7 @@ class ConversationsListViewModel: ObservableObject {
break break
} }
}) })
core.addDelegate(delegate: self.coreConversationDelegate!)
self.mCoreSuscriptions.insert(core.publisher?.onChatRoomRead?.postOnCoreQueue { _ in
self.computeChatRoomsList(filter: "")
})
self.mCoreSuscriptions.insert(core.publisher?.onMessageSent?.postOnCoreQueue { _ in
self.computeChatRoomsList(filter: "")
})
self.mCoreSuscriptions.insert(core.publisher?.onMessagesReceived?.postOnCoreQueue { _ in
self.computeChatRoomsList(filter: "")
})
} }
} }
@ -221,4 +216,3 @@ class ConversationsListViewModel: ObservableObject {
} }
} }
// swiftlint:enable line_length // swiftlint:enable line_length
// swiftlint:enable large_tuple