lib/dor/workflow/client/workflow_routes.rb
# frozen_string_literal: true
module Dor
module Workflow
class Client
# Makes requests relating to a workflow
class WorkflowRoutes
def initialize(requestor:)
@requestor = requestor
end
# Creates a workflow for a given object in the repository. If this particular workflow for this objects exists,
# it will replace the old workflow.
# Returns true on success. Caller must handle any exceptions.
#
# @param [String] druid The id of the object
# @param [String] workflow_name The name of the workflow you want to create. This must correspond with a workflow
# name that is known by the workflow service.
# @param [String] lane_id adds laneId attribute to all process elements in the wf_xml workflow xml. Defaults to a value of 'default'
# @param [Hash] context optional context to be included in the workflow (same for all processes for a given druid/version pair)
# @param [Integer] version specifies the version so that workflow service doesn't need to query dor-services.
# @return [Boolean] always true
#
def create_workflow_by_name(druid, workflow_name, version:, lane_id: 'default', context: nil)
params = { 'lane-id' => lane_id, 'version' => version }
body = context ? { 'context' => context }.to_json : ''
requestor.request "objects/#{druid}/workflows/#{workflow_name}", 'post', body,
content_type: 'application/json',
params: params
true
end
# Updates the status of one step in a workflow.
# Returns true on success. Caller must handle any exceptions
#
# @param [String] druid The id of the object
# @param [String] workflow The name of the workflow
# @param [String] process The name of the process step
# @param [String] status The status that you want to set -- using one of the values in VALID_STATUS
# @param [Float] :elapsed The number of seconds it took to complete this step. Can have a decimal. Is set to 0 if not passed in.
# @param [String] :lifecycle Bookeeping label for this particular workflow step. Examples are: 'registered', 'shelved'
# @param [String] :note Any kind of string annotation that you want to attach to the workflow
# @param [String] :current_status Setting this string tells the workflow service to compare the current status to this value. If the current value does not match this value, the update is not performed
# @return [Boolean] always true
# Http Call
# ==
# The method does an HTTP PUT to the base URL. As an example:
#
# PUT "/objects/pid:123/workflows/GoogleScannedWF/convert"
# <process name=\"convert\" status=\"completed\" />"
def update_status(druid:, workflow:, process:, status:, elapsed: 0, lifecycle: nil, note: nil, current_status: nil)
raise ArgumentError, "Unknown status value #{status}" unless VALID_STATUS.include?(status)
raise ArgumentError, "Unknown current_status value #{current_status}" if current_status && !VALID_STATUS.include?(current_status)
raise ArgumentError, "Do not set status to 'error', use update_error_status method" if status == 'error'
xml = create_process_xml(name: process, status: status, elapsed: elapsed, lifecycle: lifecycle, note: note)
uri = "objects/#{druid}/workflows/#{workflow}/#{process}"
uri += "?current-status=#{current_status}" if current_status
response = requestor.request(uri, 'put', xml, content_type: 'application/xml')
Workflow::Response::Update.new(json: response)
end
#
# Retrieves the process status of the given workflow for the given object identifier
# @param [String] druid The id of the object
# @param [String] workflow The name of the workflow
# @param [String] process The name of the process step
# @return [String] status for repo-workflow-process-druid
def workflow_status(druid:, workflow:, process:)
workflow_md = fetch_workflow(druid: druid, workflow: workflow)
doc = Nokogiri::XML(workflow_md)
raise Dor::WorkflowException, "Unable to parse response:\n#{workflow_md}" if doc.root.nil?
processes = doc.root.xpath("//process[@name='#{process}']")
process = processes.max { |a, b| a.attr('version').to_i <=> b.attr('version').to_i }
process&.attr('status')
end
# Updates the status of one step in a workflow to error.
# Returns true on success. Caller must handle any exceptions
#
# @param [String] druid The id of the object
# @param [String] workflow The name of the workflow
# @param [String] process The name of the workflow step
# @param [String] error_msg The error message. Ideally, this is a brief message describing the error
# @param [String] error_text A slot to hold more information about the error, like a full stacktrace
# @return [Workflow::Response::Update]
#
# Http Call
# ==
# The method does an HTTP PUT to the base URL.
#
# PUT "/objects/pid:123/workflows/GoogleScannedWF/convert"
# <process name=\"convert\" status=\"error\" />"
def update_error_status(druid:, workflow:, process:, error_msg:, error_text: nil)
xml = create_process_xml(name: process, status: 'error', errorMessage: error_msg, error_text: error_text)
response = requestor.request "objects/#{druid}/workflows/#{workflow}/#{process}", 'put', xml, content_type: 'application/xml'
Workflow::Response::Update.new(json: response)
end
# Retrieves all workflows for the given object
# @param [String] pid The id of the object
# @return [Workflow::Response::Workflows]
def all_workflows(pid:)
xml = requestor.request "objects/#{pid}/workflows"
Workflow::Response::Workflows.new(xml: xml)
end
# Skips all steps in a WF
def skip_all(druid:, workflow:, note:)
xml = create_process_xml(name: 'skip-all', status: 'skipped', note: note)
response = requestor.request "objects/#{druid}/workflows/#{workflow}/skip-all", 'post', xml, content_type: 'application/xml'
Workflow::Response::Workflows.new(xml: response)
end
# Get workflow names into an array for given PID
# This method only works when this gem is used in a project that is configured to connect to DOR
#
# @param [String] pid of druid
# @return [Array<String>] list of worklows
# @example
# client.workflows('druid:sr100hp0609')
# => ["accessionWF", "assemblyWF", "disseminationWF"]
def workflows(pid)
xml_doc = Nokogiri::XML(fetch_workflow(druid: pid, workflow: ''))
xml_doc.xpath('//workflow').collect { |workflow| workflow['id'] }
end
# @param [String] pid id of object
# @param [String] workflow_name The name of the workflow
# @return [Workflow::Response::Workflow]
def workflow(pid:, workflow_name:)
xml = fetch_workflow(druid: pid, workflow: workflow_name)
Workflow::Response::Workflow.new(xml: xml)
end
# @param [String] pid id of object
# @param [String] workflow_name The name of the workflow
# @param [String] process The name of the workflow step
# @return [Workflow::Response::Process]
def process(pid:, workflow_name:, process:)
workflow(pid: pid, workflow_name: workflow_name).process_for_recent_version(name: process)
end
# Deletes a workflow from a particular repository and druid. This is only used by Hydrus.
# @param [String] druid The id of the object to delete the workflow from
# @param [String] workflow The name of the workflow to be deleted
# @param [Integer] version The version of the workflow to delete
# @return [Boolean] always true
def delete_workflow(druid:, workflow:, version:)
qs_args = "?version=#{version}"
requestor.request "/objects/#{druid}/workflows/#{workflow}#{qs_args}", 'delete'
true
end
# Deletes all workflow steps for a particular druid
# @param [String] pid The id of the object to delete the workflow from
# @return [Boolean] always true
def delete_all_workflows(pid:)
requestor.request "objects/#{pid}/workflows", 'delete'
true
end
private
attr_reader :requestor
def fetch_workflow(druid:, workflow:)
raise ArgumentError, 'missing workflow' unless workflow
requestor.request "objects/#{druid}/workflows/#{workflow}"
end
# @param [Hash] params
# @return [String]
def create_process_xml(params)
builder = Nokogiri::XML::Builder.new do |xml|
attrs = params.compact
attrs = attrs.transform_keys { |k| k.to_s.camelize(:lower) } # camelize all the keys in the attrs hash
xml.process(attrs)
end
builder.to_xml
end
end
end
end
end