Sha256: 0b80ec7d8d684d2fa21dcd5fd70018be332a94000da0d5ff5d269c82c329af1d
Contents?: true
Size: 1.98 KB
Versions: 6
Compression:
Stored size: 1.98 KB
Contents
# frozen_string_literal: true
require 'active_support'
class LHS::Item < LHS::Proxy
module Save
extend ActiveSupport::Concern
def save(options = nil)
save!(options)
rescue LHC::Error
false
end
def save!(options = {})
options = options.present? ? options.dup : {}
data = _data._raw.dup
url = url_for_persistance!(options, data)
create_and_merge_data!(
apply_default_creation_options(options, url, data)
)
rescue LHC::Error => e
self.errors = LHS::Problems::Errors.new(e.response, record)
raise e
end
private
def apply_default_creation_options(options, url, data)
options = options.merge(method: :post, url: url, body: data)
options[:headers] ||= {}
options
end
def create_and_merge_data!(options)
direct_response_data = record.request(options)
_data.merge_raw!(direct_response_data.unwrap(:item_created_key))
response_headers = direct_response_data._request.response.headers
if response_headers && response_headers['Location']
location_data = record.request(options.merge(url: response_headers['Location'], method: :get, body: nil))
_data.merge_raw!(location_data.unwrap(:item_created_key))
end
true
end
def endpoint_for_persistance(data, options)
record.find_endpoint(merge_data_with_options(data, options))
end
def merge_data_with_options(data, options)
if options && options[:params]
data.merge(options[:params])
else
data
end
end
def url_for_persistance!(options, data)
return href if href.present?
endpoint = endpoint_for_persistance(data, options)
endpoint.compile(
merge_data_with_options(data, options)
).tap do
endpoint.remove_interpolated_params!(data)
endpoint.remove_interpolated_params!(options.fetch(:params, {}))
options.merge!(endpoint.options.merge(options)) if endpoint.options
end
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems