Class: Faraday::Request::Multipart
- Inherits:
-
UrlEncoded
- Object
- Middleware
- UrlEncoded
- Faraday::Request::Multipart
- Defined in:
- lib/faraday/request/multipart.rb
Overview
Middleware for supporting multi-part requests.
Constant Summary collapse
- DEFAULT_BOUNDARY_PREFIX =
'-----------RubyMultipartPost'
Constants inherited from UrlEncoded
Instance Attribute Summary
Attributes included from DependencyLoader
Instance Method Summary collapse
-
#call(env) ⇒ Object
Checks for files in the payload, otherwise leaves everything untouched.
- #create_multipart(env, params) ⇒ Object
-
#has_multipart?(obj) ⇒ Boolean
Returns true if obj is an enumerable with values that are multipart.
- #part(boundary, key, value) ⇒ Object
- #process_params(params, prefix = nil, pieces = nil, &block) ⇒ Object
- #process_request?(env) ⇒ Boolean
- #unique_boundary ⇒ String
Methods inherited from UrlEncoded
#match_content_type, #request_type
Methods inherited from Middleware
Methods included from MiddlewareRegistry
#fetch_middleware, #load_middleware, #lookup_middleware, #middleware_mutex, #register_middleware, #unregister_middleware
Methods included from DependencyLoader
#dependency, #inherited, #loaded?, #new
Constructor Details
This class inherits a constructor from Faraday::Middleware
Instance Method Details
#call(env) ⇒ Object
Checks for files in the payload, otherwise leaves everything untouched.
18 19 20 21 22 23 24 25 26 |
# File 'lib/faraday/request/multipart.rb', line 18 def call(env) match_content_type(env) do |params| env.request.boundary ||= unique_boundary env.request_headers[CONTENT_TYPE] += "; boundary=#{env.request.boundary}" env.body = create_multipart(env, params) end @app.call env end |
#create_multipart(env, params) ⇒ Object
52 53 54 55 56 57 58 59 60 61 62 |
# File 'lib/faraday/request/multipart.rb', line 52 def create_multipart(env, params) boundary = env.request.boundary parts = process_params(params) do |key, value| part(boundary, key, value) end parts << Faraday::Parts::EpiloguePart.new(boundary) body = Faraday::CompositeReadIO.new(parts) env.request_headers[Faraday::Env::ContentLength] = body.length.to_s body end |
#has_multipart?(obj) ⇒ Boolean
Returns true if obj is an enumerable with values that are multipart.
41 42 43 44 45 46 47 48 |
# File 'lib/faraday/request/multipart.rb', line 41 def has_multipart?(obj) # rubocop:disable Naming/PredicateName if obj.respond_to?(:each) (obj.respond_to?(:values) ? obj.values : obj).each do |val| return true if val.respond_to?(:content_type) || has_multipart?(val) end end false end |
#part(boundary, key, value) ⇒ Object
64 65 66 67 68 69 70 |
# File 'lib/faraday/request/multipart.rb', line 64 def part(boundary, key, value) if value.respond_to?(:to_part) value.to_part(boundary, key) else Faraday::Parts::Part.new(boundary, key, value) end end |
#process_params(params, prefix = nil, pieces = nil, &block) ⇒ Object
80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 |
# File 'lib/faraday/request/multipart.rb', line 80 def process_params(params, prefix = nil, pieces = nil, &block) params.inject(pieces || []) do |all, (key, value)| key = "#{prefix}[#{key}]" if prefix case value when Array values = value.inject([]) { |a, v| a << [nil, v] } process_params(values, key, all, &block) when Hash process_params(value, key, all, &block) else # rubocop:disable Performance/RedundantBlockCall all << block.call(key, value) # rubocop:enable Performance/RedundantBlockCall end end end |
#process_request?(env) ⇒ Boolean
29 30 31 32 33 34 35 |
# File 'lib/faraday/request/multipart.rb', line 29 def process_request?(env) type = request_type(env) env.body.respond_to?(:each_key) && !env.body.empty? && ( (type.empty? && has_multipart?(env.body)) || (type == self.class.mime_type) ) end |
#unique_boundary ⇒ String
73 74 75 |
# File 'lib/faraday/request/multipart.rb', line 73 def unique_boundary "#{DEFAULT_BOUNDARY_PREFIX}-#{SecureRandom.hex}" end |