class RubyLsp::Rails::RunnerClient

# File lib/ruby_lsp/ruby_lsp_rails/runner_client.rb, line 14
        def create_client
          if File.exist?("bin/rails")
            new
          else
            $stderr.puts(<<~MSG)
              Ruby LSP Rails failed to locate bin/rails in the current directory: #{Dir.pwd}"
            MSG
            $stderr.puts("Server dependent features will not be available")
            NullClient.new
          end
        rescue Errno::ENOENT, StandardError => e # rubocop:disable Lint/ShadowedException
          $stderr.puts("Ruby LSP Rails failed to initialize server: #{e.message}\n#{e.backtrace&.join("\n")}")
          $stderr.puts("Server dependent features will not be available")
          NullClient.new
        end

# File lib/ruby_lsp/ruby_lsp_rails/runner_client.rb, line 40
def initialize
  # Spring needs a Process session ID. It uses this ID to "attach" itself to the parent process, so that when the
  # parent ends, the spring process ends as well. If this is not set, Spring will throw an error while trying to
  # set its own session ID
  begin
    Process.setpgrp
    Process.setsid
  rescue Errno::EPERM
    # If we can't set the session ID, continue
  rescue NotImplementedError
    # setpgrp() may be unimplemented on some platform
    # https://github.com/Shopify/ruby-lsp-rails/issues/348
  end

  stdin, stdout, stderr, wait_thread = Bundler.with_original_env do
    Open3.popen3("bundle", "exec", "rails", "runner", "#{__dir__}/server.rb", "start")
  end

  @stdin = T.let(stdin, IO)
  @stdout = T.let(stdout, IO)
  @stderr = T.let(stderr, IO)
  @wait_thread = T.let(wait_thread, Process::Waiter)
  @stdin.binmode # for Windows compatibility
  @stdout.binmode # for Windows compatibility

  $stderr.puts("Ruby LSP Rails booting server")
  count = 0

  begin
    count += 1
    read_response
  rescue EmptyMessageError
    $stderr.puts("Ruby LSP Rails is retrying initialize (#{count})")
    retry if count < MAX_RETRIES
  end

  $stderr.puts("Finished booting Ruby LSP Rails server")

  unless ENV["RAILS_ENV"] == "test"
    at_exit do
      if @wait_thread.alive?
        $stderr.puts("Ruby LSP Rails is force killing the server")
        sleep(0.5) # give the server a bit of time if we already issued a shutdown notification

        # Windows does not support the `TERM` signal, so we're forced to use `KILL` here
        Process.kill(T.must(Signal.list["KILL"]), @wait_thread.pid)
      end
    end
  end
rescue Errno::EPIPE, IncompleteMessageError
  raise InitializationError, @stderr.read
end

# File lib/ruby_lsp/ruby_lsp_rails/runner_client.rb, line 94
def model(name)
  make_request("model", name: name)
rescue IncompleteMessageError
  $stderr.puts("Ruby LSP Rails failed to get model information: #{@stderr.read}")
  nil
end

# File lib/ruby_lsp/ruby_lsp_rails/runner_client.rb, line 102
def route_location(name)
  make_request("route_location", name: name)
rescue IncompleteMessageError
  $stderr.puts("Ruby LSP Rails failed to get route location: #{@stderr.read}")
  nil
end

# File lib/ruby_lsp/ruby_lsp_rails/runner_client.rb, line 119
def shutdown
  $stderr.puts("Ruby LSP Rails shutting down server")
  send_message("shutdown")
  sleep(0.5) # give the server a bit of time to shutdown
  [@stdin, @stdout, @stderr].each(&:close)
end

# File lib/ruby_lsp/ruby_lsp_rails/runner_client.rb, line 127
def stopped?
  [@stdin, @stdout, @stderr].all?(&:closed?) && !@wait_thread.alive?
end

# File lib/ruby_lsp/ruby_lsp_rails/runner_client.rb, line 110
def trigger_reload
  $stderr.puts("Reloading Rails application")
  send_notification("reload")
rescue IncompleteMessageError
  $stderr.puts("Ruby LSP Rails failed to trigger reload")
  nil
end