Class: IiifPrint::PersistenceLayer::ValkyrieAdapter

Inherits:
AbstractAdapter show all
Defined in:
lib/iiif_print/persistence_layer/valkyrie_adapter.rb

Class Method Summary collapse

Methods inherited from AbstractAdapter

solr_field_query

Class Method Details

.clean_for_tests! ⇒ Object

Raises:

  • (NotImplementedError) 


70
71
72
73
74
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 70

def self.clean_for_tests!
  # For Fedora backed repositories, we'll want to consider some cleaning mechanism.  For
  # database backed repositories, we can rely on the database_cleaner gem.
  raise NotImplementedError
end

.copy_derivatives_from_data_store(stream:, directives:) ⇒ TrueClass

Performs an extra step to create the Hyrax::Metadata objects for derivatives.

Parameters:

  • []

Returns:

  • (TrueClass) 


192
193
194
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 192

def self.copy_derivatives_from_data_store(stream:, directives:)
  Hyrax::ValkyriePersistDerivatives.call(stream, directives)
end

.create_relationship_between(child_record:, parent_record:) ⇒ TrueClass

Add a child record as a member of a parent record

Parameters:

  • model (child_record) —

    a Valkyrie::Resource model

  • model (parent_record) —

    a Valkyrie::Resource model

Returns:

  • (TrueClass) 


131
132
133
134
135
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 131

def self.create_relationship_between(child_record:, parent_record:)
  return true if parent_record.member_ids.include?(child_record.id)
  parent_record.member_ids << child_record.id
  true
end

.decorate_form_with_adapter_logic(work_type:) ⇒ Object

Returns form for the given :work_type.

Parameters:

  • work_type (Class<ActiveFedora::Base>)

Returns:

  • form for the given :work_type



36
37
38
39
40
41
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 36

def self.decorate_form_with_adapter_logic(work_type:)
  form = "#{work_type}Form".constantize
  form.send(:include, Hyrax::FormFields(:child_works_from_pdf_splitting)) unless
    Hyrax.config.try(:work_include_metadata?) || Hyrax.config.try(:flexible?) || form.included_modules.include?(Hyrax::FormFields(:child_works_from_pdf_splitting))
  form
end

.decorate_with_adapter_logic(work_type:) ⇒ Object

Returns the indexer for the given :work_type.

Parameters:

  • work_type (Class<Valkyrie::Resource>)

Returns:

  • the indexer for the given :work_type



23
24
25
26
27
28
29
30
31
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 23

def self.decorate_with_adapter_logic(work_type:)
  work_type.send(:include, Hyrax::Schema(:child_works_from_pdf_splitting)) unless
    Hyrax.config.try(:work_include_metadata?) || Hyrax.config.try(:flexible?) || work_type.included_modules.include?(Hyrax::Schema(:child_works_from_pdf_splitting))
  # TODO: Use `Hyrax::ValkyrieIndexer.indexer_class_for` once changes are merged.
  indexer = "#{work_type}Indexer".constantize
  indexer.send(:include, Hyrax::Indexer(:child_works_from_pdf_splitting)) unless
    Hyrax.config.try(:work_include_metadata?) || Hyrax.config.try(:flexible?) || indexer.included_modules.include?(Hyrax::Indexer(:child_works_from_pdf_splitting))
  indexer
end

.destroy_children_split_from(file_set:, work:, model:, user:) ⇒ Object

NOTE: this isn’t the most efficient method, but it is the most reliable.

Attribute 'split_from_pdf_id' is saved in Valkyrie as a string rather than as { id: string },
  so we can't use the 'find_inverse_references_by' query.
Additionally, the attribute does not exist on all child works, as it was added later, so using
  a child work's title allows us to find child works when the attribute isn't present.
Building a custom query to find these child works directly via the attribute would be more efficient.
  However, it would require more effort for a lesser-used feature, and would not allow for the fallback
  of finding child works by title.

rubocop:disable Lint/UnusedMethodArgument, Metrics/AbcSize, Metrics/MethodLength



93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 93

def self.destroy_children_split_from(file_set:, work:, model:, user:)
  all_child_works = Hyrax.custom_queries.find_child_works(resource: work)
  return if all_child_works.blank?
  # look first for children by the file set id they were split from
  children = all_child_works.select { |m| m.split_from_pdf_id == file_set.id }
  if children.blank?
    # find works where file name and work `to_param` are both in the title
    children = all_child_works.select { |m| m.title.include?(file_set.label) && m.title.include?(work.to_param) }
  end
  return if children.blank?
  # we have to update the work's members first, then delete the children
  # otherwise Hyrax tries to save the parent as each child is deleted, resulting
  # in failing jobs
  remaining_members = work.member_ids - children.map(&:id)
  work.member_ids = remaining_members
  Hyrax.persister.save(resource: work)
  Hyrax.index_adapter.save(resource: work)
  Hyrax.publisher.publish('object.membership.updated', object: work, user: user)

  children.each do |rcd|
    Hyrax.persister.delete(resource: rcd)
    Hyrax.index_adapter.delete(resource: rcd)
    Hyrax.publisher.publish('object.deleted', object: rcd, user: user)
  end
  true
end

.extract_text_for(file_set:) ⇒ String

Extract text from the derivatives

Parameters:

  • a (Hyrax::FileSet) —

    Valkyrie fileset

Returns:

  • (String) —

    Text from fileset’s file



201
202
203
204
205
206
207
208
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 201

def self.extract_text_for(file_set:)
  fm = Hyrax.custom_queries.find_many_file_metadata_by_use(resource: file_set,
  use: Hyrax::FileMetadata::Use.uri_for(use: :extracted_file))
  return if fm.empty?
  text_fm = fm.find { |t| t.mime_type == Marcel::MimeType.for(extension: 'txt') }
  return if text_fm.nil?
  text_fm.content
end

.find_by(id:) ⇒ Object

find a work or file_set

Parameters:

  • id (String) 


156
157
158
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 156

def self.find_by(id:)
  Hyrax.query_service.find_by(id: id)
end

.find_by_title_for(title:, model:) ⇒ Array<Valkyrie::Resource]

find a work by title We should only find one, but there is no guarantee of that

Parameters:

  • title (String)
  • model (String) —

    a Valkyrie::Resource model

Returns:

  • (Array<Valkyrie::Resource]) —

    Array<Valkyrie::Resource]



143
144
145
146
147
148
149
150
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 143

def self.find_by_title_for(title:, model:)
  work_type = model.constantize
  # TODO: This creates a hard dependency on Bulkrax because that is where this custom query is defined
  #       Is this adequate?
  Array.wrap(Hyrax.query_service.custom_query.find_by_model_and_property_value(model: work_type,
                                                                               property: :title,
                                                                               value: title))
end

.grandparent_for(file_set) ⇒ #work?, ...

Return the parent’s parent of the given :file_set.

Parameters:

  • file_set (Hyrax::FileMetadata or FileSet)

Returns:

  • (#work?, Hydra::PCDM::Work)
  • (NilClass) —

    when no grand parent is found.



60
61
62
63
64
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 60

def self.grandparent_for(file_set)
  parent = parent_for(file_set)
  return nil unless parent
  Hyrax.query_service.find_parents(resource: parent).first
end

.index_works(objects:) ⇒ TrueClass

reindex an array of works and their file_sets

Parameters:

  • objects (Array<Valkyrie::Resource]) —

    bjects [Array<Valkyrie::Resource]

Returns:

  • (TrueClass) 


176
177
178
179
180
181
182
183
184
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 176

def self.index_works(objects:)
  objects.each do |work|
    Hyrax.index_adapter.save(resource: work)
    Hyrax.custom_queries.find_child_file_sets(resource: work).each do |file_set|
      Hyrax.index_adapter.save(resource: file_set)
    end
  end
  true
end

.object_in_works(object) ⇒ Array<Valkyrie::Resource>

Parameters:

  • object (Valkyrie::Resource)

Returns:

  • (Array<Valkyrie::Resource>) 


9
10
11
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 9

def self.object_in_works(object)
  Array.wrap(Hyrax.custom_queries.find_parent_work(resource: object))
end

.object_ordered_works(object) ⇒ Array<Valkyrie::Resource>

Parameters:

  • object (Valkyrie::Resource)

Returns:

  • (Array<Valkyrie::Resource>) 


16
17
18
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 16

def self.object_ordered_works(object)
  Hyrax.custom_queries.find_child_works(resource: object).to_a
end

.parent_for(file_set) ⇒ #work?, ...

Return the immediate parent of the given :file_set.

Parameters:

  • file_set (Hyrax::FileMetadata or FileSet)

Returns:

  • (#work?, Hydra::PCDM::Work)
  • (NilClass) —

    when no parent is found.



49
50
51
52
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 49

def self.parent_for(file_set)
  file_set = Hyrax.query_service.find_by(id: file_set.file_set_id) if file_set.is_a?(Hyrax::FileMetadata)
  Hyrax.query_service.find_parents(resource: file_set).first
end

.pdf?(file_set) ⇒ Boolean

rubocop:enable Lint/UnusedMethodArgument, Metrics/AbcSize, Metrics/MethodLength

Returns:

  • (Boolean) 


121
122
123
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 121

def self.pdf?(file_set)
  file_set.original_file&.pdf?
end

.pdf_path_for(file_set:) ⇒ String

Location of the file for resplitting

Parameters:

  • a (Hyrax::FileSet) —

    Valkyrie fileset

Returns:

  • (String) —

    location of the original file



215
216
217
218
219
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 215

def self.pdf_path_for(file_set:)
  file = file_set.original_file
  return '' unless file.pdf?
  file.file.disk_path.to_s
end

.save(object:) ⇒ Object

save a work

Parameters:

  • object (Array<Valkyrie::Resource]) —

    bject [Array<Valkyrie::Resource]



164
165
166
167
168
169
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 164

def self.save(object:)
  Hyrax.persister.save(resource: object)
  Hyrax.index_adapter.save(resource: object)

  Hyrax.publisher.publish('object.membership.updated', object: object, user: object.depositor)
end

.solr_construct_query(*args) ⇒ Object 



66
67
68
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 66

def self.solr_construct_query(*args)
  Hyrax::SolrQueryBuilderService.construct_query(*args)
end

.solr_name(field_name) ⇒ Object 



80
81
82
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 80

def self.solr_name(field_name)
  Hyrax.config.index_field_mapper.solr_name(field_name.to_s)
end

.solr_query(query, **args) ⇒ Object 



76
77
78
 
# File 'lib/iiif_print/persistence_layer/valkyrie_adapter.rb', line 76

def self.solr_query(query, **args)
  Hyrax::SolrService.query(query, **args)
end