class Aruba::Setup

def call(clobber = true)
  return if runtime.setup_already_done?
  working_directory(clobber)
  events
  runtime.setup_done
  self
end

def events
  runtime.event_bus.register(
    :command_started,
    proc do |event|
      runtime.announcer.announce(:command) { event.entity.commandline }
      runtime.announcer.announce(:timeout, "exit") { event.entity.exit_timeout }
      runtime.announcer.announce(:timeout, "io wait") { event.entity.io_wait_timeout }
      runtime.announcer
        .announce(:wait_time, "startup wait time") { event.entity.startup_wait_time }
      runtime.announcer.announce(:full_environment) { event.entity.environment }
    end
  )
  runtime.event_bus.register(
    :command_started,
    proc do |event|
      runtime.command_monitor.register_command event.entity
      runtime.command_monitor.last_command_started = event.entity
    end
  )
  runtime.event_bus.register(
    :command_stopped,
    proc do |event|
      runtime.announcer.announce(:stdout) { event.entity.stdout }
      runtime.announcer.announce(:stderr) { event.entity.stderr }
      runtime.announcer.announce(:command_content) { event.entity.content }
      runtime.announcer
        .announce(:command_filesystem_status) { event.entity.filesystem_status }
    end
  )
  runtime.event_bus.register(
    :command_stopped,
    proc do |event|
      runtime.command_monitor.last_command_stopped = event.entity
    end
  )
  runtime.event_bus.register(
    [:changed_environment_variable,
     :added_environment_variable,
     :deleted_environment_variable],
    proc do |event|
      runtime.announcer.announce :changed_environment,
                                 event.entity[:changed][:name],
                                 event.entity[:changed][:value]
      runtime.announcer.announce :environment,
                                 event.entity[:changed][:name],
                                 event.entity[:changed][:value]
    end
  )
  runtime.event_bus.register(
    :changed_working_directory,
    proc { |event| runtime.announcer.announce :directory, event.entity[:new] }
  )
  runtime.event_bus.register(
    :changed_configuration,
    proc { |event|
      runtime.announcer.announce :configuration,
                                 event.entity[:changed][:name],
                                 event.entity[:changed][:value]
    }
  )
end

def initialize(runtime)
  @runtime = runtime
end

def working_directory(clobber = true)
  if clobber
    Aruba.platform.rm File.join(runtime.config.root_directory,
                                runtime.config.working_directory),
                      force: true
  end
  Aruba.platform.mkdir File.join(runtime.config.root_directory,
                                 runtime.config.working_directory)
  Aruba.platform.chdir runtime.config.root_directory
end