92 lines
3.5 KiB
Swift
92 lines
3.5 KiB
Swift
//
|
|
// Copyright 2022 New Vector Ltd
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
//
|
|
|
|
import Combine
|
|
import SwiftUI
|
|
|
|
typealias RoomDirectorySearchScreenViewModelType = StateStoreViewModel<RoomDirectorySearchScreenViewState, RoomDirectorySearchScreenViewAction>
|
|
|
|
class RoomDirectorySearchScreenViewModel: RoomDirectorySearchScreenViewModelType, RoomDirectorySearchScreenViewModelProtocol {
|
|
private let roomDirectorySearch: RoomDirectorySearchProxyProtocol
|
|
private let userIndicatorController: UserIndicatorControllerProtocol
|
|
|
|
private let actionsSubject: PassthroughSubject<RoomDirectorySearchScreenViewModelAction, Never> = .init()
|
|
var actionsPublisher: AnyPublisher<RoomDirectorySearchScreenViewModelAction, Never> {
|
|
actionsSubject.eraseToAnyPublisher()
|
|
}
|
|
|
|
init(roomDirectorySearch: RoomDirectorySearchProxyProtocol,
|
|
userIndicatorController: UserIndicatorControllerProtocol,
|
|
imageProvider: ImageProviderProtocol) {
|
|
self.roomDirectorySearch = roomDirectorySearch
|
|
self.userIndicatorController = userIndicatorController
|
|
super.init(initialViewState: RoomDirectorySearchScreenViewState(), imageProvider: imageProvider)
|
|
|
|
roomDirectorySearch.resultsPublisher
|
|
.receive(on: DispatchQueue.main)
|
|
.weakAssign(to: \.state.searchResults, on: self)
|
|
.store(in: &cancellables)
|
|
|
|
context.$viewState.map(\.bindings.searchString)
|
|
// only listen to the search string when is not loading
|
|
.combineLatest(context.$viewState.map(\.isLoading)
|
|
.filter { $0 == false })
|
|
.map(\.0)
|
|
.debounceTextQueriesAndRemoveDuplicates()
|
|
.sink { [weak self] query in
|
|
self?.search(query: query)
|
|
}
|
|
.store(in: &cancellables)
|
|
}
|
|
|
|
// MARK: - Public
|
|
|
|
override func process(viewAction: RoomDirectorySearchScreenViewAction) {
|
|
MXLog.info("View model: received view action: \(viewAction)")
|
|
|
|
switch viewAction {
|
|
case .dismiss:
|
|
actionsSubject.send(.dismiss)
|
|
case .join(roomID: let roomID):
|
|
joinRoom(roomID: roomID)
|
|
}
|
|
}
|
|
|
|
private func joinRoom(roomID: String) { }
|
|
|
|
private static let errorID = "roomDirectorySearchViewModelLoadingError"
|
|
|
|
private func search(query: String?) {
|
|
guard !state.isLoading else {
|
|
return
|
|
}
|
|
|
|
state.isLoading = true
|
|
Task {
|
|
switch await roomDirectorySearch.search(query: query) {
|
|
case .success:
|
|
break
|
|
case .failure:
|
|
userIndicatorController.submitIndicator(UserIndicator(id: Self.errorID,
|
|
type: .toast,
|
|
title: L10n.screenRoomDirectorySearchLoadingError,
|
|
iconName: "xmark"))
|
|
}
|
|
state.isLoading = false
|
|
}
|
|
}
|
|
}
|