release-2.3.0

Author: maksimn

Source/Array+Core.swift

@@ -15,3 +15,18 @@ extension Array {
         return self[index]
     }
 }
+
+extension Array where Element: Hashable {
+
+    public func removingDuplicates() -> [Element] {
+        var addedDict = [Element: Bool]()
+
+        return filter {
+            addedDict.updateValue(true, forKey: $0) == nil
+        }
+    }
+
+    public mutating func removeDuplicates() {
+        self = self.removingDuplicates()
+    }
+}

Source/Networking/HttpClient.swift

@@ -1,5 +1,5 @@
 //
-//  CoreService.swift
+//  HttpClient.swift
 //  PersonalDictionary
 //
 //  Created by Maxim Ivanov on 09.10.2021.

Source/Networking/HttpClientAdapter.swift

@@ -0,0 +1,23 @@
+//
+//  HttpClientAdapter.swift
+//  CoreModule
+//
+//  Created by Maxim Ivanov on 21.05.2023.
+//
+
+import Foundation
+
+public struct HttpResponseResult {
+    public let response: HTTPURLResponse
+    public let data: Data
+
+    public init(response: HTTPURLResponse, data: Data) {
+        self.response = response
+        self.data = data
+    }
+}
+
+public protocol HttpClientAdapter {
+
+    func send(_ http: Http) async throws -> HttpResponseResult
+}

Source/Networking/HttpClientAdapterImpl.swift

@@ -0,0 +1,40 @@
+//
+//  HttpClientAdapter.swift
+//  CoreModule
+//
+//  Created by Maxim Ivanov on 21.05.2023.
+//
+
+import Combine
+
+public final class HttpClientAdapterImpl: HttpClientAdapter {
+
+    private let httpClient: HttpClient
+
+    private var cancellables: Set<AnyCancellable> = []
+
+    public init(httpClient: HttpClient = LoggableHttpClient(logger: LoggerImpl(category: "HTTP"))) {
+        self.httpClient = httpClient
+    }
+
+    public func send(_ http: Http) async throws -> HttpResponseResult {
+        try await withCheckedThrowingContinuation { continuation in
+            httpClient.send(http)
+                .sink(
+                    receiveCompletion: { completion in
+                        switch completion {
+                        case .failure(let error):
+                            continuation.resume(throwing: error)
+                        case .finished:
+                            break
+                        }
+                    },
+                    receiveValue: { httpResponse in
+                        continuation.resume(
+                            returning: HttpResponseResult(response: httpResponse.response, data: httpResponse.data)
+                        )
+                    }
+                ).store(in: &self.cancellables)
+        }
+    }
+}