Remove unused default headers & allow request specific headers

This commit is contained in:
Victor Bodinaud
2024-06-03 13:46:51 +02:00
parent 9e97d9195c
commit aaf8706300

View File

@@ -14,6 +14,11 @@ public enum NetworkError: Error {
case notFound case notFound
} }
public protocol HermesMiddleware {
func processRequest(_ request: inout URLRequest)
func processResponse(_ data: Data?, _ response: URLResponse?, error: Error?)
}
extension NetworkError: LocalizedError { extension NetworkError: LocalizedError {
public var errorDescription: String? { public var errorDescription: String? {
switch self { switch self {
@@ -58,18 +63,21 @@ public struct Resource<T: Codable> {
let url: URL let url: URL
var method: HTTPMethod = .get([]) var method: HTTPMethod = .get([])
var modelType: T.Type var modelType: T.Type
var headers: [String: String]
public init(url: URL, method: HTTPMethod, modelType: T.Type) { public init(url: URL, method: HTTPMethod, modelType: T.Type, headers: [String: String] = [:]) {
self.url = url self.url = url
self.method = method self.method = method
self.modelType = modelType self.modelType = modelType
self.headers = headers
} }
} }
public final class Hermes { public final class Hermes {
public static let shared = Hermes() public static let shared = Hermes()
private var config: HermesConfiguration private var config: HermesConfiguration
private var middlewares: [HermesMiddleware] = []
private init(config: HermesConfiguration = HermesConfiguration()) { private init(config: HermesConfiguration = HermesConfiguration()) {
self.config = config self.config = config
} }
@@ -77,63 +85,87 @@ public final class Hermes {
public func configure(_ config: HermesConfiguration) { public func configure(_ config: HermesConfiguration) {
self.config = config self.config = config
} }
public func addMiddleware(_ middleware: HermesMiddleware) {
middlewares.append(middleware)
}
private var defaultHeaders: [String: String] { private var defaultHeaders: [String: String] {
var headers = ["Content-Type": "application/json"] var headers = [
if let token = UserDefaults.standard.string(forKey: "authToken") { "Content-Type": "application/json",
headers["Authorization"] = "Bearer \(token)" "Accept": "application/json"
} ]
headers.merge(config.defaultHeaders) { (_, new) in new }
headers.merge(config.defaultHeaders) { _, new in new }
return headers return headers
} }
public func load<T: Codable>(_ resource: Resource<T>) async throws -> T { public func load<T: Codable>(_ resource: Resource<T>) async throws -> T {
var request = URLRequest(url: resource.url) var request = URLRequest(url: resource.url)
request.httpMethod = resource.method.name request.httpMethod = resource.method.name
for middleware in middlewares {
middleware.processRequest(&request)
}
switch resource.method { switch resource.method {
case .get(let queryItems): case .get(let queryItems):
if let queryItems = queryItems { if let queryItems = queryItems {
var components = URLComponents(url: resource.url, resolvingAgainstBaseURL: false) var components = URLComponents(url: resource.url, resolvingAgainstBaseURL: false)
components?.queryItems = queryItems components?.queryItems = queryItems
request.url = components?.url request.url = components?.url
} }
case .post(let data), case .post(let data),
.put(let data), .put(let data),
.patch(let data): .patch(let data):
request.httpBody = data request.httpBody = data
case .delete: case .delete:
break break
} }
request.allHTTPHeaderFields = defaultHeaders var headers = defaultHeaders
let configuration = URLSessionConfiguration.default if !resource.headers.isEmpty {
configuration.httpAdditionalHeaders = defaultHeaders headers.merge(resource.headers) { _, new in new }
let session = URLSession(configuration: configuration)
let (data, response) = try await session.data(for: request)
guard let httpResponse = response as? HTTPURLResponse else {
throw NetworkError.invalidResponse
} }
try validate(response: httpResponse) request.allHTTPHeaderFields = headers
let decoder = JSONDecoder() let session = URLSession(configuration: URLSessionConfiguration.default)
decoder.keyDecodingStrategy = config.decodingStrategy
do { do {
return try decoder.decode(resource.modelType, from: data) let (data, response) = try await session.data(for: request)
for middleware in middlewares {
middleware.processResponse(data, response, error: nil)
}
guard let httpResponse = response as? HTTPURLResponse else {
throw NetworkError.invalidResponse
}
try validate(response: httpResponse)
let decoder = JSONDecoder()
decoder.keyDecodingStrategy = config.decodingStrategy
do {
return try decoder.decode(resource.modelType, from: data)
} catch {
throw NetworkError.decodingError
}
} catch { } catch {
throw NetworkError.decodingError for middleware in middlewares {
middleware.processResponse(nil, nil, error: error)
}
throw error
} }
} }
private func validate(response: HTTPURLResponse) throws { private func validate(response: HTTPURLResponse) throws {
switch response.statusCode { switch response.statusCode {
case 200...299: case 200 ... 299:
return return
case 400: case 400:
throw NetworkError.badRequest throw NetworkError.badRequest