Sha256: e57da398d341184344a8f7d2a85b05406e0a69eac53c8875c62cc57c60a75e27
Contents?: true
Size: 1.74 KB
Versions: 52
Compression:
Stored size: 1.74 KB
Contents
require 'dor/datastreams/workflow_definition_ds'
module Dor
class WorkflowObject < ::ActiveFedora::Base
include Identifiable
include SolrDocHelper
include Governable
@@xml_cache = {}
has_object_type 'workflow'
has_metadata :name => "workflowDefinition", :type => Dor::WorkflowDefinitionDs, :label => 'Workflow Definition'
def self.find_by_name(name, opts={})
Dor.find_all(%{objectType_t:"#{self.object_type}" workflow_name_s:"#{name}"}, opts).first
end
# Searches for the workflow definition object in DOR, then
# returns an object's initial workflow as defined in the worfklowDefinition datastream
# It will cache the result for subsequent requests
# @param [String] name the name of the workflow
# @return [String] the initial workflow xml
def self.initial_workflow(name)
return @@xml_cache[name] if(@@xml_cache.include?(name))
wobj = self.find_by_name(name)
wf_xml = wobj.generate_initial_workflow
@@xml_cache[name] = wf_xml
end
def definition
datastreams['workflowDefinition']
end
def graph *args
self.definition.graph *args
end
def to_solr solr_doc=Hash.new, *args
super solr_doc, *args
client = Dor::WorkflowService.workflow_resource
xml = client["workflow_archive?repository=#{definition.repo}&workflow=#{definition.name}&count-only=true"].get
count = Nokogiri::XML(xml).at_xpath('/objects/@count').value
add_solr_value(solr_doc,"#{definition.name}_archived",count,:integer,[:displayable])
solr_doc
end
def generate_initial_workflow
datastreams['workflowDefinition'].initial_workflow
end
alias_method :generate_intial_workflow, :generate_initial_workflow
end
end
Version data entries
52 entries across 52 versions & 1 rubygems