48 lines
2.0 KiB
Swift
48 lines
2.0 KiB
Swift
//
|
|
// Copyright 2025 New Vector Ltd.
|
|
//
|
|
// SPDX-License-Identifier: AGPL-3.0-only OR LicenseRef-Element-Commercial
|
|
// Please see LICENSE files in the repository root for full details.
|
|
//
|
|
|
|
import Combine
|
|
import Foundation
|
|
import MatrixRustSDK
|
|
|
|
extension SpaceRoomListProxyMock {
|
|
class Configuration {
|
|
var spaceRoomProxy: SpaceRoomProxyProtocol
|
|
var initialSpaceRooms: [SpaceRoomProxyProtocol]
|
|
var paginationStateSubject: CurrentValueSubject<SpaceRoomListProxyPaginationState, Never>
|
|
var paginationResponses: [[SpaceRoomProxyProtocol]]
|
|
|
|
init(spaceRoomProxy: SpaceRoomProxyProtocol,
|
|
initialSpaceRooms: [SpaceRoomProxyProtocol] = [],
|
|
paginationStateSubject: CurrentValueSubject<SpaceRoomListProxyPaginationState, Never> = .init(.idle(endReached: true)),
|
|
paginationResponses: [[SpaceRoomProxyProtocol]] = []) {
|
|
self.spaceRoomProxy = spaceRoomProxy
|
|
self.initialSpaceRooms = initialSpaceRooms
|
|
self.paginationStateSubject = paginationStateSubject
|
|
self.paginationResponses = paginationResponses
|
|
}
|
|
}
|
|
|
|
convenience init(_ configuration: Configuration) {
|
|
self.init()
|
|
|
|
let spaceRoomsSubject: CurrentValueSubject<[SpaceRoomProxyProtocol], Never> = .init(configuration.initialSpaceRooms)
|
|
|
|
spaceRoom = configuration.spaceRoomProxy
|
|
spaceRoomsPublisher = spaceRoomsSubject.asCurrentValuePublisher()
|
|
paginationStatePublisher = configuration.paginationStateSubject.asCurrentValuePublisher()
|
|
|
|
paginateClosure = {
|
|
configuration.paginationStateSubject.send(.loading)
|
|
try? await Task.sleep(for: .milliseconds(100))
|
|
let newRooms = configuration.paginationResponses.removeFirst()
|
|
spaceRoomsSubject.send(spaceRoomsSubject.value + newRooms)
|
|
configuration.paginationStateSubject.send(.idle(endReached: configuration.paginationResponses.isEmpty))
|
|
}
|
|
}
|
|
}
|