2 # Subclasses Struct with some special helpers for converting from a Hash to
7 value ? new.update(value) : new
12 return to_enum(:each) unless block_given?
14 yield(key.to_sym, send(key))
20 obj.each do |key, value|
21 if sub_options = self.class.options_for(key)
22 value = sub_options.from(value) if value
25 value.each do |hash_key, hash_value|
26 hash[hash_key] = hash_value
31 self.send("#{key}=", value) unless value.nil?
47 members.each { |member| delete(member) }
57 unless symbolized_key_set.include?(key.to_sym)
58 key_setter = "#{key}="
60 send(key_setter, args.first)
62 send(key_setter, Proc.new.call(key))
64 raise self.class.fetch_error_class, "key not found: #{key.inspect}"
72 keys.map { |key| send(key) }
77 members.reject { |member| send(member).nil? }
87 return to_enum(:each_key) unless block_given?
102 return to_enum(:each_value) unless block_given?
103 values.each do |value|
110 values.include?(value)
113 alias has_value? value?
118 members.each do |key|
120 hash[key.to_sym] = value unless value.nil?
128 members.each do |member|
130 values << "#{member}=#{value.inspect}" if value
132 values = values.empty? ? ' (empty)' : (' ' << values.join(", "))
134 %(#<#{self.class}#{values}>)
138 def self.options(mapping)
139 attribute_options.update(mapping)
143 def self.options_for(key)
144 attribute_options[key]
148 def self.attribute_options
149 @attribute_options ||= {}
152 def self.memoized(key)
153 memoized_attributes[key.to_sym] = Proc.new
154 class_eval <<-RUBY, __FILE__, __LINE__ + 1
155 def #{key}() self[:#{key}]; end
159 def self.memoized_attributes
160 @memoized_attributes ||= {}
165 if method = self.class.memoized_attributes[key]
166 super(key) || (self[key] = instance_eval(&method))
172 def symbolized_key_set
173 @symbolized_key_set ||= Set.new(keys.map { |k| k.to_sym })
176 def self.inherited(subclass)
178 subclass.attribute_options.update(attribute_options)
179 subclass.memoized_attributes.update(memoized_attributes)
182 def self.fetch_error_class
183 @fetch_error_class ||= if Object.const_defined?(:KeyError)
191 class RequestOptions < Options.new(:params_encoder, :proxy, :bind,
192 :timeout, :open_timeout, :boundary,
196 if key && key.to_sym == :proxy
197 super(key, value ? ProxyOptions.from(value) : nil)
204 class SSLOptions < Options.new(:verify, :ca_file, :ca_path, :verify_mode,
205 :cert_store, :client_cert, :client_key, :certificate, :private_key, :verify_depth, :version)
216 class ProxyOptions < Options.new(:uri, :user, :password)
218 def_delegators :uri, :scheme, :scheme=, :host, :host=, :port, :port=, :path, :path=
223 value = {:uri => Utils.URI(value)}
225 value = {:uri => value}
227 if uri = value.delete(:uri)
228 value[:uri] = Utils.URI(uri)
234 memoized(:user) { uri.user && Utils.unescape(uri.user) }
235 memoized(:password) { uri.password && Utils.unescape(uri.password) }
238 class ConnectionOptions < Options.new(:request, :proxy, :ssl, :builder, :url,
239 :parallel_manager, :params, :headers, :builder_class)
241 options :request => RequestOptions, :ssl => SSLOptions
243 memoized(:request) { self.class.options_for(:request).new }
245 memoized(:ssl) { self.class.options_for(:ssl).new }
247 memoized(:builder_class) { RackBuilder }
249 def new_builder(block)
250 builder_class.new(&block)
254 class Env < Options.new(:method, :body, :url, :request, :request_headers,
255 :ssl, :parallel_manager, :params, :response, :response_headers, :status)
257 ContentLength = 'Content-Length'.freeze
258 StatusesWithoutBody = Set.new [204, 304]
259 SuccessfulStatuses = 200..299
261 # A Set of HTTP verbs that typically send a body. If no body is set for
262 # these requests, the Content-Length header is set to 0.
263 MethodsWithBodies = Set.new [:post, :put, :patch, :options]
265 options :request => RequestOptions,
266 :request_headers => Utils::Headers, :response_headers => Utils::Headers
270 def_delegators :request, :params_encoder
274 if in_member_set?(key)
283 if in_member_set?(key)
286 custom_members[key] = value
292 SuccessfulStatuses.include?(status)
297 !body && MethodsWithBodies.include?(method)
302 request_headers[ContentLength] = '0'
308 !StatusesWithoutBody.include?(status)
318 members.each do |mem|
320 attrs << "@#{mem}=#{value.inspect}"
323 if !custom_members.empty?
324 attrs << "@custom=#{custom_members.inspect}"
326 %(#<#{self.class}#{attrs.join(" ")}>)
331 @custom_members ||= {}
335 if members.first.is_a?(Symbol)
336 def in_member_set?(key)
337 self.class.member_set.include?(key.to_sym)
340 def in_member_set?(key)
341 self.class.member_set.include?(key.to_s)
347 @member_set ||= Set.new(members)