mirror of https://github.com/oxen-io/session-ios
You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
41 lines
2.0 KiB
Swift
41 lines
2.0 KiB
Swift
// Copyright © 2022 Rangeproof Pty Ltd. All rights reserved.
|
|
|
|
import Foundation
|
|
import GRDB
|
|
import DifferenceKit
|
|
import SignalUtilitiesKit
|
|
import SessionMessagingKit
|
|
|
|
public class ThreadPickerViewModel {
|
|
/// This value is the current state of the view
|
|
public private(set) var viewData: [SessionThreadViewModel] = []
|
|
|
|
/// This is all the data the screen needs to populate itself, please see the following link for tips to help optimise
|
|
/// performance https://github.com/groue/GRDB.swift#valueobservation-performance
|
|
///
|
|
/// **Note:** The 'trackingConstantRegion' is optimised in such a way that the request needs to be static
|
|
/// otherwise there may be situations where it doesn't get updates, this means we can't have conditional queries
|
|
///
|
|
/// **Note:** This observation will be triggered twice immediately (and be de-duped by the `removeDuplicates`)
|
|
/// this is due to the behaviour of `ValueConcurrentObserver.asyncStartObservation` which triggers it's own
|
|
/// fetch (after the ones in `ValueConcurrentObserver.asyncStart`/`ValueConcurrentObserver.syncStart`)
|
|
/// just in case the database has changed between the two reads - unfortunately it doesn't look like there is a way to prevent this
|
|
public lazy var observableViewData = ValueObservation
|
|
.trackingConstantRegion { db -> [SessionThreadViewModel] in
|
|
let userPublicKey: String = getUserHexEncodedPublicKey(db)
|
|
|
|
return try SessionThreadViewModel
|
|
.shareQuery(userPublicKey: userPublicKey)
|
|
.fetchAll(db)
|
|
}
|
|
.map { threads -> [SessionThreadViewModel] in threads.filter { $0.canWrite } } // Exclude unwritable threads
|
|
.removeDuplicates()
|
|
.handleEvents(didFail: { SNLog("[ThreadPickerViewModel] Observation failed with error: \($0)") })
|
|
|
|
// MARK: - Functions
|
|
|
|
public func updateData(_ updatedData: [SessionThreadViewModel]) {
|
|
self.viewData = updatedData
|
|
}
|
|
}
|