2022-12-11 01:38:03 +05:30
|
|
|
import Cache
|
2021-09-25 13:48:22 +05:30
|
|
|
import Foundation
|
2022-12-11 01:38:03 +05:30
|
|
|
import Logging
|
2021-09-25 13:48:22 +05:30
|
|
|
import Siesta
|
|
|
|
import SwiftUI
|
2022-12-11 01:38:03 +05:30
|
|
|
import SwiftyJSON
|
2021-09-25 13:48:22 +05:30
|
|
|
|
2022-12-11 17:08:57 +05:30
|
|
|
final class SubsribedChannelsModel: ObservableObject {
|
|
|
|
static var shared = SubsribedChannelsModel()
|
2022-12-11 01:38:03 +05:30
|
|
|
let logger = Logger(label: "stream.yattee.cache.channels")
|
|
|
|
|
|
|
|
static let diskConfig = DiskConfig(name: "channels")
|
|
|
|
static let memoryConfig = MemoryConfig()
|
|
|
|
|
|
|
|
let storage = try! Storage<String, JSON>(
|
2022-12-11 17:08:57 +05:30
|
|
|
diskConfig: SubsribedChannelsModel.diskConfig,
|
|
|
|
memoryConfig: SubsribedChannelsModel.memoryConfig,
|
2022-12-11 01:38:03 +05:30
|
|
|
transformer: CacheModel.jsonTransformer
|
|
|
|
)
|
2022-11-25 02:06:05 +05:30
|
|
|
|
2022-12-11 17:08:57 +05:30
|
|
|
@Published var isLoading = false
|
2021-09-25 13:48:22 +05:30
|
|
|
@Published var channels = [Channel]()
|
2022-11-25 02:06:05 +05:30
|
|
|
var accounts: AccountsModel { .shared }
|
2021-10-17 04:18:58 +05:30
|
|
|
|
2021-10-21 03:51:50 +05:30
|
|
|
var resource: Resource? {
|
|
|
|
accounts.api.subscriptions
|
2021-09-25 13:48:22 +05:30
|
|
|
}
|
|
|
|
|
|
|
|
var all: [Channel] {
|
|
|
|
channels.sorted { $0.name.lowercased() < $1.name.lowercased() }
|
|
|
|
}
|
|
|
|
|
|
|
|
func subscribe(_ channelID: String, onSuccess: @escaping () -> Void = {}) {
|
2021-11-15 04:36:01 +05:30
|
|
|
accounts.api.subscribe(channelID) {
|
|
|
|
self.scheduleLoad(onSuccess: onSuccess)
|
|
|
|
}
|
2021-09-25 13:48:22 +05:30
|
|
|
}
|
|
|
|
|
|
|
|
func unsubscribe(_ channelID: String, onSuccess: @escaping () -> Void = {}) {
|
2021-11-15 04:36:01 +05:30
|
|
|
accounts.api.unsubscribe(channelID) {
|
|
|
|
self.scheduleLoad(onSuccess: onSuccess)
|
|
|
|
}
|
2021-09-25 13:48:22 +05:30
|
|
|
}
|
|
|
|
|
|
|
|
func isSubscribing(_ channelID: String) -> Bool {
|
|
|
|
channels.contains { $0.id == channelID }
|
|
|
|
}
|
|
|
|
|
|
|
|
func load(force: Bool = false, onSuccess: @escaping () -> Void = {}) {
|
2022-12-11 17:08:57 +05:30
|
|
|
guard accounts.app.supportsSubscriptions, !isLoading, accounts.signedIn, let account = accounts.current else {
|
2021-12-20 03:57:20 +05:30
|
|
|
channels = []
|
2021-11-15 04:36:01 +05:30
|
|
|
return
|
|
|
|
}
|
2021-12-20 03:57:20 +05:30
|
|
|
|
2022-12-11 01:38:03 +05:30
|
|
|
loadCachedChannels(account)
|
|
|
|
|
2022-12-11 17:08:57 +05:30
|
|
|
DispatchQueue.main.async { [weak self] in
|
|
|
|
guard let self else { return }
|
|
|
|
let request = force ? self.resource?.load() : self.resource?.loadIfNeeded()
|
2021-09-25 13:48:22 +05:30
|
|
|
|
2022-12-11 17:08:57 +05:30
|
|
|
if request != nil {
|
|
|
|
self.isLoading = true
|
2021-09-25 13:48:22 +05:30
|
|
|
}
|
2022-12-11 17:08:57 +05:30
|
|
|
|
|
|
|
request?
|
|
|
|
.onCompletion { [weak self] _ in
|
|
|
|
self?.isLoading = false
|
|
|
|
}
|
|
|
|
.onSuccess { resource in
|
|
|
|
if let channels: [Channel] = resource.typedContent() {
|
|
|
|
self.channels = channels
|
|
|
|
self.storeChannels(account: account, channels: channels)
|
|
|
|
onSuccess()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
.onFailure { _ in
|
|
|
|
self.channels = []
|
|
|
|
}
|
|
|
|
}
|
2021-09-25 13:48:22 +05:30
|
|
|
}
|
|
|
|
|
2022-12-11 01:38:03 +05:30
|
|
|
func loadCachedChannels(_ account: Account) {
|
|
|
|
let cache = getChannels(account: account)
|
|
|
|
if !cache.isEmpty {
|
2022-12-11 17:08:57 +05:30
|
|
|
DispatchQueue.main.async {
|
|
|
|
self.channels = cache
|
|
|
|
}
|
2022-12-11 01:38:03 +05:30
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
func storeChannels(account: Account, channels: [Channel]) {
|
2022-12-11 17:08:57 +05:30
|
|
|
let date = iso8601DateFormatter.string(from: Date())
|
2022-12-11 01:38:03 +05:30
|
|
|
logger.info("caching channels \(channelsDateCacheKey(account)) -- \(date)")
|
|
|
|
|
|
|
|
let dateObject: JSON = ["date": date]
|
|
|
|
let channelsObject: JSON = ["channels": channels.map(\.json).map(\.object)]
|
|
|
|
|
|
|
|
try? storage.setObject(dateObject, forKey: channelsDateCacheKey(account))
|
|
|
|
try? storage.setObject(channelsObject, forKey: channelsCacheKey(account))
|
|
|
|
}
|
|
|
|
|
|
|
|
func getChannels(account: Account) -> [Channel] {
|
|
|
|
logger.info("getting channels \(channelsDateCacheKey(account))")
|
|
|
|
|
|
|
|
if let json = try? storage.object(forKey: channelsCacheKey(account)),
|
|
|
|
let channels = json.dictionaryValue["channels"]
|
|
|
|
{
|
|
|
|
return channels.arrayValue.map { Channel.from($0) }
|
|
|
|
}
|
|
|
|
|
|
|
|
return []
|
|
|
|
}
|
|
|
|
|
2021-11-15 04:36:01 +05:30
|
|
|
private func scheduleLoad(onSuccess: @escaping () -> Void) {
|
|
|
|
DispatchQueue.main.asyncAfter(deadline: .now() + 2) {
|
2021-09-25 13:48:22 +05:30
|
|
|
self.load(force: true, onSuccess: onSuccess)
|
|
|
|
}
|
|
|
|
}
|
2022-12-11 01:38:03 +05:30
|
|
|
|
2022-12-11 17:08:57 +05:30
|
|
|
private var iso8601DateFormatter: ISO8601DateFormatter {
|
2022-12-11 01:38:03 +05:30
|
|
|
.init()
|
|
|
|
}
|
|
|
|
|
|
|
|
private func channelsCacheKey(_ account: Account) -> String {
|
|
|
|
"channels-\(account.id)"
|
|
|
|
}
|
|
|
|
|
|
|
|
private func channelsDateCacheKey(_ account: Account) -> String {
|
|
|
|
"channels-\(account.id)-date"
|
|
|
|
}
|
2022-12-11 17:08:57 +05:30
|
|
|
|
|
|
|
func getFeedTime(account: Account) -> Date? {
|
|
|
|
if let json = try? storage.object(forKey: channelsDateCacheKey(account)),
|
|
|
|
let string = json.dictionaryValue["date"]?.string,
|
|
|
|
let date = iso8601DateFormatter.date(from: string)
|
|
|
|
{
|
|
|
|
return date
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
var feedTime: Date? {
|
|
|
|
if let account = accounts.current {
|
|
|
|
return getFeedTime(account: account)
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
|
|
|
var formattedCacheTime: String {
|
|
|
|
if let feedTime {
|
|
|
|
let isSameDay = Calendar(identifier: .iso8601).isDate(feedTime, inSameDayAs: Date())
|
|
|
|
let formatter = isSameDay ? dateFormatterForTimeOnly : dateFormatter
|
|
|
|
return formatter.string(from: feedTime)
|
|
|
|
}
|
|
|
|
|
|
|
|
return ""
|
|
|
|
}
|
|
|
|
|
|
|
|
private var dateFormatter: DateFormatter {
|
|
|
|
let formatter = DateFormatter()
|
|
|
|
formatter.dateStyle = .short
|
|
|
|
formatter.timeStyle = .medium
|
|
|
|
|
|
|
|
return formatter
|
|
|
|
}
|
|
|
|
|
|
|
|
private var dateFormatterForTimeOnly: DateFormatter {
|
|
|
|
let formatter = DateFormatter()
|
|
|
|
formatter.dateStyle = .none
|
|
|
|
formatter.timeStyle = .medium
|
|
|
|
|
|
|
|
return formatter
|
|
|
|
}
|
2021-09-25 13:48:22 +05:30
|
|
|
}
|