Sha256: 928a43adfcdce38d141844fbd812a428d2ea96386f609bde6eea22f4cdf96949
Contents?: true
Size: 1.8 KB
Versions: 12
Compression:
Stored size: 1.8 KB
Contents
# frozen_string_literal: true
module Dor
module Workflow
module Response
# The response from asking the server about a workflow for an item
class Workflow
def initialize(xml:)
@xml = xml
end
def pid
workflow['objectId']
end
def workflow_name
workflow['id']
end
def repository
workflow['repository']
end
# @param [Integer] version the version we are checking for.
def active_for?(version:)
result = ng_xml.at_xpath("/workflow/process[@version=#{version}]")
result ? true : false
end
# Returns the process, for the most recent version that matches the given name:
def process_for_recent_version(name:)
nodes = process_nodes_for(name: name)
node = nodes.max { |a, b| a.attr('version').to_i <=> b.attr('version').to_i }
attributes = node ? Hash[node.attributes.collect { |k, v| [k.to_sym, v.value] }] : {}
Process.new(parent: self, **attributes)
end
def empty?
ng_xml.xpath('/workflow/process').empty?
end
def complete?
ng_xml.xpath("/workflow/process[@version=#{version}]/@status").map(&:value).all? { |p| %w[skipped completed].include?(p) }
end
attr_reader :xml
private
# Return the max version in this workflow document
def version
ng_xml.xpath('/workflow/process/@version').map { |attr| attr.value.to_i }.max
end
def workflow
ng_xml.at_xpath('workflow')
end
def process_nodes_for(name:)
ng_xml.xpath("/workflow/process[@name = '#{name}']")
end
def ng_xml
@ng_xml ||= Nokogiri::XML(@xml)
end
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems