module Proxy::Dynflow::Helpers

Public Instance Methods

authorize_with_token(task_id:, clear: true) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 13
def authorize_with_token(task_id:, clear: true)
  if request.env.key? 'HTTP_AUTHORIZATION'
    if defined?(::Proxy::Dynflow)
      auth = request.env['HTTP_AUTHORIZATION']
      basic_prefix = /\ABasic /
      if !auth.to_s.empty? && auth =~ basic_prefix &&
         Proxy::Dynflow::OtpManager.authenticate(auth.gsub(basic_prefix, ''),
                                                 expected_user: task_id, clear: clear)
        Log.instance.debug('authorized with token')
        return true
      end
    end
    halt 403, MultiJson.dump(:error => 'Invalid username or password supplied')
  end
  false
end
cancel_task(task_id) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 35
def cancel_task(task_id)
  execution_plan = world.persistence.load_execution_plan(task_id)
  cancel_events = execution_plan.cancel
  { :task_id => task_id, :canceled_steps_count => cancel_events.size }
end
dispatch_external_event(task_id, params) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 63
def dispatch_external_event(task_id, params)
  world.event(task_id,
              params['step_id'].to_i,
              ::Proxy::Dynflow::Runner::ExternalEvent.new(params))
end
execution_plan_status(plan) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 81
def execution_plan_status(plan)
  actions = plan.actions.map do |action|
    refresh_output(plan, action)
    expand_output(action)
  end
  plan.to_hash.merge(:actions => actions)
end
expand_output(action) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 75
def expand_output(action)
  hash = action.to_hash
  hash[:output][:result] = action.output_result if action.is_a?(Proxy::Dynflow::Action::Runner)
  hash
end
refresh_output(execution_plan, action) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 69
def refresh_output(execution_plan, action)
  if action.is_a?(Proxy::Dynflow::Action::WithExternalPolling) && %i[running suspended].include?(action.run_step&.state)
    world.event(execution_plan.id, action.run_step_id, Proxy::Dynflow::Action::WithExternalPolling::Poll)
  end
end
task_status(task_id) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 41
def task_status(task_id)
  ep = world.persistence.load_execution_plan(task_id)
  execution_plan_status(ep)
rescue KeyError => _e
  status 404
  {}
end
tasks_count(state) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 56
def tasks_count(state)
  state ||= 'all'
  filter = state != 'all' ? { :filters => { :state => [state] } } : {}
  count = world.persistence.find_execution_plan_counts(filter)
  { :count => count, :state => state }
end
tasks_statuses(task_ids) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 49
def tasks_statuses(task_ids)
  eps = world.persistence.find_execution_plans(filters: { uuid: task_ids })
  eps.reduce({}) do |acc, ep|
    acc.update(ep.id => execution_plan_status(ep))
  end
end
trigger_task(*args) click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 30
def trigger_task(*args)
  triggered = world.trigger(*args)
  { :task_id => triggered.id }
end
world() click to toggle source
# File lib/smart_proxy_dynflow/helpers.rb, line 9
def world
  Proxy::Dynflow::Core.world
end