117 lines
3.3 KiB
Swift
117 lines
3.3 KiB
Swift
import Foundation
|
|
|
|
class Cache {
|
|
static let shared = Cache()
|
|
|
|
private var items: [String: CacheItem] = [:]
|
|
private let queue = DispatchQueue(label: "cache.queue", attributes: .concurrent)
|
|
|
|
private init() {
|
|
startCleanupTimer()
|
|
}
|
|
|
|
func set<T: Codable>(_ data: T, forKey key: String, ttl: TimeInterval = 300) {
|
|
do {
|
|
let encodedData = try JSONEncoder().encode(data)
|
|
queue.async(flags: .barrier) {
|
|
self.items[key] = CacheItem(
|
|
data: encodedData,
|
|
timestamp: Date(),
|
|
ttl: ttl
|
|
)
|
|
}
|
|
} catch {
|
|
print("Ошибка кодирования данных для кэша: \(error)")
|
|
}
|
|
}
|
|
|
|
func get<T: Codable>(_ type: T.Type, forKey key: String) -> T? {
|
|
return queue.sync {
|
|
guard let item = items[key] else { return nil }
|
|
|
|
if Date().timeIntervalSince(item.timestamp) > item.ttl {
|
|
items.removeValue(forKey: key)
|
|
return nil
|
|
}
|
|
|
|
guard let data = item.data as? Data else { return nil }
|
|
|
|
do {
|
|
return try JSONDecoder().decode(type, from: data)
|
|
} catch {
|
|
print("Ошибка декодирования данных из кэша: \(error)")
|
|
return nil
|
|
}
|
|
}
|
|
}
|
|
|
|
func delete(_ key: String) {
|
|
queue.async(flags: .barrier) {
|
|
self.items.removeValue(forKey: key)
|
|
}
|
|
}
|
|
|
|
func clear() {
|
|
queue.async(flags: .barrier) {
|
|
self.items.removeAll()
|
|
}
|
|
}
|
|
|
|
private func startCleanupTimer() {
|
|
Timer.scheduledTimer(withTimeInterval: 300, repeats: true) { _ in
|
|
self.cleanup()
|
|
}
|
|
}
|
|
|
|
private func cleanup() {
|
|
queue.async(flags: .barrier) {
|
|
let now = Date()
|
|
self.items = self.items.filter { key, item in
|
|
if now.timeIntervalSince(item.timestamp) > item.ttl {
|
|
return false
|
|
}
|
|
return true
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
struct CacheItem {
|
|
let data: Data
|
|
let timestamp: Date
|
|
let ttl: TimeInterval
|
|
}
|
|
|
|
extension Cache {
|
|
func setBoards(_ boards: [Board]) {
|
|
set(boards, forKey: "boards", ttl: 600)
|
|
}
|
|
|
|
func getBoards() -> [Board]? {
|
|
return get([Board].self, forKey: "boards")
|
|
}
|
|
|
|
func setThreads(_ threads: [Thread], forBoard boardCode: String) {
|
|
set(threads, forKey: "threads_\(boardCode)", ttl: 300)
|
|
}
|
|
|
|
func getThreads(forBoard boardCode: String) -> [Thread]? {
|
|
return get([Thread].self, forKey: "threads_\(boardCode)")
|
|
}
|
|
|
|
func setThreadDetail(_ thread: ThreadDetail, forThreadId threadId: Int) {
|
|
set(thread, forKey: "thread_detail_\(threadId)", ttl: 180)
|
|
}
|
|
|
|
func getThreadDetail(forThreadId threadId: Int) -> ThreadDetail? {
|
|
return get(ThreadDetail.self, forKey: "thread_detail_\(threadId)")
|
|
}
|
|
|
|
func setComments(_ comments: [Comment], forThreadId threadId: Int) {
|
|
set(comments, forKey: "comments_\(threadId)", ttl: 180)
|
|
}
|
|
|
|
func getComments(forThreadId threadId: Int) -> [Comment]? {
|
|
return get([Comment].self, forKey: "comments_\(threadId)")
|
|
}
|
|
} |