module Fluere

# File lib/fluere.rb, line 26
def self.activities
  @activities ||= []
end

# File lib/fluere.rb, line 22
def self.activities_task_list
  Fluere.prefixed_task_list('activities')
end

# File lib/fluere.rb, line 92
def self.assert_stubbed
  raise StubbedPathOnlyError.new unless stubbed?
end

# File lib/fluere.rb, line 10
def self.configure(&block)
  yield Fluere::Config
end

# File lib/fluere.rb, line 18
def self.decisions_task_list
  Fluere.prefixed_task_list('decisions')
end

# File lib/fluere.rb, line 50
def self.default_activity_options
  {
    default_task_schedule_to_close_timeout: 60 * 60 * 2,
    default_task_schedule_to_start_timeout: 60 * 60 * 2,
    default_task_start_to_close_timeout: 60 * 60 * 2,
  }
end

# File lib/fluere.rb, line 42
def self.default_workflow_options
  {
    default_execution_start_to_close_timeout: 60 * 60 * 2,
    default_task_start_to_close_timeout: 60 * 60 * 2,
    default_child_policy: :terminate,
  }
end

# File lib/fluere.rb, line 34
def self.domain
  swf.domains[Config.domain]
end

# File lib/fluere.rb, line 76
def self.flush!
  domain.workflow_executions.with_status(:open).map { |we| we.terminate }
end

# File lib/fluere.rb, line 104
def self.ignore_executions
  raise "only allowed to ignore executions when stubbed!" unless stubbed?
  @ignore_executions = true
  yield
ensure
  @ignore_executions = false
end

# File lib/fluere.rb, line 100
def self.ignore_executions?
  @ignore_executions
end

# File lib/fluere.rb, line 72
def self.info(msg)
  Fluere::Config.logger.info(msg)
end

# File lib/fluere.rb, line 96
def self.perform_executions?
  !ignore_executions?
end

# File lib/fluere.rb, line 38
def self.prefixed_task_list(task_list)
  [Fluere::Config.task_list_prefix, task_list].join('-')
end

# File lib/fluere.rb, line 58
def self.start_execution(klass, *args)
  if stubbed?
    if perform_executions?
      info("Performing a stubbed execution, calling #{klass} decider block with args: #{args.inspect}")
      klass.decider_class.new.send(Fluere::Workflow::EXECUTION_METHOD, *args)
    else
      info("Skipped workflow execution for #{klass}")
    end
  else
    info("Requesting a workflow execution for #{klass}")
    klass.workflow_client.start_execution(*args)
  end
end

# File lib/fluere.rb, line 84
def self.stub!
  @stubbed = true
end

# File lib/fluere.rb, line 80
def self.stubbed?
  @stubbed
end

# File lib/fluere.rb, line 30
def self.swf
  @swf ||= AWS::SimpleWorkflow.new
end

# File lib/fluere.rb, line 88
def self.unstub!
  @stubbed = false
end

# File lib/fluere.rb, line 14
def self.workflows
  @workflows ||= []
end