class Guard::Jobs::PryWrapper

def _add_hooks(options)
  _add_load_guard_rc_hook(Pathname(options[:guard_rc] || GUARD_RC))
  _add_load_project_guard_rc_hook(Pathname.pwd + ".guardrc")
  _add_restore_visibility_hook if @terminal_settings.configurable?
end

def _add_load_guard_rc_hook(guard_rc)
  _pry_config.hooks.add_hook :when_started, :load_guard_rc do
    guard_rc.expand_path.tap { |p| load p if p.exist? }
  end
end

def _add_load_project_guard_rc_hook(guard_rc)
  _pry_config.hooks.add_hook :when_started, :load_project_guard_rc do
    load guard_rc if guard_rc.exist?
  end
end

def _add_restore_visibility_hook
  _pry_config.hooks.add_hook :after_eval, :restore_visibility do
    @terminal_settings.echo
  end
end

def _clip_name(target)
  Pry.view_clip(target)
end

def _configure_history_file(history_file)
  history_file_path = File.expand_path(history_file)
  # Pry >= 0.13
  if _pry_config.respond_to?(:history_file=)
    _pry_config.history_file = history_file_path
  else
    _pry_config.history.file = history_file_path
  end
end

def _configure_prompt
  prompt_procs = [_prompt(">"), _prompt("*")]
  prompt =
    if Pry::Prompt.is_a?(Class)
      Pry::Prompt.new("Guard", "Guard Pry prompt", prompt_procs)
    else
      prompt_procs
    end
  _pry_config.prompt = prompt
end

def _create_command_aliases
  SHORTCUTS.each do |command, shortcut|
    _pry_commands.alias_command shortcut, command.to_s
  end
end

def _create_group_commands
  Guard.state.session.groups.all.each do |group|
    next if group.name == :default
    cmd = "Run all #{group.title}"
    _pry_commands.create_command group.name.to_s, cmd do
      group "Guard"
      def process
        Pry.run_command "all #{ match }"
      end
    end
  end
end

def _create_guard_commands
  Guard.state.session.plugins.all.each do |guard_plugin|
    cmd = "Run all #{guard_plugin.title}"
    _pry_commands.create_command guard_plugin.name, cmd do
      group "Guard"
      def process
        Pry.run_command "all #{ match }"
      end
    end
  end
end

def _create_run_all_command
  _pry_commands.block_command(/^$/, "Hit enter to run all") do
    Pry.run_command "all"
  end
end

def _history(pry)
  if pry.respond_to?(:input_ring)
    pry.input_ring.size
  else
    pry.input_array.size
  end
end

def _kill_pry
  @mutex.synchronize do
    unless @thread.nil?
      @thread.kill
      @thread = nil # set to nil so we know we were killed
    end
  end
end

def _killed?
  th = nil
  @mutex.synchronize { th = @thread }
  th.nil?
end

def _prompt(ending_char)
  proc do |target_self, nest_level, pry|
    process = Guard.listener.paused? ? "pause" : "guard"
    level = ":#{ nest_level }" unless nest_level.zero?
    "[#{ _history(pry) }] #{ _scope_for_prompt }#{ process }"\
      "(#{ _clip_name(target_self) })#{ level }#{ ending_char } "
  end
end

def _pry_commands
  Pry.commands
end

def _pry_config
  Pry.config
end

def _replace_reset_command
  _pry_commands.command "reset", "Reset the Guard to a clean state." do
    output.puts "Guard reset."
    exec "guard"
  end
end

def _scope_for_prompt
  titles = Guard.state.scope.titles.join(",")
  titles == "all" ? "" : titles + " "
end

def _setup(options)
  _pry_config.should_load_rc = false
  _pry_config.should_load_local_rc = false
  _configure_history_file(options[:history_file] || HISTORY_FILE)
  _add_hooks(options)
  Commands::All.import
  Commands::Change.import
  Commands::Notification.import
  Commands::Pause.import
  Commands::Reload.import
  Commands::Show.import
  Commands::Scope.import
  _setup_commands
  _configure_prompt
end

def _setup_commands
  _replace_reset_command
  _create_run_all_command
  _create_command_aliases
  _create_guard_commands
  _create_group_commands
end

def _switch_to_pry
  th = nil
  @mutex.synchronize do
    unless @thread
      @thread = Thread.new { Pry.start }
      @thread.join(0.5) # give pry a chance to start
      th = @thread
    end
  end
  # check for nill, because it might've been killed between the mutex and
  # now
  th.join unless th.nil?
end

def background
  _kill_pry
end

def foreground
  UI.debug "Start interactor"
  @terminal_settings.save
  _switch_to_pry
  # TODO: rename :stopped to continue
  _killed? ? :stopped : :exit
ensure
  UI.reset_line
  UI.debug "Interactor was stopped or killed"
  @terminal_settings.restore
end

def handle_interrupt
  thread = @thread
  fail Interrupt unless thread
  thread.raise Interrupt
end

def initialize(options)
  @mutex = Mutex.new
  @thread = nil
  @terminal_settings = TerminalSettings.new
  _setup(options)
end

def process
  Pry.run_command "all #{ match }"
end

def process
  Pry.run_command "all #{ match }"
end