Class: Krikri::Mapper::Agent

Inherits:
Object
  • Object
show all
Includes:
EntityConsumer, SoftwareAgent
Defined in:
lib/krikri/mapper.rb

Overview

A SoftwareAgent to run mapping processes.

@see: Krikri::SoftwareAgent, Krikri::Activity

Examples:


To map the records harvested by the harvest activity with ID 1:

Krikri::Mapper::Agent.enqueue(
  :mapping,
  opts = {
    name: 'scdl_qdc',
    generator_uri: 'http://ldp.local.dp.la/ldp/activity/1'
  }
)

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Methods included from EntityConsumer

#assign_generator_activity!

Methods included from SoftwareAgent

#agent_name

Constructor Details

#initialize(opts = {}) ⇒ Agent

Returns a new instance of Agent.



126
127
128
129
 
# File 'lib/krikri/mapper.rb', line 126

def initialize(opts = {})
  @name = opts.fetch(:name).to_sym
  assign_generator_activity!(opts)
end

Instance Attribute Details

#name ⇒ Object (readonly)

Returns the value of attribute name.



112
113
114
 
# File 'lib/krikri/mapper.rb', line 112

def name
  @name
end

Class Method Details

.queue_name ⇒ Object 



114
115
116
 
# File 'lib/krikri/mapper.rb', line 114

def self.queue_name
  :mapping
end

Instance Method Details

#entity_behavior ⇒ Object

See Also:



122
123
124
 
# File 'lib/krikri/mapper.rb', line 122

def entity_behavior
  @entity_behavior ||= Krikri::AggregationEntityBehavior
end

#run(activity_uri = nil) ⇒ Object 



131
132
133
134
135
136
137
138
139
140
141
142
 
# File 'lib/krikri/mapper.rb', line 131

def run(activity_uri = nil)
  harvest_records = generator_activity.entities
  Krikri::Mapper.map(name, harvest_records).each do |rec|
    begin
      rec.mint_id! if rec.node?
      activity_uri ? rec.save_with_provenance(activity_uri) : rec.save
    rescue => e
      Rails.logger.error("Error saving record: #{rec.try(:rdf_subject)}\n" \
                         "#{e.message}\n#{e.backtrace}")
    end
  end
end