Sha256: e06d3ea59a8f3f6d75c3848283f9932e81ea2f4c6d98fe9a5d3098d14d3133a7
Contents?: true
Size: 1.92 KB
Versions: 22
Compression:
Stored size: 1.92 KB
Contents
# frozen_string_literal: true
module Valkyrie::Persistence::Postgres
# Responsible for converting a {Valkyrie::Resource} into a
# {Valkyrie::Persistence::Postgres::ORM::Resource}
class ResourceConverter
delegate :orm_class, to: :resource_factory
attr_reader :resource, :resource_factory
# @param [Valkyrie::Resource] resource
# @param [ResourceFactory] resource_factory
def initialize(resource, resource_factory:)
@resource = resource
@resource_factory = resource_factory
end
# Converts the Valkyrie Resource into an ActiveRecord object
# @return [ORM::Resource]
def convert!
orm_class.find_or_initialize_by(id: resource.id && resource.id.to_s).tap do |orm_object|
orm_object.internal_resource = resource.internal_resource
process_lock_token(orm_object)
orm_object.disable_optimistic_locking! unless resource.optimistic_locking_enabled?
orm_object.metadata = attributes
end
end
# Retrieves the optimistic lock token from the Valkyrie attribute value and
# sets it to the lock_version on ORM resource
# @see https://api.rubyonrails.org/classes/ActiveRecord/Locking/Optimistic.html
# @param [ORM::Resource] orm_object
def process_lock_token(orm_object)
return unless resource.respond_to?(Valkyrie::Persistence::Attributes::OPTIMISTIC_LOCK)
postgres_token = resource[Valkyrie::Persistence::Attributes::OPTIMISTIC_LOCK].find do |token|
token.adapter_id == resource_factory.adapter_id
end
return unless postgres_token
orm_object.lock_version = postgres_token.token
end
# Convert attributes to all be arrays to better enable querying and
# "changing of minds" later on.
# @return [Hash]
def attributes
Hash[
resource.attributes.except(:id, :internal_resource, :created_at, :updated_at).compact.map do |k, v|
[k, Array.wrap(v)]
end
]
end
end
end
Version data entries
22 entries across 22 versions & 1 rubygems