mirror of
https://github.com/yattee/yattee.git
synced 2024-12-13 13:50:32 +05:30
54 lines
1.6 KiB
Swift
54 lines
1.6 KiB
Swift
import Foundation
|
|
import Siesta
|
|
import SwiftUI
|
|
|
|
final class SubscriptionsModel: ObservableObject {
|
|
@Published var channels = [Channel]()
|
|
@Published var api: InvidiousAPI! = InvidiousAPI()
|
|
|
|
var resource: Resource {
|
|
api.subscriptions
|
|
}
|
|
|
|
init(api: InvidiousAPI? = nil) {
|
|
self.api = api
|
|
}
|
|
|
|
var all: [Channel] {
|
|
channels.sorted { $0.name.lowercased() < $1.name.lowercased() }
|
|
}
|
|
|
|
func subscribe(_ channelID: String, onSuccess: @escaping () -> Void = {}) {
|
|
performRequest(channelID, method: .post, onSuccess: onSuccess)
|
|
}
|
|
|
|
func unsubscribe(_ channelID: String, onSuccess: @escaping () -> Void = {}) {
|
|
performRequest(channelID, method: .delete, onSuccess: onSuccess)
|
|
}
|
|
|
|
func isSubscribing(_ channelID: String) -> Bool {
|
|
channels.contains { $0.id == channelID }
|
|
}
|
|
|
|
func load(force: Bool = false, onSuccess: @escaping () -> Void = {}) {
|
|
let request = force ? resource.load() : resource.loadIfNeeded()
|
|
|
|
request?
|
|
.onSuccess { resource in
|
|
if let channels: [Channel] = resource.typedContent() {
|
|
self.channels = channels
|
|
onSuccess()
|
|
}
|
|
}
|
|
.onFailure { _ in
|
|
self.channels = []
|
|
}
|
|
}
|
|
|
|
fileprivate func performRequest(_ channelID: String, method: RequestMethod, onSuccess: @escaping () -> Void = {}) {
|
|
api.channelSubscription(channelID).request(method).onCompletion { _ in
|
|
self.load(force: true, onSuccess: onSuccess)
|
|
}
|
|
}
|
|
}
|