/
HttpClient.swift
110 lines (94 loc) · 4.13 KB
/
HttpClient.swift
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
//
// HttpClient.swift
// Anemone SDK
//
// Created by Angel Garcia on 20/12/2016.
// Copyright © 2016 Syltek Solutions S.L. All rights reserved.
//
import Foundation
import UIKit
public class HttpClient: IHttpClient {
let urlSession: URLSession
let baseUrl: String
let urlEncoder: IHttpParameterEncoder
let bodyEncoders: [IHttpParameterEncoder]
public init(baseUrl: String,
timeOut: TimeInterval? = nil,
urlSession: URLSession? = nil,
urlEncoder: IHttpParameterEncoder = HttpUrlParameterEncoder(),
bodyEncoders: [IHttpParameterEncoder] = [HttpJsonParameterEncoder(), HttpUrlParameterEncoder()]) {
self.baseUrl = baseUrl
self.urlSession = urlSession ?? URLSession(configuration: URLSessionConfiguration.default)
if let timeOut = timeOut {
self.urlSession.configuration.timeoutIntervalForRequest = timeOut
}
self.urlEncoder = urlEncoder
self.bodyEncoders = bodyEncoders
}
public func request(_ httpRequest: HttpRequest) -> Promise<HttpResponse> {
var urlString = hasScheme(httpRequest.url) ? httpRequest.url : "\(baseUrl)\(httpRequest.url)"
var body: Data? = nil
do {
body = try buildRequestBody(httpRequest)
try buildRequestQuery(httpRequest).let {
urlString += "?\($0)"
}
} catch {
return Promise(error: AnemoneException.jsonInvalidFormat)
}
guard let url = URL(string: urlString) else {
return Promise(error: AnemoneException.wrongUrl)
}
var request = URLRequest(url: url)
request.httpMethod = httpRequest.method.rawValue
request.httpBody = body
request.setValue(encoderForType(httpRequest.contentType)?.contentType, forHTTPHeaderField: "Content-Type")
httpRequest.headers?.forEach { request.setValue($0.value, forHTTPHeaderField: $0.key) }
return Promise { fulfill, reject in
let task = self.urlSession.dataTask(with: request) { (data: Data?, response: URLResponse?, error: Error?) in
let httpResponse = HttpResponse(request: httpRequest, response: response, body: data)
if error == nil && httpResponse.isSuccessful {
fulfill(httpResponse)
} else {
var serverMessage: Message? = nil
if let data = data {
serverMessage = self.getErrorMessage(data: data)
}
reject(AnemoneException.network(response: httpResponse, error: error, serverMessage: serverMessage))
}
}
task.resume()
}
}
func buildRequestQuery(_ request: HttpRequest) throws -> String? {
guard let params = request.queryParams else { return nil }
return try urlEncoder.stringEncode(params)
}
func buildRequestBody(_ request: HttpRequest) throws -> Data? {
guard request.method != .get && request.method != .delete else { return nil }
guard let params = request.bodyParams else { return nil }
guard let encoder = encoderForType(request.contentType) else {
throw AnemoneException.jsonInvalidFormat
}
return try encoder.dataEncode(params)
}
func getErrorMessage(data: Data) -> Message? {
return JSONTransformer().transform(data: data)
}
func hasScheme(_ endpoint: String) -> Bool {
return endpoint.hasPrefix("http://") || endpoint.hasPrefix("https://")
}
func encoderForType(_ type: String?) -> IHttpParameterEncoder? {
guard let type = type else { return bodyEncoders.first }
return bodyEncoders.filter { $0.contentType.starts(with: type) }.first
}
}
extension HttpResponse {
fileprivate init(request: HttpRequest, response: URLResponse?, body: Data?) {
let httpResponse = response as? HTTPURLResponse
self.init(request: request,
headers: httpResponse?.allHeaderFields as? [String : String] ?? [:],
code: httpResponse?.statusCode ?? 0,
body: body ?? Data())
}
}