Unified CDN & Media Loading Architecture (v5)

Sources/StreamChat/APIClient/APIClient.swift

@@ -23,12 +23,9 @@
 
     /// The attachment downloader.
     let attachmentDownloader: AttachmentDownloader
-
-    /// The attachment uploader.
-    let attachmentUploader: AttachmentUploader
 
-    /// The CDN Client to store and delete attachments.
-    let cdnClient: CDNClient
+    /// The CDN storage for uploading and deleting attachments.
+    let cdnStorage: CDNStorage
 
     /// Queue in charge of handling incoming requests
     private let operationQueue: OperationQueue = {
@@ -66,15 +63,13 @@
         requestEncoder: RequestEncoder,
         requestDecoder: RequestDecoder,
         attachmentDownloader: AttachmentDownloader,
-        attachmentUploader: AttachmentUploader,
-        cdnClient: CDNClient
+        cdnStorage: CDNStorage
     ) {
         encoder = requestEncoder
         decoder = requestDecoder
         session = URLSession(configuration: sessionConfiguration)
         self.attachmentDownloader = attachmentDownloader
-        self.attachmentUploader = attachmentUploader
-        self.cdnClient = cdnClient
+        self.cdnStorage = cdnStorage
     }
 
     /// Performs a network request and retries in case of network failures
@@ -323,18 +318,24 @@
         completion: @escaping @Sendable (Result<UploadedAttachment, Error>) -> Void
     ) {
         let uploadOperation = AsyncOperation(maxRetries: maximumRequestRetries) { [weak self] operation, done in
-            self?.attachmentUploader.upload(attachment, progress: progress) { [weak self] result in
-                switch result {
+            self?.cdnStorage.uploadAttachment(attachment, options: .init(progress: progress)) { [weak self] result in
+                let mappedResult = result.map { file in
+                    UploadedAttachment(
+                        attachment: attachment,
+                        remoteURL: file.fileURL,
+                        thumbnailURL: file.thumbnailURL
+                    )
+                }
+                switch mappedResult {
                 case let .failure(error) where self?.isConnectionError(error) == true:
-                    // Do not retry unless its a connection problem and we still have retries left
                     if operation.canRetry {
                         done(.retry)
                     } else {
-                        completion(result)
+                        completion(mappedResult)
                         done(.continue)
                     }
                 case .success, .failure:
-                    completion(result)
+                    completion(mappedResult)
                     done(.continue)
                 }
             }

Sources/StreamChat/APIClient/CDNClient/CDNClient.swift

@@ -15,78 +15,11 @@
     }
 }
 
-/// The CDN client is responsible to upload files to a CDN.
-public protocol CDNClient: Sendable {
-    static var maxAttachmentSize: Int64 { get }
-
-    /// Uploads attachment as a multipart/form-data and returns only the uploaded remote file.
-    /// - Parameters:
-    ///   - attachment: An attachment to upload.
-    ///   - progress: A closure that broadcasts upload progress.
-    ///   - completion: Returns the uploaded file's information.
-    func uploadAttachment(
-        _ attachment: AnyChatMessageAttachment,
-        progress: (@Sendable (Double) -> Void)?,
-        completion: @escaping @Sendable (Result<URL, Error>) -> Void
-    )
-
-    /// Uploads attachment as a multipart/form-data and returns the uploaded remote file and its thumbnail.
-    /// - Parameters:
-    ///   - attachment: An attachment to upload.
-    ///   - progress: A closure that broadcasts upload progress.
-    ///   - completion: Returns the uploaded file's information.
-    func uploadAttachment(
-        _ attachment: AnyChatMessageAttachment,
-        progress: (@Sendable (Double) -> Void)?,
-        completion: @escaping @Sendable (Result<UploadedFile, Error>) -> Void
-    )
-
-    /// Uploads standalone attachment as a multipart/form-data and returns the uploaded remote file and its thumbnail.
-    /// - Parameters:
-    ///   - attachment: An attachment to upload.
-    ///   - progress: A closure that broadcasts upload progress.
-    ///   - completion: Returns the uploaded file's information.
-    func uploadStandaloneAttachment<Payload>(
-        _ attachment: StreamAttachment<Payload>,
-        progress: (@Sendable (Double) -> Void)?,
-        completion: @escaping @Sendable (Result<UploadedFile, Error>) -> Void
-    )
-
-    /// Deletes the attachment from the CDN, given the remote URL.
-    /// - Parameters:
-    ///   - remoteUrl: The remote url of the attachment.
-    ///   - completion: Returns an error in case the delete operation fails.
-    func deleteAttachment(
-        remoteUrl: URL,
-        completion: @escaping @Sendable (Error?) -> Void
-    )
-}
-
-public extension CDNClient {
-    func uploadAttachment(
-        _ attachment: AnyChatMessageAttachment,
-        progress: (@Sendable (Double) -> Void)?,
-        completion: @escaping @Sendable (Result<UploadedFile, Error>) -> Void
-    ) {
-        uploadAttachment(attachment, progress: progress, completion: { (result: Result<URL, Error>) in
-            switch result {
-            case let .success(url):
-                completion(.success(UploadedFile(fileURL: url, thumbnailURL: nil)))
-            case let .failure(error):
-                completion(.failure(error))
-            }
-        })
-    }
-}
-
-/// Default implementation of CDNClient that uses Stream CDN
-final class StreamCDNClient: CDNClient, @unchecked Sendable {
-    static var maxAttachmentSize: Int64 { 100 * 1024 * 1024 }
-
+/// Default implementation of CDNStorage that uses Stream's API.
+final class StreamCDNStorage: CDNStorage, @unchecked Sendable {
     private let decoder: RequestDecoder
     private let encoder: RequestEncoder
     private let session: URLSession
-    /// Keeps track of uploading tasks progress
     @Atomic private var taskProgressObservers: [Int: NSKeyValueObservation] = [:]
 
     init(
@@ -101,64 +34,61 @@
 
     func uploadAttachment(
         _ attachment: AnyChatMessageAttachment,
-        progress: (@Sendable (Double) -> Void)? = nil,
-        completion: @escaping @Sendable (Result<URL, Error>) -> Void
-    ) {
-        uploadAttachment(attachment, progress: progress, completion: { (result: Result<UploadedFile, Error>) in
-            switch result {
-            case let .success(file):
-                completion(.success(file.fileURL))
-            case let .failure(error):
-                completion(.failure(error))
-            }
-        })
-    }
-
-    func uploadAttachment(
-        _ attachment: AnyChatMessageAttachment,
-        progress: (@Sendable (Double) -> Void)? = nil,
+        options: AttachmentUploadOptions,
         completion: @escaping @Sendable (Result<UploadedFile, Error>) -> Void
     ) {
         guard
             let uploadingState = attachment.uploadingState,
-            let fileData = try? Data(contentsOf: uploadingState.localFileURL) else {
+            let fileData = try? Data(contentsOf: uploadingState.localFileURL, options: .mappedIfSafe) else {
             return completion(.failure(ClientError.AttachmentUploading(id: attachment.id)))
         }
         let endpoint = Endpoint<FileUploadPayload>.uploadAttachment(with: attachment.id.cid, type: attachment.type)
-        
+
         uploadAttachment(
             endpoint: endpoint,
             fileData: fileData,
             uploadingState: uploadingState,
-            progress: progress,
+            progress: options.progress,
             completion: completion
         )
     }
-    
-    func uploadStandaloneAttachment<Payload>(
-        _ attachment: StreamAttachment<Payload>,
-        progress: (@Sendable (Double) -> Void)? = nil,
+
+    func uploadAttachment(
+        localUrl: URL,
+        options: AttachmentUploadOptions,
         completion: @escaping @Sendable (Result<UploadedFile, Error>) -> Void
     ) {
-        guard
-            let uploadingState = attachment.uploadingState,
-            let fileData = try? Data(contentsOf: uploadingState.localFileURL) else {
+        let uploadingState: AttachmentUploadingState
+        do {
+            uploadingState = AttachmentUploadingState(
+                localFileURL: localUrl,
+                state: .pendingUpload,
+                file: try .init(url: localUrl)
+            )
+        } catch {
+            completion(.failure(error))
+            return
+        }
+
+        guard let fileData = try? Data(contentsOf: localUrl, options: .mappedIfSafe) else {
             return completion(.failure(ClientError.Unknown()))
         }
 
-        let endpoint = Endpoint<FileUploadPayload>.uploadAttachment(type: attachment.type)
-
+        let isImage = uploadingState.file.type.isImage
+        let endpoint = Endpoint<FileUploadPayload>.uploadAttachment(type: isImage ? .image : .file)
+
         uploadAttachment(
             endpoint: endpoint,
             fileData: fileData,
             uploadingState: uploadingState,
-            progress: progress,
+            progress: options.progress,
             completion: completion
         )
     }
 
     func deleteAttachment(
         remoteUrl: URL,
+        options: AttachmentDeleteOptions,
         completion: @escaping @Sendable (Error?) -> Void
     ) {
         let isImage = AttachmentFileType(ext: remoteUrl.pathExtension).isImage
@@ -196,7 +126,6 @@
         progress: (@Sendable (Double) -> Void)? = nil,
         completion: @escaping @Sendable (Result<UploadedFile, Error>) -> Void
     ) {
-        // Encode locally stored attachment into multipart form data
         let multipartFormData = MultipartFormData(
             fileData,
             fileName: uploadingState.localFileURL.lastPathComponent,

Sources/StreamChat/APIClient/CDNClient/CDNImageResize.swift

@@ -0,0 +1,24 @@
+//
+// Copyright © 2026 Stream.io Inc. All rights reserved.
+//
+
+import CoreGraphics
+
+/// Parameters for CDN server-side image resize (Stream `w` / `h` / `resize` / `crop` query parameters).
+public struct CDNImageResize: Sendable {
+    /// Width in points (scaled to pixels using screen scale when building the URL).
+    public var width: CGFloat
+    /// Height in points (scaled to pixels using screen scale when building the URL).
+    public var height: CGFloat
+    /// Value for the `resize` query parameter (for example `"clip"`, `"crop"`, `"fill"`, `"scale"`).
+    public var resizeMode: String
+    /// Value for the `crop` query parameter when using crop resize mode.
+    public var crop: String?
+
+    public init(width: CGFloat, height: CGFloat, resizeMode: String, crop: String? = nil) {
+        self.width = width
+        self.height = height
+        self.resizeMode = resizeMode
+        self.crop = crop
+    }
+}