Sha256: 35fba6669043baef3a4e94f8a32222372ac5339d7bfd89482fcec696a5273ecb
Contents?: true
Size: 1.81 KB
Versions: 6
Compression:
Stored size: 1.81 KB
Contents
require 'faraday'
module CMIS
class Connection
class RequestModifier < Faraday::Middleware
def call(env)
if env[:body]
env[:body].reject! { |_, v| v.nil? }
wrap_content(env)
massage_properties(env)
end
@app.call(env)
end
private
def wrap_content(env)
if content_hash = env[:body][:content]
env[:body][:content] = Faraday::UploadIO.new(content_hash[:stream],
content_hash[:mime_type],
content_hash[:filename])
end
end
def massage_properties(env)
if props = env[:body].delete(:properties)
props.each_with_index do |(id, value), index|
if value.is_a?(Array)
env[:body][id_key(index)] = id
value.each_with_index do |sub_value, sub_index|
env[:body][val_key(index, sub_index)] = normalize(sub_value)
end
else
env[:body][id_key(index)] = id
env[:body][val_key(index)] = normalize(value)
end
end
end
if tuples = env[:body].delete(:objectIdAndChangeToken)
tuples.each_with_index do |(object_id, change_token), index|
env[:body]["objectId[#{index}]"] = object_id
env[:body]["changeToken[#{index}]"] = change_token
end
end
end
def normalize(v)
v = Time.utc(v.year, v.month, v.day) if v.is_a?(Date)
v = (v.to_f * 1000).to_i if v.is_a?(Time)
v
end
def id_key(index)
"propertyId[#{index}]"
end
def val_key(i1, i2 = nil)
result = "propertyValue[#{i1}]"
result = "#{result}[#{i2}]" if i2
result
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems