🎷 [UPDATE] Download support added.

Author: Burak Colak

Sources/ACMNetworking/ACMNetworking.swift

@@ -8,6 +8,7 @@ import Foundation
 public class ACMNetworking: NSObject {
     var requestTask: URLSessionDataTask?
     var downloadTask: URLSessionDownloadTask?
+    var taskProgress: NSKeyValueObservation?
 
     /// Public Init function
     /// For creating object with SDK

Sources/ACMNetworking/Library/Callbacks/ACMGenericCallbacks.swift

@@ -16,4 +16,6 @@ public enum ACMGenericCallbacks {
     public typealias ResponseCallback<T> = ((T) -> Void)?
     /// Success callback with generic response for closures
     public typealias DownloadCallback = ((ACMDownloadModel) -> Void)?
+    /// Progress callback with generic response for closures
+    public typealias ProgressCallback = ((ACMProgressModel) -> Void)?
 }

Sources/ACMNetworking/Library/Constants/NetworkMessages/ACMNetworkConstants.swift

@@ -42,6 +42,8 @@ public enum ACMNetworkConstants {
     public static var httpBodyMultipart = "Multipart data, length: %@"
     /// Info message for retry mechanism
     public static var httpRetryCount = "Current retry count is %d, total retry count is %d"
+    /// Error message if data is invalid and could not be parsed
+    public static var genericErrorMessage = "Generic error : %@"
 }
 
 public extension ACMNetworkConstants {

Sources/ACMNetworking/Library/MainCalls/ACMNetworking+Download.swift

@@ -19,46 +19,63 @@ public extension ACMNetworking {
     /// - Returns:
     ///     - Void
     func download(to endpoint: ACMBaseEndpoint,
-                                currentRetryCount: Int? = 0,
-                                onSuccess: ACMGenericCallbacks.DownloadCallback,
-                                onError: ACMGenericCallbacks.ErrorCallback)
+                  currentRetryCount _: Int? = 0,
+                  onSuccess: ACMGenericCallbacks.DownloadCallback,
+                  onProgress: ACMGenericCallbacks.ProgressCallback = nil,
+                  onError: ACMGenericCallbacks.ErrorCallback = nil)
     {
         guard let urlRequest = generateURLRequest(endpoint: endpoint) else { return }
 
         downloadTask = endpoint.session(delegate: self).downloadTask(with: urlRequest) { [weak self] url, urlResponse, error in
             guard let self else { return }
 
             self.handleNilErrorResponse(with: endpoint, error: error, onError: onError)
+            self.handleNilResponse(with: endpoint, response: urlResponse, onError: onError)
             self.handleConnectivityError(with: endpoint, error: error, onError: onError)
 
-            guard let url else { return }
-
-            guard let urlResponse else { return }
+            guard let url,
+                  let urlResponse,
+                  let httpResponse = self.handleHttpResponse(with: endpoint, response: urlResponse, onError: onError),
+                  let pathExtension = httpResponse.url?.pathExtension
+            else {
+                self.cancel()
+                return
+            }
 
             self.cancel()
+            self.taskProgress?.invalidate()
+            self.taskProgress = nil
 
             do {
-                let data = try Data(contentsOf: url)
-
-                let model = ACMDownloadModel(data: data, localURL: url, response: urlResponse)
-                onSuccess?(model)
-            } catch {}
+                let searchUrl = try FileManager.default.url(for: .documentDirectory, in: .userDomainMask, appropriateFor: nil, create: true)
+                let destinationDirectory = searchUrl
+                    .appendingPathComponent("ACMNetworking")
 
+                if !FileManager.default.fileExists(atPath: destinationDirectory.relativePath) {
+                    try FileManager.default.createDirectory(at: destinationDirectory, withIntermediateDirectories: true)
+                }
 
-            /* guard let data = self.handleData(with: endpoint, data: data, onError: onError) else { return }
-             guard let httpResponse = self.handleHttpResponse(with: endpoint, response: response, onError: onError) else { return }
+                let destination = destinationDirectory.appendingPathComponent(url.lastPathComponent)
+                    .appendingPathExtension(pathExtension)
 
-             // Check if response is in valid http range
-             guard self.validateResponse(with: httpResponse) else {
-                 self.executeRetry(with: endpoint, httpResponse: httpResponse, data: data, currentRetryCount: currentRetryCount, onSuccess: onSuccess, onError: onError)
-                 return
-             }
+                try FileManager.default.moveItem(at: url, to: destination)
 
-             self.cancel()
+                let data = try Data(contentsOf: destination)
 
-             self.handleResult(with: endpoint, data: data, onSuccess: onSuccess, onError: onError)
-              */
+                let model = ACMDownloadModel(data: data, localURL: destination, response: urlResponse)
+                onSuccess?(model)
+            } catch let e {
+                let errorMessage = String(format: ACMNetworkConstants.genericErrorMessage, e.localizedDescription)
+                ACMBaseLogger.warning(errorMessage)
+                onError?(ACMBaseNetworkError(message: ACMNetworkConstants.errorMessage, log: errorMessage, endpoint: endpoint))
+            }
         }
+
+        taskProgress = downloadTask?.progress.observe(\.fractionCompleted, changeHandler: { progress, _ in
+            let model = ACMProgressModel(progress: progress.fractionCompleted)
+            onProgress?(model)
+        })
+
         downloadTask?.resume()
     }
 }

Sources/ACMNetworking/Library/Models/ACMProgressModel.swift

@@ -0,0 +1,20 @@
+//
+//  ACMProgressModel.swift
+//
+//
+//  Created by Burak on 28.12.2023.
+//
+
+import Foundation
+
+public struct ACMProgressModel {
+    public var progress: Double
+    public func formatted(with format: String = "%.2f") -> String {
+        return String(format: format, progress)
+    }
+
+    public func formattedPercentage(with format: String = "%.f") -> String {
+        let percentageProgress = progress * 100
+        return String(format: format, percentageProgress)
+    }
+}