module ForemanTasks

# File lib/foreman_tasks.rb, line 53
def self.async_task(action, *args, &block)
  trigger_task true, action, *args, &block
end

# File lib/foreman_tasks.rb, line 63
def self.delay(action, delay_options, *args)
  result = dynflow.world.delay action, delay_options, *args
  ForemanTasks::Task::DynflowTask.where(:external_id => result.id).first!
end

# File lib/foreman_tasks.rb, line 14
def self.dynflow
  @dynflow ||= begin
                 world = ForemanTasks::Dynflow.new(nil, ForemanTasks::Dynflow::Configuration.new)
                 ForemanTasksCore.dynflow_setup(world) if defined?(ForemanTasksCore)
                 world
               end
end

# File lib/foreman_tasks.rb, line 47
def self.rails_safe_trigger_task
  ActiveSupport::Dependencies.interlock.permit_concurrent_loads do
    yield
  end
end

# File lib/foreman_tasks.rb, line 57
def self.sync_task(action, *args, &block)
  trigger_task(false, action, *args, &block).tap do |task|
    raise TaskError, task if task.execution_plan.error? || task.execution_plan.result == :warning
  end
end

# File lib/foreman_tasks/engine.rb, line 158
def self.table_name_prefix
  'foreman_tasks_'
end

# File lib/foreman_tasks.rb, line 22
def self.trigger(action, *args, &block)
  dynflow.world.trigger action, *args, &block
end

# File lib/foreman_tasks.rb, line 26
def self.trigger_task(async, action, *args, &block)
  rails_safe_trigger_task do
    Match! async, true, false
    match trigger(action, *args, &block),
          (on ::Dynflow::World::PlaningFailed.call(error: ~any) do |error|
            raise error
          end),
          (on ::Dynflow::World::Triggered.call(execution_plan_id: ~any, future: ~any) do |id, finished|
            unless async
              timeout = Setting['foreman_tasks_sync_task_timeout']
              finished.wait(timeout)
              task = ForemanTasks::Task::DynflowTask.where(:external_id => id).first
              if task.nil? || (!task.paused? && task.pending?)
                raise TimeoutError, "The time waiting for task #{task.try(:id)} to finish exceeded the 'foreman_tasks_sync_task_timeout' (#{timeout}s)"
              end
            end
            task || ForemanTasks::Task::DynflowTask.where(:external_id => id).first!
          end)
  end
end

# File lib/foreman_tasks/engine.rb, line 162
def use_relative_model_naming
  true
end