# frozen_string_literal: true

module Aruba
  class Setup
    private

    attr_reader :runtime

    public

    def initialize(runtime)
      @runtime = runtime
    end

    def call(clobber = true)
      return if runtime.setup_already_done?

      working_directory(clobber)
      events

      runtime.setup_done

      self
    end

    private

    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

    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(
        %i[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
  end
end