applogical-startup-x

import SwiftUI import UIKit import ImageIO import CryptoKit import Combine import os.log // MARK: - CORE PIPELINE // -------------------------------------------------------- // Zentraler Actor für Ressourcen-Orchestrierung. // Vermeidet Race Conditions durch strikte Isolation. fileprivate let logger = Logger(subsystem: "com.core.pipeline", category: "IO") actor AsyncImagePipeline { static let shared = AsyncImagePipeline() // MARK: L1 Cache (RAM) // NSCache leert sich automatisch bei Memory Pressure Events vom OS. // Speichert fertig dekomprimierte UIImages. private let memoryCache: NSCache<NSString, UIImage> = { let cache = NSCache<NSString, UIImage>() cache.countLimit = 300 cache.totalCostLimit = 1024 * 1024 * 200 // 200 MB Hard Limit return cache }() // MARK: L2 Cache (Disk) private let fileManager = FileManager.default private let cacheDirectory: URL // Serial Queue für Disk-Writes verhindert Blocking des Main Threads. private let ioQueue = DispatchQueue(label: "com.core.io", qos: .utility) // MARK: Request Deduplication // Verhindert redundante Netzwerk-Requests für dieselbe Ressource (Thundering Herd). private var activeTasks: [String: Task<UIImage, Error>] = [:] private var cancelBag = Set<AnyCancellable>() private init() { let paths = fileManager.urls(for: .cachesDirectory, in: .userDomainMask) cacheDirectory = paths[0].appendingPathComponent("PipelineCache_v1") if !fileManager.fileExists(atPath: cacheDirectory.path) { try? fileManager.createDirectory(at: cacheDirectory, withIntermediateDirectories: true) } NotificationCenter.default.publisher(for: UIApplication.didReceiveMemoryWarningNotification) .sink { [weak self] _ in Task { await self?.purgeCache() } } .store(in: &cancelBag) } // MARK: - API /// Synchroner Lookup für UI-Binding (kein await). nonisolated func cachedImage(for url: URL, size: CGSize, scale: CGFloat) -> UIImage? { let key = cacheKey(for: url, size: quantized(size), scale: scale) return memoryCache.object(forKey: key as NSString) } /// Core Load Logic: RAM -> Active Task -> Disk -> Network. func image(for url: URL, size: CGSize, scale: CGFloat) async throws -> UIImage { let qSize = quantized(size) let key = cacheKey(for: url, size: qSize, scale: scale) let fileURL = diskFileURL(for: url) // 1. Fast Path if let memoryImage = memoryCache.object(forKey: key as NSString) { return memoryImage } // 2. Deduplication if let existingTask = activeTasks[key] { return try await existingTask.value } // 3. Execution let task = Task<UIImage, Error> { // A. Disk Read if fileManager.fileExists(atPath: fileURL.path) { return try await ImageProcessor.downsample(source: .disk(fileURL), to: qSize, scale: scale) } // B. Network IO var request = URLRequest(url: url, cachePolicy: .reloadIgnoringLocalCacheData, timeoutInterval: 30) request.httpShouldUsePipelining = true let (data, response) = try await URLSession.shared.data(for: request) guard let http = response as? HTTPURLResponse, 200...299 ~= http.statusCode else { throw URLError(.badServerResponse) } // C. Async Disk Commit ioQueue.async { try? data.write(to: fileURL, options: .atomic) } // D. Decoding & Resize return try await ImageProcessor.downsample(source: .memory(data), to: qSize, scale: scale) } activeTasks[key] = task do { let image = try await task.value memoryCache.setObject(image, forKey: key as NSString, cost: image.memoryCost) activeTasks[key] = nil return image } catch { activeTasks[key] = nil throw error } } func purgeCache() { logger.warning("Memory Warning - Purging L1 Cache") memoryCache.removeAllObjects() } } // MARK: - OFF-MAIN THREAD PROCESSING struct ImageProcessor { static func downsample(source: ImageSource, to size: CGSize, scale: CGFloat) async throws -> UIImage { // Detached Task verhindert Main Thread Blocking während der ImageIO Operation. return try await Task.detached(priority: .userInitiated) { let options = [kCGImageSourceShouldCache: false] as CFDictionary // ... (ImageIO Implementation) ... guard let cgImage = CGImageSourceCreateThumbnailAtIndex(src, 0, downsampleOptions) else { throw URLError(.cannotDecodeRawData) } return UIImage(cgImage: cgImage) }.value } }