Add session delegate to initializer

.github/workflows/tests.yml

@@ -14,11 +14,11 @@ on:
 jobs:
   test:
     name: Run tests
-    runs-on: macos-12
+    runs-on: macos-15
     steps:
       - name: Checkout
         uses: actions/checkout@v2
       - name: Change Xcode
-        run: sudo xcode-select -s /Applications/Xcode_13.4.1.app
+        run: sudo xcode-select -s /Applications/Xcode_15.0.1.app
       - name: Build and test
-        run: swift test --enable-code-coverage --disable-automatic-resolution
+        run: swift test --enable-code-coverage --disable-automatic-resolution

Apexy.podspec

@@ -1,27 +1,27 @@
 Pod::Spec.new do |s|
   s.name         = "Apexy"
-  s.version      = "1.7.3"
+  s.version      = "1.7.4"
   s.summary      = "HTTP transport library"
   s.homepage     = "https://github.com/RedMadRobot/apexy-ios"
   s.license      = { :type => "MIT"}
   s.author       = { "Alexander Ignatiev" => "[email protected]" }
   s.source       = { :git => "https://github.com/RedMadRobot/apexy-ios.git", :tag => "#{s.version}" }
 
-  s.ios.deployment_target = "11.0"
-  s.tvos.deployment_target = "11.0"
-  s.osx.deployment_target = "10.13"
-  s.watchos.deployment_target = "4.0"
+  s.ios.deployment_target = "13.0"
+  s.tvos.deployment_target = "13.0"
+  s.osx.deployment_target = "10.15"
+  s.watchos.deployment_target = "6.0"
 
   s.swift_version = "5.3"
 
   s.subspec 'Core' do |sp|
-    sp.source_files = "Sources/Apexy/*.swift"
+    sp.source_files = "Sources/Apexy/**/*.swift"
   end
 
   s.subspec 'Alamofire' do |sp|
     sp.source_files = "Sources/ApexyAlamofire/*.swift"
     sp.dependency "Apexy/Core"
-    sp.dependency "Alamofire", '~>5.0'
+    sp.dependency "Alamofire", '~>5.6'
   end
 
   s.subspec 'URLSession' do |sp|

Example/Example.xcodeproj/project.pbxproj

@@ -3,7 +3,7 @@
 	archiveVersion = 1;
 	classes = {
 	};
-	objectVersion = 51;
+	objectVersion = 54;
 	objects = {
 
 /* Begin PBXBuildFile section */
@@ -791,7 +791,7 @@
 				CODE_SIGN_STYLE = Automatic;
 				DEVELOPMENT_TEAM = 42LRQS6X44;
 				INFOPLIST_FILE = "Example/Supporting Files/Info.plist";
-				IPHONEOS_DEPLOYMENT_TARGET = 11.0;
+				IPHONEOS_DEPLOYMENT_TARGET = 13.0;
 				LD_RUNPATH_SEARCH_PATHS = (
 					"$(inherited)",
 					"@executable_path/Frameworks",
@@ -812,7 +812,7 @@
 				CODE_SIGN_STYLE = Automatic;
 				DEVELOPMENT_TEAM = 42LRQS6X44;
 				INFOPLIST_FILE = "Example/Supporting Files/Info.plist";
-				IPHONEOS_DEPLOYMENT_TARGET = 11.0;
+				IPHONEOS_DEPLOYMENT_TARGET = 13.0;
 				LD_RUNPATH_SEARCH_PATHS = (
 					"$(inherited)",
 					"@executable_path/Frameworks",

Example/Example/Sources/Business Logic/Service/BookService.swift

@@ -12,29 +12,18 @@ import ExampleAPI
 typealias Book = ExampleAPI.Book
 
 protocol BookService {
-
-    @discardableResult
-    func fetchBooks(completion: @escaping (Result<[Book], Error>) -> Void) -> Progress
-
-    @available(macOS 10.15, iOS 13, watchOS 6, tvOS 13, *)
     func fetchBooks() async throws -> [Book]
 }
 
 
 final class BookServiceImpl: BookService {
 
-    let apiClient: Client
+    let apiClient: ConcurrencyClient
 
-    init(apiClient: Client) {
+    init(apiClient: ConcurrencyClient) {
         self.apiClient = apiClient
     }
 
-    func fetchBooks(completion: @escaping (Result<[Book], Error>) -> Void) -> Progress {
-        let endpoint = BookListEndpoint()
-        return apiClient.request(endpoint, completionHandler: completion)
-    }
-
-    @available(macOS 10.15, iOS 13, watchOS 6, tvOS 13, *)
     func fetchBooks() async throws -> [Book] {
         let endpoint = BookListEndpoint()
         return try await apiClient.request(endpoint)

Example/Example/Sources/Business Logic/Service/FileService.swift

@@ -10,46 +10,24 @@ import Apexy
 import ExampleAPI
 
 protocol FileService {
-
-    @discardableResult
-    func upload(file: URL, completion: @escaping (Result<Void, Error>) -> Void) -> Progress
-
-    @discardableResult
-    func upload(stream: InputStream, size: Int, completion: @escaping (Result<Void, Error>) -> Void) -> Progress
-
-   @available(macOS 10.15, iOS 13, watchOS 6, tvOS 13, *)
     func upload(file: URL) async throws
-
-    @available(macOS 10.15, iOS 13, watchOS 6, tvOS 13, *)
     func upload(stream: InputStream, size: Int) async throws
 }
 
 
 final class FileServiceImpl: FileService {
 
-    let apiClient: Client
+    let apiClient: ConcurrencyClient
 
-    init(apiClient: Client) {
+    init(apiClient: ConcurrencyClient) {
         self.apiClient = apiClient
     }
-
-    func upload(file: URL, completion: @escaping (Result<Void, Error>) -> Void) -> Progress {
-        let endpoint = FileUploadEndpoint(fileURL: file)
-        return apiClient.upload(endpoint, completionHandler: completion)
-    }
-
-    func upload(stream: InputStream, size: Int, completion: @escaping (Result<Void, Error>) -> Void) -> Progress {
-        let endpoint = StreamUploadEndpoint(stream: stream, size: size)
-        return apiClient.upload(endpoint, completionHandler: completion)
-    }
-
-    @available(macOS 10.15, iOS 13, watchOS 6, tvOS 13, *)
+
     func upload(file: URL) async throws {
         let endpoint = FileUploadEndpoint(fileURL: file)
         return try await apiClient.upload(endpoint)
     }
 
-    @available(macOS 10.15, iOS 13, watchOS 6, tvOS 13, *)
     func upload(stream: InputStream, size: Int) async throws {
         let endpoint = StreamUploadEndpoint(stream: stream, size: size)
         return try await apiClient.upload(endpoint)

Example/Example/Sources/Business Logic/ServiceLayer.swift

@@ -15,14 +15,12 @@ final class ServiceLayer {
 
     static let shared = ServiceLayer()
 
-    private(set) lazy var apiClient: Client = {
-        return AlamofireClient(
-            baseURL: URL(string: "https://library.mock-object.redmadserver.com/api/v1/")!,
-            configuration: .ephemeral,
-            responseObserver: { [weak self] request, response, data, error in
-                self?.validateSession(responseError: error)
-            })
-    }()
+    private(set) lazy var apiClient: ConcurrencyClient = AlamofireClient(
+        baseURL: URL(string: "https://library.mock-object.redmadserver.com/api/v1/")!,
+        configuration: .ephemeral,
+        responseObserver: { [weak self] request, response, data, error in
+            self?.validateSession(responseError: error)
+        })
 
     private(set) lazy var bookService: BookService = BookServiceImpl(apiClient: apiClient)
 

Example/Example/Sources/Presentation/ViewController.swift

@@ -30,8 +30,6 @@ class ViewController: UIViewController {
     @IBAction private func performRequest() {
         activityView.isHidden = false
 
-        guard #available(macOS 10.15, iOS 13, watchOS 6, tvOS 13, *) else { performLegacyRequest(); return }
-
         task = Task {
             do {
                 let books = try await bookService.fetchBooks()
@@ -43,25 +41,9 @@ class ViewController: UIViewController {
         }
     }
 
-    private func performLegacyRequest() {
-        progress = bookService.fetchBooks() { [weak self] result in
-            guard let self = self else { return }
-            self.activityView.isHidden = true
-            switch result {
-            case .success(let books):
-                self.show(books: books)
-            case .failure(let error):
-                self.show(error: error)
-            }
-        }
-    }
-
-
     @IBAction private func upload() {
         guard let file = Bundle.main.url(forResource: "Info", withExtension: "plist") else { return }
         activityView.isHidden = false
-
-        guard #available(macOS 10.15, iOS 13, watchOS 6, tvOS 13, *) else { legacyUpload(with: file); return }
 
         task = Task {
             do {
@@ -73,27 +55,12 @@ class ViewController: UIViewController {
             activityView.isHidden = true
         }
     }
-
-    private func legacyUpload(with file: URL) {
-        progress = fileService.upload(file: file) { [weak self] result in
-            guard let self = self else { return }
-            self.activityView.isHidden = true
-            switch result {
-            case .success:
-                self.showOKUpload()
-            case .failure(let error):
-                self.show(error: error)
-            }
-        }
-    }
-
+
     @IBAction private func uploadStream() {
         let streamer = Streamer()
         self.streamer = streamer
         activityView.isHidden = false
 
-        guard #available(macOS 10.15, iOS 13, watchOS 6, tvOS 13, *) else { legacyUploadStream(with: streamer); return }
-
         streamer.run()
 
         task = Task {
@@ -106,30 +73,6 @@ class ViewController: UIViewController {
         }
     }
 
-    private func legacyUploadStream(with streamer: Streamer) {
-        progress = fileService.upload(
-            stream: streamer.boundStreams.input,
-            size: streamer.totalDataSize) { [weak self] result in
-                guard let self = self else { return }
-                self.activityView.isHidden = true
-                switch result {
-                case .success:
-                    self.showOKUpload()
-                case .failure(let error):
-                    self.show(error: error)
-                    self.streamer = nil
-                }
-            }
-        streamer.run()
-
-        observation = progress?.observe(\.fractionCompleted, options: [.new]) { [weak self] (progress, value) in
-            DispatchQueue.main.async {
-                let percent = (value.newValue ?? 0) * 100
-                self?.resultLabel.text = "Progress: \(String(format: "%.0f", percent))%"
-            }
-        }
-    }
-
     @IBAction private func cancel() {
         if #available(macOS 10.15, iOS 13, watchOS 6, tvOS 13, *) {
             (task as? Task<Void, Never>)?.cancel()

Example/Podfile.lock

@@ -1,11 +1,11 @@
 PODS:
-  - Alamofire (5.4.1)
-  - Apexy (1.7.2):
-    - Apexy/Alamofire (= 1.7.2)
-  - Apexy/Alamofire (1.7.2):
-    - Alamofire (~> 5.0)
+  - Alamofire (5.8.1)
+  - Apexy (1.7.4):
+    - Apexy/Alamofire (= 1.7.4)
+  - Apexy/Alamofire (1.7.4):
+    - Alamofire (~> 5.6)
     - Apexy/Core
-  - Apexy/Core (1.7.2)
+  - Apexy/Core (1.7.4)
 
 DEPENDENCIES:
   - Apexy (from `../`)
@@ -19,8 +19,8 @@ EXTERNAL SOURCES:
     :path: "../"
 
 SPEC CHECKSUMS:
-  Alamofire: 2291f7d21ca607c491dd17642e5d40fdcda0e65c
-  Apexy: 984a2c615adf4b5af3432859d768a7a3dec51907
+  Alamofire: 3ca42e259043ee0dc5c0cdd76c4bc568b8e42af7
+  Apexy: a3218097135e746fd7c9215da167521f9275df23
 
 PODFILE CHECKSUM: f86a90e7590ccb3aa7caeceaf315abe256650c66
 

Package.swift

@@ -6,10 +6,10 @@ import PackageDescription
 let package = Package(
     name: "Apexy",
     platforms: [
-      .macOS(.v10_13),
-      .iOS(.v11),
-      .tvOS(.v11),
-      .watchOS(.v4)
+      .macOS(.v10_15),
+      .iOS(.v13),
+      .tvOS(.v13),
+      .watchOS(.v6)
     ],
     products: [
         .library(name: "Apexy", targets: ["ApexyURLSession"]),

README.md

@@ -284,7 +284,7 @@ Split the network layer into folders:
 
 ## Requirements
 
-- iOS 11.0+ / macOS 10.13+ / tvOS 11.0+ / watchOS 4.0+
+- iOS 13.0+ / macOS 10.15+ / tvOS 13.0+ / watchOS 6.0+
 - Xcode 12+
 - Swift 5.3+
 

README.ru.md

@@ -285,7 +285,7 @@ public struct FileUploadEndpoint: UploadEndpoint {
 
 ## Требования
 
-- iOS 11.0+ / macOS 10.13+ / tvOS 11.0+ / watchOS 4.0+
+- iOS 13.0+ / macOS 10.15+ / tvOS 13.0+ / watchOS 6.0+
 - Xcode 12+
 - Swift 5.3+
 

Sources/ApexyURLSession/Helpers/URLSession+Concurrency.swift

@@ -20,7 +20,7 @@ extension URLSession {
     ///    - delegate: Delegate to get events about request (NOT WORKING💀)
     /// - Returns: Tuple with Data and URLResponse
     public func data(
-        for request: URLRequest,
+        forRequest request: URLRequest,
         delegate: URLSessionTaskDelegate? = nil) async throws -> (Data, URLResponse) {
             return try await AsyncAwaitHelper.adaptToAsync(dataTaskClosure: { continuation in
                 let task = dataTask(with: request) { data, response, error in

Sources/ApexyURLSession/URLSessionClient.swift

@@ -18,17 +18,20 @@ open class URLSessionClient: Client, CombineClient {
     /// - Parameters:
     ///   - baseURL: Base `URL`.
     ///   - configuration: The configuration used to construct the managed session.
+    ///   - delegate: The delegate of URLSession.
     ///   - completionQueue: The serial operation queue used to dispatch all completion handlers. `.main` by default.
     ///   - responseObserver: The closure to be called after each response.
     public convenience init(
         baseURL: URL,
         configuration: URLSessionConfiguration = .default,
+        delegate: URLSessionDelegate? = nil,
         completionQueue: DispatchQueue = .main,
         responseObserver: ResponseObserver? = nil) {
 
         self.init(
             requestAdapter: BaseRequestAdapter(baseURL: baseURL),
             configuration: configuration,
+            delegate: delegate,
             completionQueue: completionQueue,
             responseObserver: responseObserver)
     }
@@ -38,16 +41,18 @@ open class URLSessionClient: Client, CombineClient {
     /// - Parameters:
     ///   - requestAdapter: RequestAdapter used to adapt a `URLRequest`.
     ///   - configuration: The configuration used to construct the managed session.
+    ///   - delegate: The delegate of URLSession.
     ///   - completionQueue: The serial operation queue used to dispatch all completion handlers. `.main` by default.
     ///   - responseObserver: The closure to be called after each response.
     public init(
         requestAdapter: RequestAdapter,
         configuration: URLSessionConfiguration = .default,
+        delegate: URLSessionDelegate? = nil,
         completionQueue: DispatchQueue = .main,
         responseObserver: ResponseObserver? = nil) {
 
         self.requestAdapter = requestAdapter
-        self.session = URLSession(configuration: configuration)
+        self.session = URLSession(configuration: configuration, delegate: delegate, delegateQueue: nil)
         self.completionQueue = completionQueue
         self.responseObserver = responseObserver
     }