123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465 |
- //
- // Alamofire.swift
- //
- // Copyright (c) 2014 Alamofire Software Foundation (http://alamofire.org/)
- //
- // Permission is hereby granted, free of charge, to any person obtaining a copy
- // of this software and associated documentation files (the "Software"), to deal
- // in the Software without restriction, including without limitation the rights
- // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
- // copies of the Software, and to permit persons to whom the Software is
- // furnished to do so, subject to the following conditions:
- //
- // The above copyright notice and this permission notice shall be included in
- // all copies or substantial portions of the Software.
- //
- // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
- // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
- // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
- // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
- // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
- // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
- // THE SOFTWARE.
- //
- import Foundation
- /// Types adopting the `URLConvertible` protocol can be used to construct URLs, which are then used to construct
- /// URL requests.
- public protocol URLConvertible {
- /// Returns a URL that conforms to RFC 2396 or throws an `Error`.
- ///
- /// - throws: An `Error` if the type cannot be converted to a `URL`.
- ///
- /// - returns: A URL or throws an `Error`.
- func asURL() throws -> URL
- }
- extension String: URLConvertible {
- /// Returns a URL if `self` represents a valid URL string that conforms to RFC 2396 or throws an `AFError`.
- ///
- /// - throws: An `AFError.invalidURL` if `self` is not a valid URL string.
- ///
- /// - returns: A URL or throws an `AFError`.
- public func asURL() throws -> URL {
- guard let url = URL(string: self) else { throw AFError.invalidURL(url: self) }
- return url
- }
- }
- extension URL: URLConvertible {
- /// Returns self.
- public func asURL() throws -> URL { return self }
- }
- extension URLComponents: URLConvertible {
- /// Returns a URL if `url` is not nil, otherwise throws an `Error`.
- ///
- /// - throws: An `AFError.invalidURL` if `url` is `nil`.
- ///
- /// - returns: A URL or throws an `AFError`.
- public func asURL() throws -> URL {
- guard let url = url else { throw AFError.invalidURL(url: self) }
- return url
- }
- }
- // MARK: -
- /// Types adopting the `URLRequestConvertible` protocol can be used to construct URL requests.
- public protocol URLRequestConvertible {
- /// Returns a URL request or throws if an `Error` was encountered.
- ///
- /// - throws: An `Error` if the underlying `URLRequest` is `nil`.
- ///
- /// - returns: A URL request.
- func asURLRequest() throws -> URLRequest
- }
- extension URLRequestConvertible {
- /// The URL request.
- public var urlRequest: URLRequest? { return try? asURLRequest() }
- }
- extension URLRequest: URLRequestConvertible {
- /// Returns a URL request or throws if an `Error` was encountered.
- public func asURLRequest() throws -> URLRequest { return self }
- }
- // MARK: -
- extension URLRequest {
- /// Creates an instance with the specified `method`, `urlString` and `headers`.
- ///
- /// - parameter url: The URL.
- /// - parameter method: The HTTP method.
- /// - parameter headers: The HTTP headers. `nil` by default.
- ///
- /// - returns: The new `URLRequest` instance.
- public init(url: URLConvertible, method: HTTPMethod, headers: HTTPHeaders? = nil) throws {
- let url = try url.asURL()
- self.init(url: url)
- httpMethod = method.rawValue
- if let headers = headers {
- for (headerField, headerValue) in headers {
- setValue(headerValue, forHTTPHeaderField: headerField)
- }
- }
- }
- func adapt(using adapter: RequestAdapter?) throws -> URLRequest {
- guard let adapter = adapter else { return self }
- return try adapter.adapt(self)
- }
- }
- // MARK: - Data Request
- /// Creates a `DataRequest` using the default `SessionManager` to retrieve the contents of the specified `url`,
- /// `method`, `parameters`, `encoding` and `headers`.
- ///
- /// - parameter url: The URL.
- /// - parameter method: The HTTP method. `.get` by default.
- /// - parameter parameters: The parameters. `nil` by default.
- /// - parameter encoding: The parameter encoding. `URLEncoding.default` by default.
- /// - parameter headers: The HTTP headers. `nil` by default.
- ///
- /// - returns: The created `DataRequest`.
- @discardableResult
- public func request(
- _ url: URLConvertible,
- method: HTTPMethod = .get,
- parameters: Parameters? = nil,
- encoding: ParameterEncoding = URLEncoding.default,
- headers: HTTPHeaders? = nil)
- -> DataRequest
- {
- return SessionManager.default.request(
- url,
- method: method,
- parameters: parameters,
- encoding: encoding,
- headers: headers
- )
- }
- /// Creates a `DataRequest` using the default `SessionManager` to retrieve the contents of a URL based on the
- /// specified `urlRequest`.
- ///
- /// - parameter urlRequest: The URL request
- ///
- /// - returns: The created `DataRequest`.
- @discardableResult
- public func request(_ urlRequest: URLRequestConvertible) -> DataRequest {
- return SessionManager.default.request(urlRequest)
- }
- // MARK: - Download Request
- // MARK: URL Request
- /// Creates a `DownloadRequest` using the default `SessionManager` to retrieve the contents of the specified `url`,
- /// `method`, `parameters`, `encoding`, `headers` and save them to the `destination`.
- ///
- /// If `destination` is not specified, the contents will remain in the temporary location determined by the
- /// underlying URL session.
- ///
- /// - parameter url: The URL.
- /// - parameter method: The HTTP method. `.get` by default.
- /// - parameter parameters: The parameters. `nil` by default.
- /// - parameter encoding: The parameter encoding. `URLEncoding.default` by default.
- /// - parameter headers: The HTTP headers. `nil` by default.
- /// - parameter destination: The closure used to determine the destination of the downloaded file. `nil` by default.
- ///
- /// - returns: The created `DownloadRequest`.
- @discardableResult
- public func download(
- _ url: URLConvertible,
- method: HTTPMethod = .get,
- parameters: Parameters? = nil,
- encoding: ParameterEncoding = URLEncoding.default,
- headers: HTTPHeaders? = nil,
- to destination: DownloadRequest.DownloadFileDestination? = nil)
- -> DownloadRequest
- {
- return SessionManager.default.download(
- url,
- method: method,
- parameters: parameters,
- encoding: encoding,
- headers: headers,
- to: destination
- )
- }
- /// Creates a `DownloadRequest` using the default `SessionManager` to retrieve the contents of a URL based on the
- /// specified `urlRequest` and save them to the `destination`.
- ///
- /// If `destination` is not specified, the contents will remain in the temporary location determined by the
- /// underlying URL session.
- ///
- /// - parameter urlRequest: The URL request.
- /// - parameter destination: The closure used to determine the destination of the downloaded file. `nil` by default.
- ///
- /// - returns: The created `DownloadRequest`.
- @discardableResult
- public func download(
- _ urlRequest: URLRequestConvertible,
- to destination: DownloadRequest.DownloadFileDestination? = nil)
- -> DownloadRequest
- {
- return SessionManager.default.download(urlRequest, to: destination)
- }
- // MARK: Resume Data
- /// Creates a `DownloadRequest` using the default `SessionManager` from the `resumeData` produced from a
- /// previous request cancellation to retrieve the contents of the original request and save them to the `destination`.
- ///
- /// If `destination` is not specified, the contents will remain in the temporary location determined by the
- /// underlying URL session.
- ///
- /// On the latest release of all the Apple platforms (iOS 10, macOS 10.12, tvOS 10, watchOS 3), `resumeData` is broken
- /// on background URL session configurations. There's an underlying bug in the `resumeData` generation logic where the
- /// data is written incorrectly and will always fail to resume the download. For more information about the bug and
- /// possible workarounds, please refer to the following Stack Overflow post:
- ///
- /// - http://stackoverflow.com/a/39347461/1342462
- ///
- /// - parameter resumeData: The resume data. This is an opaque data blob produced by `URLSessionDownloadTask`
- /// when a task is cancelled. See `URLSession -downloadTask(withResumeData:)` for additional
- /// information.
- /// - parameter destination: The closure used to determine the destination of the downloaded file. `nil` by default.
- ///
- /// - returns: The created `DownloadRequest`.
- @discardableResult
- public func download(
- resumingWith resumeData: Data,
- to destination: DownloadRequest.DownloadFileDestination? = nil)
- -> DownloadRequest
- {
- return SessionManager.default.download(resumingWith: resumeData, to: destination)
- }
- // MARK: - Upload Request
- // MARK: File
- /// Creates an `UploadRequest` using the default `SessionManager` from the specified `url`, `method` and `headers`
- /// for uploading the `file`.
- ///
- /// - parameter file: The file to upload.
- /// - parameter url: The URL.
- /// - parameter method: The HTTP method. `.post` by default.
- /// - parameter headers: The HTTP headers. `nil` by default.
- ///
- /// - returns: The created `UploadRequest`.
- @discardableResult
- public func upload(
- _ fileURL: URL,
- to url: URLConvertible,
- method: HTTPMethod = .post,
- headers: HTTPHeaders? = nil)
- -> UploadRequest
- {
- return SessionManager.default.upload(fileURL, to: url, method: method, headers: headers)
- }
- /// Creates a `UploadRequest` using the default `SessionManager` from the specified `urlRequest` for
- /// uploading the `file`.
- ///
- /// - parameter file: The file to upload.
- /// - parameter urlRequest: The URL request.
- ///
- /// - returns: The created `UploadRequest`.
- @discardableResult
- public func upload(_ fileURL: URL, with urlRequest: URLRequestConvertible) -> UploadRequest {
- return SessionManager.default.upload(fileURL, with: urlRequest)
- }
- // MARK: Data
- /// Creates an `UploadRequest` using the default `SessionManager` from the specified `url`, `method` and `headers`
- /// for uploading the `data`.
- ///
- /// - parameter data: The data to upload.
- /// - parameter url: The URL.
- /// - parameter method: The HTTP method. `.post` by default.
- /// - parameter headers: The HTTP headers. `nil` by default.
- ///
- /// - returns: The created `UploadRequest`.
- @discardableResult
- public func upload(
- _ data: Data,
- to url: URLConvertible,
- method: HTTPMethod = .post,
- headers: HTTPHeaders? = nil)
- -> UploadRequest
- {
- return SessionManager.default.upload(data, to: url, method: method, headers: headers)
- }
- /// Creates an `UploadRequest` using the default `SessionManager` from the specified `urlRequest` for
- /// uploading the `data`.
- ///
- /// - parameter data: The data to upload.
- /// - parameter urlRequest: The URL request.
- ///
- /// - returns: The created `UploadRequest`.
- @discardableResult
- public func upload(_ data: Data, with urlRequest: URLRequestConvertible) -> UploadRequest {
- return SessionManager.default.upload(data, with: urlRequest)
- }
- // MARK: InputStream
- /// Creates an `UploadRequest` using the default `SessionManager` from the specified `url`, `method` and `headers`
- /// for uploading the `stream`.
- ///
- /// - parameter stream: The stream to upload.
- /// - parameter url: The URL.
- /// - parameter method: The HTTP method. `.post` by default.
- /// - parameter headers: The HTTP headers. `nil` by default.
- ///
- /// - returns: The created `UploadRequest`.
- @discardableResult
- public func upload(
- _ stream: InputStream,
- to url: URLConvertible,
- method: HTTPMethod = .post,
- headers: HTTPHeaders? = nil)
- -> UploadRequest
- {
- return SessionManager.default.upload(stream, to: url, method: method, headers: headers)
- }
- /// Creates an `UploadRequest` using the default `SessionManager` from the specified `urlRequest` for
- /// uploading the `stream`.
- ///
- /// - parameter urlRequest: The URL request.
- /// - parameter stream: The stream to upload.
- ///
- /// - returns: The created `UploadRequest`.
- @discardableResult
- public func upload(_ stream: InputStream, with urlRequest: URLRequestConvertible) -> UploadRequest {
- return SessionManager.default.upload(stream, with: urlRequest)
- }
- // MARK: MultipartFormData
- /// Encodes `multipartFormData` using `encodingMemoryThreshold` with the default `SessionManager` and calls
- /// `encodingCompletion` with new `UploadRequest` using the `url`, `method` and `headers`.
- ///
- /// It is important to understand the memory implications of uploading `MultipartFormData`. If the cummulative
- /// payload is small, encoding the data in-memory and directly uploading to a server is the by far the most
- /// efficient approach. However, if the payload is too large, encoding the data in-memory could cause your app to
- /// be terminated. Larger payloads must first be written to disk using input and output streams to keep the memory
- /// footprint low, then the data can be uploaded as a stream from the resulting file. Streaming from disk MUST be
- /// used for larger payloads such as video content.
- ///
- /// The `encodingMemoryThreshold` parameter allows Alamofire to automatically determine whether to encode in-memory
- /// or stream from disk. If the content length of the `MultipartFormData` is below the `encodingMemoryThreshold`,
- /// encoding takes place in-memory. If the content length exceeds the threshold, the data is streamed to disk
- /// during the encoding process. Then the result is uploaded as data or as a stream depending on which encoding
- /// technique was used.
- ///
- /// - parameter multipartFormData: The closure used to append body parts to the `MultipartFormData`.
- /// - parameter encodingMemoryThreshold: The encoding memory threshold in bytes.
- /// `multipartFormDataEncodingMemoryThreshold` by default.
- /// - parameter url: The URL.
- /// - parameter method: The HTTP method. `.post` by default.
- /// - parameter headers: The HTTP headers. `nil` by default.
- /// - parameter encodingCompletion: The closure called when the `MultipartFormData` encoding is complete.
- public func upload(
- multipartFormData: @escaping (MultipartFormData) -> Void,
- usingThreshold encodingMemoryThreshold: UInt64 = SessionManager.multipartFormDataEncodingMemoryThreshold,
- to url: URLConvertible,
- method: HTTPMethod = .post,
- headers: HTTPHeaders? = nil,
- encodingCompletion: ((SessionManager.MultipartFormDataEncodingResult) -> Void)?)
- {
- return SessionManager.default.upload(
- multipartFormData: multipartFormData,
- usingThreshold: encodingMemoryThreshold,
- to: url,
- method: method,
- headers: headers,
- encodingCompletion: encodingCompletion
- )
- }
- /// Encodes `multipartFormData` using `encodingMemoryThreshold` and the default `SessionManager` and
- /// calls `encodingCompletion` with new `UploadRequest` using the `urlRequest`.
- ///
- /// It is important to understand the memory implications of uploading `MultipartFormData`. If the cummulative
- /// payload is small, encoding the data in-memory and directly uploading to a server is the by far the most
- /// efficient approach. However, if the payload is too large, encoding the data in-memory could cause your app to
- /// be terminated. Larger payloads must first be written to disk using input and output streams to keep the memory
- /// footprint low, then the data can be uploaded as a stream from the resulting file. Streaming from disk MUST be
- /// used for larger payloads such as video content.
- ///
- /// The `encodingMemoryThreshold` parameter allows Alamofire to automatically determine whether to encode in-memory
- /// or stream from disk. If the content length of the `MultipartFormData` is below the `encodingMemoryThreshold`,
- /// encoding takes place in-memory. If the content length exceeds the threshold, the data is streamed to disk
- /// during the encoding process. Then the result is uploaded as data or as a stream depending on which encoding
- /// technique was used.
- ///
- /// - parameter multipartFormData: The closure used to append body parts to the `MultipartFormData`.
- /// - parameter encodingMemoryThreshold: The encoding memory threshold in bytes.
- /// `multipartFormDataEncodingMemoryThreshold` by default.
- /// - parameter urlRequest: The URL request.
- /// - parameter encodingCompletion: The closure called when the `MultipartFormData` encoding is complete.
- public func upload(
- multipartFormData: @escaping (MultipartFormData) -> Void,
- usingThreshold encodingMemoryThreshold: UInt64 = SessionManager.multipartFormDataEncodingMemoryThreshold,
- with urlRequest: URLRequestConvertible,
- encodingCompletion: ((SessionManager.MultipartFormDataEncodingResult) -> Void)?)
- {
- return SessionManager.default.upload(
- multipartFormData: multipartFormData,
- usingThreshold: encodingMemoryThreshold,
- with: urlRequest,
- encodingCompletion: encodingCompletion
- )
- }
- #if !os(watchOS)
- // MARK: - Stream Request
- // MARK: Hostname and Port
- /// Creates a `StreamRequest` using the default `SessionManager` for bidirectional streaming with the `hostname`
- /// and `port`.
- ///
- /// If `startRequestsImmediately` is `true`, the request will have `resume()` called before being returned.
- ///
- /// - parameter hostName: The hostname of the server to connect to.
- /// - parameter port: The port of the server to connect to.
- ///
- /// - returns: The created `StreamRequest`.
- @discardableResult
- @available(iOS 9.0, macOS 10.11, tvOS 9.0, *)
- public func stream(withHostName hostName: String, port: Int) -> StreamRequest {
- return SessionManager.default.stream(withHostName: hostName, port: port)
- }
- // MARK: NetService
- /// Creates a `StreamRequest` using the default `SessionManager` for bidirectional streaming with the `netService`.
- ///
- /// If `startRequestsImmediately` is `true`, the request will have `resume()` called before being returned.
- ///
- /// - parameter netService: The net service used to identify the endpoint.
- ///
- /// - returns: The created `StreamRequest`.
- @discardableResult
- @available(iOS 9.0, macOS 10.11, tvOS 9.0, *)
- public func stream(with netService: NetService) -> StreamRequest {
- return SessionManager.default.stream(with: netService)
- }
- #endif
|