MultipartUpload.swift 3.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889
  1. //
  2. // MultipartUpload.swift
  3. //
  4. // Copyright (c) 2014-2018 Alamofire Software Foundation (http://alamofire.org/)
  5. //
  6. // Permission is hereby granted, free of charge, to any person obtaining a copy
  7. // of this software and associated documentation files (the "Software"), to deal
  8. // in the Software without restriction, including without limitation the rights
  9. // to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
  10. // copies of the Software, and to permit persons to whom the Software is
  11. // furnished to do so, subject to the following conditions:
  12. //
  13. // The above copyright notice and this permission notice shall be included in
  14. // all copies or substantial portions of the Software.
  15. //
  16. // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  17. // IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  18. // FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
  19. // AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  20. // LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  21. // OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
  22. // THE SOFTWARE.
  23. //
  24. import Foundation
  25. /// Internal type which encapsulates a `MultipartFormData` upload.
  26. final class MultipartUpload {
  27. lazy var result = Result { try build() }
  28. private let multipartFormData: Protected<MultipartFormData>
  29. let encodingMemoryThreshold: UInt64
  30. let request: URLRequestConvertible
  31. let fileManager: FileManager
  32. init(encodingMemoryThreshold: UInt64,
  33. request: URLRequestConvertible,
  34. multipartFormData: MultipartFormData) {
  35. self.encodingMemoryThreshold = encodingMemoryThreshold
  36. self.request = request
  37. fileManager = multipartFormData.fileManager
  38. self.multipartFormData = Protected(multipartFormData)
  39. }
  40. func build() throws -> UploadRequest.Uploadable {
  41. let uploadable: UploadRequest.Uploadable
  42. if multipartFormData.contentLength < encodingMemoryThreshold {
  43. let data = try multipartFormData.read { try $0.encode() }
  44. uploadable = .data(data)
  45. } else {
  46. let tempDirectoryURL = fileManager.temporaryDirectory
  47. let directoryURL = tempDirectoryURL.appendingPathComponent("org.alamofire.manager/multipart.form.data")
  48. let fileName = UUID().uuidString
  49. let fileURL = directoryURL.appendingPathComponent(fileName)
  50. try fileManager.createDirectory(at: directoryURL, withIntermediateDirectories: true, attributes: nil)
  51. do {
  52. try multipartFormData.read { try $0.writeEncodedData(to: fileURL) }
  53. } catch {
  54. // Cleanup after attempted write if it fails.
  55. try? fileManager.removeItem(at: fileURL)
  56. throw error
  57. }
  58. uploadable = .file(fileURL, shouldRemove: true)
  59. }
  60. return uploadable
  61. }
  62. }
  63. extension MultipartUpload: UploadConvertible {
  64. func asURLRequest() throws -> URLRequest {
  65. var urlRequest = try request.asURLRequest()
  66. multipartFormData.read { multipartFormData in
  67. urlRequest.headers.add(.contentType(multipartFormData.contentType))
  68. }
  69. return urlRequest
  70. }
  71. func createUploadable() throws -> UploadRequest.Uploadable {
  72. try result.get()
  73. }
  74. }