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. @Protected
  29. private(set) var multipartFormData: MultipartFormData
  30. let encodingMemoryThreshold: UInt64
  31. let request: URLRequestConvertible
  32. let fileManager: FileManager
  33. init(encodingMemoryThreshold: UInt64,
  34. request: URLRequestConvertible,
  35. multipartFormData: MultipartFormData) {
  36. self.encodingMemoryThreshold = encodingMemoryThreshold
  37. self.request = request
  38. fileManager = multipartFormData.fileManager
  39. self.multipartFormData = multipartFormData
  40. }
  41. func build() throws -> UploadRequest.Uploadable {
  42. let uploadable: UploadRequest.Uploadable
  43. if $multipartFormData.contentLength < encodingMemoryThreshold {
  44. let data = try $multipartFormData.read { try $0.encode() }
  45. uploadable = .data(data)
  46. } else {
  47. let tempDirectoryURL = fileManager.temporaryDirectory
  48. let directoryURL = tempDirectoryURL.appendingPathComponent("org.alamofire.manager/multipart.form.data")
  49. let fileName = UUID().uuidString
  50. let fileURL = directoryURL.appendingPathComponent(fileName)
  51. try fileManager.createDirectory(at: directoryURL, withIntermediateDirectories: true, attributes: nil)
  52. do {
  53. try $multipartFormData.read { try $0.writeEncodedData(to: fileURL) }
  54. } catch {
  55. // Cleanup after attempted write if it fails.
  56. try? fileManager.removeItem(at: fileURL)
  57. throw error
  58. }
  59. uploadable = .file(fileURL, shouldRemove: true)
  60. }
  61. return uploadable
  62. }
  63. }
  64. extension MultipartUpload: UploadConvertible {
  65. func asURLRequest() throws -> URLRequest {
  66. var urlRequest = try request.asURLRequest()
  67. $multipartFormData.read { multipartFormData in
  68. urlRequest.headers.add(.contentType(multipartFormData.contentType))
  69. }
  70. return urlRequest
  71. }
  72. func createUploadable() throws -> UploadRequest.Uploadable {
  73. try result.get()
  74. }
  75. }