module Byebug

def self.attach
  require 'byebug/core'
  unless started?
    self.mode = :attached
    start
    run_init_script
  end
  current_context.step_out(3, true)
end

def self.handle_post_mortem
  return unless raised_exception
  context = raised_exception.__bb_context
  PostMortemProcessor.new(context).at_line
end

def self.load_settings
  Dir.glob(File.expand_path('../settings/*.rb', __FILE__)).each do |file|
    require file
  end
  constants.grep(/[a-z]Setting/).map do |name|
    setting = const_get(name).new
    Byebug::Setting.settings[setting.to_sym] = setting
  end
end

def interrupt
  current_context.interrupt
end

def parse_host_and_port(host_port_spec)
  location = host_port_spec.split(':')
  location[1] ? [location[0], location[1].to_i] : ['localhost', location[0]]
end

def run_init_script
  home_rc = File.expand_path(File.join(ENV['HOME'].to_s, init_file))
  run_script(home_rc) if File.exist?(home_rc)
  cwd_rc = File.expand_path(File.join('.', init_file))
  run_script(cwd_rc) if File.exist?(cwd_rc) && cwd_rc != home_rc
end

def run_script(file, verbose = false)
  old_interface = Context.interface
  Context.interface = ScriptInterface.new(file, verbose)
  ScriptProcessor.new(nil).process_commands
ensure
  Context.interface = old_interface
end

def start_client(host = 'localhost', port = PORT)
  Context.interface = LocalInterface.new
  puts 'Connecting to byebug server...'
  socket = TCPSocket.new(host, port)
  puts 'Connected.'
  catch(:exit) do
    while (line = socket.gets)
      case line
      when /^PROMPT (.*)$/
        input = Context.interface.read_command(Regexp.last_match[1])
        throw :exit unless input
        socket.puts input
      when /^CONFIRM (.*)$/
        input = Context.interface.confirm(Regexp.last_match[1])
        throw :exit unless input
        socket.puts input
      else
        puts line
      end
    end
  end
  socket.close
end

def start_control(host = nil, ctrl_port = PORT + 1)
  return @actual_control_port if @control_thread
  server = TCPServer.new(host, ctrl_port)
  @actual_control_port = server.addr[1]
  @control_thread = DebugThread.new do
    while (session = server.accept)
      Context.interface = RemoteInterface.new(session)
      ControlProcessor.new(Byebug.current_context).process_commands
    end
  end
  @actual_control_port
end

def start_server(host = nil, port = PORT)
  return if @thread
  Context.interface = nil
  start
  start_control(host, port == 0 ? 0 : port + 1)
  yield if block_given?
  mutex = Mutex.new
  proceed = ConditionVariable.new
  server = TCPServer.new(host, port)
  self.actual_port = server.addr[1]
  @thread = DebugThread.new do
    while (session = server.accept)
      Context.interface = RemoteInterface.new(session)
      mutex.synchronize { proceed.signal } if wait_connection
    end
  end
  mutex.synchronize { proceed.wait(mutex) } if wait_connection
end