import AVFoundation

class VideoPlayerManager {
    private var player: AVPlayer?
    private var cacheURL: URL!
    private var outputStream: OutputStream?
    private var inputStream: InputStream?
    
    func startPlayback(url: URL) {
        // 創(chuàng)建緩存文件路徑
        cacheURL = FileManager.default.temporaryDirectory.appendingPathComponent("cachedVideo.mp4")
        
        // 初始化輸出流（用于寫(xiě)入緩存）
        outputStream = OutputStream(toFileAtPath: cacheURL.path, append: true)
        outputStream?.open()
        
        // 初始化輸入流（用于讀取緩存）
        inputStream = InputStream(url: cacheURL)!
        inputStream?.open()
        
        // 創(chuàng)建 AVPlayer 并綁定播放源
        let asset = AVURLAsset(url: url)
        let playerItem = AVPlayerItem(asset: asset)
        player = AVPlayer(playerItem: playerItem)
        
        // 自定義資源加載器
        let resourceLoaderDelegate = ResourceLoaderDelegate(outputStream: outputStream, inputStream: inputStream)
        asset.resourceLoader.setDelegate(resourceLoaderDelegate, queue: .main)
        
        // 開(kāi)始播放
        player?.play()
        
        // 啟動(dòng)下載任務(wù)
        startDownloadTask(url: url)
    }
    
    private func startDownloadTask(url: URL) {
        var request = URLRequest(url: url)
        request.httpMethod = "GET"
        
        // 設(shè)置 Range 請(qǐng)求頭（斷點(diǎn)續(xù)傳）
        if let fileData = try? Data(contentsOf: cacheURL), fileData.count > 0 {
            let range = "bytes=\(fileData.count)-"
            request.setValue(range, forHTTPHeaderField: "Range")
        }
        
        let task = URLSession.shared.dataTask(with: request) { [weak self] data, response, error in
            guard let self = self else { return }
            if let data = data {
                // 將下載的數(shù)據(jù)寫(xiě)入緩存文件
                self.writeDataToFile(data: data)
            }
        }
        task.resume()
    }
    
    private func writeDataToFile(data: Data) {
        if let outputStream = outputStream {
            let buffer = [UInt8](data)
            outputStream.write(buffer, maxLength: buffer.count)
            outputStream.flush()
        }
    }
}

class ResourceLoaderDelegate: NSObject, AVAssetResourceLoaderDelegate {
    private let outputStream: OutputStream?
    private let inputStream: InputStream?
    private var cachedData: Data = Data()
    
    init(outputStream: OutputStream?, inputStream: InputStream?) {
        self.outputStream = outputStream
        self.inputStream = inputStream
    }
    
    func resourceLoader(_ resourceLoader: AVAssetResourceLoader,
                        shouldWaitForLoadingOfRequestedResource loadingRequest: AVAssetResourceLoadingRequest) -> Bool {
        // 實(shí)時(shí)讀取緩存數(shù)據(jù)并返回給播放器
        DispatchQueue.global().async {
            var buffer = [UInt8](repeating: 0, count: 1024)
            while self.inputStream?.hasBytesAvailable == true {
                let bytesRead = self.inputStream?.read(&buffer, maxLength: buffer.count) ?? 0
                if bytesRead > 0 {
                    let data = Data(bytes: buffer, count: bytesRead)
                    loadingRequest.dataRequest.respond(with: data)
                }
            }
        }
        return true
    }
    
    func resourceLoader(_ resourceLoader: AVAssetResourceLoader,
                        didCancel loadingRequest: AVAssetResourceLoadingRequest) {
        // 處理取消請(qǐng)求
        loadingRequest.dataRequest.finishLoading()
    }
}

import KTVHTTPCache

class VideoCacheManager {
    func initCache() {
        do {
            try KTVHTTPCache.proxyStart()
            let maxLength: Int64 = 300 * 1024 * 1024 // 300MB
            KTVHTTPCache.cacheSetMaxCacheLength(maxLength)
        } catch {
            print("Proxy Start Failure: $error)")
        }
    }
    
    func playVideo(url: URL) {
        let proxyURLString = KTVHTTPCache.proxyURLString(withOriginalURLString: url.absoluteString)
        let proxyURL = URL(string: proxyURLString)!
        let player = AVPlayer(url: proxyURL)
        player.play()
    }
}

func preloadVideos(urls: [URL]) {
    let queue = OperationQueue()
    queue.maxConcurrentOperationCount = 3
    
    for url in urls {
        queue.addOperation {
            let proxyURLString = KTVHTTPCache.proxyURLString(withOriginalURLString: url.absoluteString)
            let proxyURL = URL(string: proxyURLString)!
            let request = URLRequest(url: proxyURL)
            let task = URLSession.shared.dataTask(with: request) { _, _, _ in }
            task.resume()
        }
    }
}