class Net::IMAP

# File net-imap-0.5.4/lib/net/imap.rb, line 755
def self.config; Config.global end

# File net-imap-0.5.4/lib/net/imap.rb, line 758
def self.debug; config.debug end

# File net-imap-0.5.4/lib/net/imap.rb, line 761
def self.debug=(val)
  config.debug = val
end

# File net-imap-0.5.4/lib/net/imap/data_encoding.rb, line 90
def self.decode_date(string)
  string = string.delete_prefix('"').delete_suffix('"')
  Date.strptime(string, STRFDATE)
end

# File net-imap-0.5.4/lib/net/imap/data_encoding.rb, line 112
def self.decode_datetime(string)
  unless string.start_with?(?") && string.end_with?(?")
    string = '"%s"' % [string]
  end
  DateTime.strptime(string, STRFTIME)
end

# File net-imap-0.5.4/lib/net/imap/data_encoding.rb, line 124
def self.decode_time(string)
  unless string.start_with?(?") && string.end_with?(?")
    string = '"%s"' % [string]
  end
  Time.strptime(string, STRFTIME)
end

# File net-imap-0.5.4/lib/net/imap/data_encoding.rb, line 57
def self.decode_utf7(s)
  return s.gsub(/&([A-Za-z0-9+,]+)?-/n) {
    if base64 = $1
      (base64.tr(",", "/") + "===").unpack1("m").encode(Encoding::UTF_8, Encoding::UTF_16BE)
    else
      "&"
    end
  }
end

# File net-imap-0.5.4/lib/net/imap.rb, line 766
def self.default_port
  return PORT
end

# File net-imap-0.5.4/lib/net/imap.rb, line 771
def self.default_tls_port
  return SSL_PORT
end

# File net-imap-0.5.4/lib/net/imap/data_encoding.rb, line 80
def self.encode_date(date)
  date.to_date.strftime STRFDATE
end

# File net-imap-0.5.4/lib/net/imap/data_encoding.rb, line 98
def self.encode_datetime(time)
  time.to_datetime.strftime STRFTIME
end

# File net-imap-0.5.4/lib/net/imap/data_encoding.rb, line 68
def self.encode_utf7(s)
  return s.gsub(/(&)|[^\x20-\x7e]+/) {
    if $1
      "&-"
    else
      base64 = [$&.encode(Encoding::UTF_16BE)].pack("m0")
      "&" + base64.delete("=").tr("/", ",") + "-"
    end
  }.force_encoding("ASCII-8BIT")
end

# File net-imap-0.5.4/lib/net/imap/data_encoding.rb, line 149
def self.format_datetime(time)
  warn("#{self}.format_datetime incorrectly formats IMAP date-time. " \
       "Convert to #{self}.encode_datetime or #{self}.format_time instead.",
       uplevel: 1, category: :deprecated)
  time.strftime("%d-%b-%Y %H:%M %z")
end

# File net-imap-0.5.4/lib/net/imap.rb, line 923
def initialize(host, port: nil, ssl:  nil,
               config: Config.global, **config_options)
  super()
  # Config options
  @host = host
  @config = Config.new(config, **config_options)
  @port = port || (ssl ? SSL_PORT : PORT)
  @ssl_ctx_params, @ssl_ctx = build_ssl_ctx(ssl)

  # Basic Client State
  @utf8_strings = false
  @debug_output_bol = true
  @exception = nil
  @greeting = nil
  @capabilities = nil

  # Client Protocol Receiver
  @parser = ResponseParser.new(config: @config)
  @responses = Hash.new {|h, k| h[k] = [] }
  @response_handlers = []
  @receiver_thread = nil
  @receiver_thread_exception = nil
  @receiver_thread_terminating = false

  # Client Protocol Sender (including state for currently running commands)
  @tag_prefix = "RUBY"
  @tagno = 0
  @tagged_responses = {}
  @tagged_response_arrival = new_cond
  @continued_command_tag = nil
  @continuation_request_arrival = new_cond
  @continuation_request_exception = nil
  @idle_done_cond = nil
  @logout_command_tag = nil

  # Connection
  @tls_verified = false
  @sock = tcp_socket(@host, @port)
  start_tls_session if ssl_ctx
  start_imap_connection
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3572
def self.saslprep(string, **opts)
  Net::IMAP::StringPrep::SASLprep.saslprep(string, **opts)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3081
def add_response_handler(handler = nil, &block)
  raise ArgumentError, "two Procs are passed" if handler && block
  synchronize do
    @response_handlers.push(block || handler)
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1856
def append(mailbox, message, flags = nil, date_time = nil)
  args = []
  if flags
    args.push(flags)
  end
  args.push(date_time) if date_time
  args.push(Literal.new(message))
  send_command("APPEND", mailbox, *args)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1067
def auth_capable?(mechanism)
  capable? "AUTH=#{mechanism}"
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1050
def auth_mechanisms
  capabilities
    .grep(/\AAUTH=/i)
    .map { _1.delete_prefix("AUTH=") }
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1350
def authenticate(*args, sasl_ir: config.sasl_ir, **props, &callback)
  sasl_adapter.authenticate(*args, sasl_ir: sasl_ir, **props, &callback)
    .tap { @capabilities = capabilities_from_resp_code _1 }
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1026
def capabilities
  @capabilities || capability
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1077
def capabilities_cached?
  !!@capabilities
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1115
def capability
  synchronize do
    send_command("CAPABILITY")
    @capabilities = clear_responses("CAPABILITY").last.freeze
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1012
def capable?(capability) capabilities.include? capability.to_s.upcase end

# File net-imap-0.5.4/lib/net/imap.rb, line 1872
def check
  send_command("CHECK")
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1090
def clear_cached_capabilities
  synchronize do
    clear_responses("CAPABILITY")
    @capabilities = nil
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3014
def clear_responses(type = nil)
  synchronize {
    if type
      @responses.delete(type) || []
    else
      @responses.dup.transform_values(&:freeze)
        .tap { _1.default = [].freeze }
        .tap { @responses.clear }
    end
  }
    .freeze
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1882
def close
  send_command("CLOSE")
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2578
def copy(set, mailbox)
  copy_internal("COPY", set, mailbox)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1456
def create(mailbox)
  send_command("CREATE", mailbox)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1468
def delete(mailbox)
  send_command("DELETE", mailbox)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 973
def disconnect
  return if disconnected?
  begin
    begin
      # try to call SSL::SSLSocket#io.
      @sock.io.shutdown
    rescue NoMethodError
      # @sock is not an SSL::SSLSocket.
      @sock.shutdown
    end
  rescue Errno::ENOTCONN
    # ignore `Errno::ENOTCONN: Socket is not connected' on some platforms.
  rescue Exception => e
    @receiver_thread.raise(e)
  end
  @receiver_thread.join
  synchronize do
    @sock.close
  end
  raise e if e
end

# File net-imap-0.5.4/lib/net/imap.rb, line 998
def disconnected?
  return @sock.closed?
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2789
def enable(*capabilities)
  capabilities = capabilities
    .flatten
    .map {|e| ENABLE_ALIASES[e] || e }
    .uniq
    .join(' ')
  synchronize do
    send_command("ENABLE #{capabilities}")
    result = clear_responses("ENABLED").last || []
    @utf8_strings ||= result.include? "UTF8=ACCEPT"
    @utf8_strings ||= result.include? "IMAP4REV2"
    result
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1440
def examine(mailbox, condstore: false)
  args = ["EXAMINE", mailbox]
  args << ["CONDSTORE"] if condstore
  synchronize do
    @responses.clear
    send_command(*args)
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1928
def expunge
  expunge_internal("EXPUNGE")
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3038
def extract_responses(type)
  type = String.try_convert(type) or
    raise ArgumentError, "type must be a string"
  raise ArgumentError, "must provide a block" unless block_given?
  extracted = []
  responses(type) do |all|
    all.reject! do |response|
      extracted << response if yield response
    end
  end
  extracted
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2437
def fetch(...)
  fetch_internal("FETCH", ...)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1736
def getacl(mailbox)
  synchronize do
    send_command("GETACL", mailbox)
    clear_responses("ACL").last
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1680
def getquota(mailbox)
  synchronize do
    send_command("GETQUOTA", mailbox)
    clear_responses("QUOTA")
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1659
def getquotaroot(mailbox)
  synchronize do
    send_command("GETQUOTAROOT", mailbox)
    result = []
    result.concat(clear_responses("QUOTAROOT"))
    result.concat(clear_responses("QUOTA"))
    return result
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1144
def id(client_id=nil)
  synchronize do
    send_command("ID", ClientID.new(client_id))
    clear_responses("ID").last
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2833
def idle(timeout = nil, &response_handler)
  raise LocalJumpError, "no block given" unless response_handler

  response = nil

  synchronize do
    tag = Thread.current[:net_imap_tag] = generate_tag
    put_string("#{tag} IDLE#{CRLF}")

    begin
      add_response_handler(&response_handler)
      @idle_done_cond = new_cond
      @idle_done_cond.wait(timeout)
      @idle_done_cond = nil
      if @receiver_thread_terminating
        raise @exception || Net::IMAP::Error.new("connection closed")
      end
    ensure
      unless @receiver_thread_terminating
        remove_response_handler(response_handler)
        put_string("DONE#{CRLF}")
        response = get_tagged_response(tag, "IDLE", idle_response_timeout)
      end
    end
  end

  return response
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2869
def idle_done
  synchronize do
    if @idle_done_cond.nil?
      raise Net::IMAP::Error, "not during IDLE"
    end
    @idle_done_cond.signal
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 796
def idle_response_timeout; config.idle_response_timeout end

# File net-imap-0.5.4/lib/net/imap.rb, line 1540
def list(refname, mailbox)
  synchronize do
    send_command("LIST", refname, mailbox)
    clear_responses("LIST")
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1381
def login(user, password)
  if enforce_logindisabled? && capability?("LOGINDISABLED")
    raise LoginDisabledError
  end
  send_command("LOGIN", user, password)
    .tap { @capabilities = capabilities_from_resp_code _1 }
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1172
def logout
  send_command("LOGOUT")
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1189
def logout!
  logout unless disconnected?
rescue => ex
  warn "%s during <Net::IMAP %s:%s> logout!: %s" % [
    ex.class, host, port, ex
  ]
ensure
  disconnect
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1751
def lsub(refname, mailbox)
  synchronize do
    send_command("LSUB", refname, mailbox)
    clear_responses("LSUB")
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2614
def move(set, mailbox)
  copy_internal("MOVE", set, mailbox)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1597
def namespace
  synchronize do
    send_command("NAMESPACE")
    clear_responses("NAMESPACE").last
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1163
def noop
  send_command("NOOP")
end

# File net-imap-0.5.4/lib/net/imap.rb, line 793
def open_timeout; config.open_timeout end

# File net-imap-0.5.4/lib/net/imap.rb, line 3091
def remove_response_handler(handler)
  synchronize do
    @response_handlers.delete(handler)
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1481
def rename(mailbox, newname)
  send_command("RENAME", mailbox, newname)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3064
def response_handlers
  synchronize { @response_handlers.clone.freeze }
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2980
def responses(type = nil)
  if block_given?
    synchronize { yield(type ? @responses[type.to_s.upcase] : @responses) }
  elsif type
    synchronize { @responses[type.to_s.upcase].dup.freeze }
  else
    case config.responses_without_block
    when :raise
      raise ArgumentError, RESPONSES_DEPRECATION_MSG
    when :warn
      warn(RESPONSES_DEPRECATION_MSG, uplevel: 1, category: :deprecated)
    when :frozen_dup
      synchronize {
        responses = @responses.transform_values(&:freeze)
        responses.default_proc = nil
        responses.default = [].freeze
        return responses.freeze
      }
    end
    @responses
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2369
def search(...)
  search_internal("SEARCH", ...)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1422
def select(mailbox, condstore: false)
  args = ["SELECT", mailbox]
  args << ["CONDSTORE"] if condstore
  synchronize do
    @responses.clear
    send_command(*args)
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1718
def setacl(mailbox, user, rights)
  if rights.nil?
    send_command("SETACL", mailbox, user, "")
  else
    send_command("SETACL", mailbox, user, rights)
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1698
def setquota(mailbox, quota)
  if quota.nil?
    data = '()'
  else
    data = '(STORAGE ' + quota.to_s + ')'
  end
  send_command("SETQUOTA", mailbox, RawData.new(data))
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2658
def sort(sort_keys, search_keys, charset)
  return sort_internal("SORT", sort_keys, search_keys, charset)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1229
def starttls(**options)
  @ssl_ctx_params, @ssl_ctx = build_ssl_ctx(options)
  send_command("STARTTLS") do |resp|
    if resp.kind_of?(TaggedResponse) && resp.name == "OK"
      clear_cached_capabilities
      clear_responses
      start_tls_session
    end
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1818
def status(mailbox, attr)
  synchronize do
    send_command("STATUS", mailbox, attr)
    clear_responses("STATUS").last&.attr
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2542
def store(set, attr, flags, unchangedsince: nil)
  store_internal("STORE", set, attr, flags, unchangedsince: unchangedsince)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1493
def subscribe(mailbox)
  send_command("SUBSCRIBE", mailbox)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2698
def thread(algorithm, search_keys, charset)
  return thread_internal("THREAD", algorithm, search_keys, charset)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 968
def tls_verified?; @tls_verified end

# File net-imap-0.5.4/lib/net/imap.rb, line 2591
def uid_copy(set, mailbox)
  copy_internal("UID COPY", set, mailbox)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1958
def uid_expunge(uid_set)
  expunge_internal("UID EXPUNGE", SequenceSet.new(uid_set))
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2495
def uid_fetch(...)
  fetch_internal("UID FETCH", ...)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2632
def uid_move(set, mailbox)
  copy_internal("UID MOVE", set, mailbox)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2386
def uid_search(...)
  search_internal("UID SEARCH", ...)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2673
def uid_sort(sort_keys, search_keys, charset)
  return sort_internal("UID SORT", sort_keys, search_keys, charset)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2560
def uid_store(set, attr, flags, unchangedsince: nil)
  store_internal("UID STORE", set, attr, flags, unchangedsince: unchangedsince)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 2712
def uid_thread(algorithm, search_keys, charset)
  return thread_internal("UID THREAD", algorithm, search_keys, charset)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1898
def unselect
  send_command("UNSELECT")
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1506
def unsubscribe(mailbox)
  send_command("UNSUBSCRIBE", mailbox)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 1641
def xlist(refname, mailbox)
  synchronize do
    send_command("XLIST", refname, mailbox)
    clear_responses("XLIST")
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3533
def build_ssl_ctx(ssl)
  if ssl
    params = (Hash.try_convert(ssl) || {}).freeze
    context = SSLContext.new
    context.set_params(params)
    if defined?(VerifyCallbackProc)
      context.verify_callback = VerifyCallbackProc
    end
    context.freeze
    [params, context]
  else
    false
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3270
def capabilities_from_resp_code(resp)
  return unless %w[PREAUTH OK].any? { _1.casecmp? resp.name }
  return unless (code = resp.data.code)
  return unless code.name.casecmp?("CAPABILITY")
  code.data.freeze
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3515
def coerce_search_arg_to_seqset?(obj)
  case obj
  when Set, -1, :* then true
  when Range       then true
  when Array       then obj.all? { coerce_search_array_arg_to_seqset? _1 }
  else                  obj.respond_to?(:to_sequence_set)
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3524
def coerce_search_array_arg_to_seqset?(obj)
  case obj
  when Integer then obj.positive? || obj == -1
  when String  then ResponseParser::Patterns::SEQUENCE_SET_STR.match?(obj.b)
  else
    coerce_search_arg_to_seqset?(obj)
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3401
def convert_return_opts(unconverted)
  return_opts = Array.try_convert(unconverted) or
    raise TypeError, "expected return options to be Array, got %s" % [
      unconverted.class
    ]
  return_opts.map {|opt|
    case opt
    when Symbol                 then opt.to_s
    when PartialRange::Negative then PartialRange[opt]
    when Range                  then SequenceSet[opt]
    else                             opt
    end
  }
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3484
def copy_internal(cmd, set, mailbox)
  send_command(cmd, SequenceSet.new(set), mailbox)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3339
def enforce_logindisabled?
  if config.enforce_logindisabled == :when_capabilities_cached
    capabilities_cached?
  else
    config.enforce_logindisabled
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3347
def expunge_internal(...)
  synchronize do
    send_command(...)
    expunged_array = clear_responses("EXPUNGE")
    vanished_array = extract_responses("VANISHED") { !_1.earlier? }
    if vanished_array.empty?
      expunged_array
    elsif vanished_array.length == 1
      vanished_array.first
    else
      merged_uids = SequenceSet[*vanished_array.map(&:uids)]
      VanishedData[uids: merged_uids, earlier: false]
    end
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3442
def fetch_internal(cmd, set, attr, mod = nil, partial: nil, changedsince: nil)
  set = SequenceSet[set]
  if partial
    mod ||= []
    mod << "PARTIAL" << PartialRange[partial]
  end
  if changedsince
    mod ||= []
    mod << "CHANGEDSINCE" << Integer(changedsince)
  end
  case attr
  when String then
    attr = RawData.new(attr)
  when Array then
    attr = attr.map { |arg|
      arg.is_a?(String) ? RawData.new(arg) : arg
    }
  end

  synchronize do
    clear_responses("FETCH")
    if mod
      send_command(cmd, set, attr, mod)
    else
      send_command(cmd, set, attr)
    end
    clear_responses("FETCH")
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3319
def generate_tag
  @tagno += 1
  return format("%s%04d", @tag_prefix, @tagno)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3233
def get_response
  buff = String.new
  while true
    s = @sock.gets(CRLF)
    break unless s
    buff.concat(s)
    if /\{(\d+)\}\r\n/n =~ s
      s = @sock.read($1.to_i)
      buff.concat(s)
    else
      break
    end
  end
  return nil if buff.length == 0
  if config.debug?
    $stderr.print(buff.gsub(/^/n, "S: "))
  end
  return @parser.parse(buff)
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3112
def get_server_greeting
  greeting = get_response
  raise Error, "No server greeting - connection closed" unless greeting
  record_untagged_response_code greeting
  raise ByeResponseError, greeting if greeting.name == "BYE"
  greeting
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3205
def get_tagged_response(tag, cmd, timeout = nil)
  if timeout
    deadline = Time.now + timeout
  end
  until @tagged_responses.key?(tag)
    raise @exception if @exception
    if timeout
      timeout = deadline - Time.now
      if timeout <= 0
        return nil
      end
    end
    @tagged_response_arrival.wait(timeout)
  end
  resp = @tagged_responses.delete(tag)
  case resp.name
  when /\A(?:OK)\z/ni
    return resp
  when /\A(?:NO)\z/ni
    raise NoResponseError, resp
  when /\A(?:BAD)\z/ni
    raise BadResponseError, resp
  else
    disconnect
    raise InvalidResponseError, "invalid tagged resp: %p" % [resp.raw.chomp]
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3504
def normalize_searching_criteria(criteria)
  return [RawData.new(criteria)] if criteria.is_a?(String)
  criteria.map {|i|
    if coerce_search_arg_to_seqset?(i)
      SequenceSet[i]
    else
      i
    end
  }
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3324
def put_string(str)
  @sock.print(str)
  if config.debug?
    if @debug_output_bol
      $stderr.print("C: ")
    end
    $stderr.print(str.gsub(/\n/n) { $'.empty? ? $& : "\nC: " })
    if /\n\z/n.match(str)
      @debug_output_bol = true
    else
      @debug_output_bol = false
    end
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3138
def receive_responses
  connection_closed = false
  until connection_closed
    synchronize do
      @exception = nil
    end
    begin
      resp = get_response
    rescue Exception => e
      synchronize do
        @sock.close
        @exception = e
      end
      break
    end
    unless resp
      synchronize do
        @exception = EOFError.new("end of file reached")
      end
      break
    end
    begin
      synchronize do
        case resp
        when TaggedResponse
          @tagged_responses[resp.tag] = resp
          @tagged_response_arrival.broadcast
          case resp.tag
          when @logout_command_tag
            return
          when @continued_command_tag
            @continuation_request_exception =
              RESPONSE_ERRORS[resp.name].new(resp)
            @continuation_request_arrival.signal
          end
        when UntaggedResponse
          record_untagged_response(resp)
          if resp.name == "BYE" && @logout_command_tag.nil?
            @sock.close
            @exception = ByeResponseError.new(resp)
            connection_closed = true
          end
        when ContinuationRequest
          @continuation_request_arrival.signal
        end
        @response_handlers.each do |handler|
          handler.call(resp)
        end
      end
    rescue Exception => e
      @exception = e
      synchronize do
        @tagged_response_arrival.broadcast
        @continuation_request_arrival.broadcast
      end
    end
  end
  synchronize do
    @receiver_thread_terminating = true
    @tagged_response_arrival.broadcast
    @continuation_request_arrival.broadcast
    if @idle_done_cond
      @idle_done_cond.signal
    end
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3257
def record_untagged_response(resp)
  @responses[resp.name] << resp.data
  record_untagged_response_code resp
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3263
def record_untagged_response_code(resp)
  return unless resp.data.is_a?(ResponseText)
  return unless (code = resp.data.code)
  @responses[code.name] << code.data
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3562
def sasl_adapter
  SASLAdapter.new(self, &method(:send_command_with_continuations))
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3367
def search_args(keys, charset_arg = nil, return: nil, charset: nil)
  {return:} => {return: return_kw}
  case [return_kw, keys]
  in [nil, Array[RETURN_WHOLE, return_opts, *keys]]
    return_opts = convert_return_opts(return_opts)
    esearch = true
  in [nil => return_opts, RETURN_START]
    esearch = true
  in [nil => return_opts, keys]
    esearch = false
  in [_, Array[RETURN_WHOLE, _, *] | RETURN_START]
    raise ArgumentError, "conflicting return options"
  in [_, Array[RETURN_WHOLE, _, *]] # workaround for https://bugs.ruby-lang.org/issues/20956
    raise ArgumentError, "conflicting return options"
  in [_, RETURN_START]              # workaround for https://bugs.ruby-lang.org/issues/20956
    raise ArgumentError, "conflicting return options"
  in [return_opts, keys]
    return_opts = convert_return_opts(return_opts)
    esearch = true
  end
  if charset && charset_arg
    raise ArgumentError, "multiple charset arguments"
  end
  charset ||= charset_arg
  # NOTE: not handling combined RETURN and CHARSET for raw strings
  if charset && keys in /\ACHARSET\b/i | Array[/\ACHARSET\z/i, *]
    raise ArgumentError, "multiple charset arguments"
  end
  args = normalize_searching_criteria(keys)
  args.prepend("CHARSET", charset)     if charset
  args.prepend("RETURN",  return_opts) if return_opts
  return args, esearch
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3416
def search_internal(cmd, ...)
  args, esearch = search_args(...)
  synchronize do
    tagged = send_command(cmd, *args)
    tag    = tagged.tag
    # Only the last ESEARCH or SEARCH is used.  Excess results are ignored.
    esearch_result = extract_responses("ESEARCH") {|response|
      response in ESearchResult(tag: ^tag)
    }.last
    search_result = clear_responses("SEARCH").last
    if esearch_result
      # silently ignore SEARCH results, if any
      esearch_result
    elsif search_result
      # warn EXPECTED_ESEARCH_RESULT if esearch
      search_result
    elsif esearch
      # warn NO_SEARCH_RESPONSE
      ESearchResult[tag:, uid: cmd.start_with?("UID ")]
    else
      # warn NO_SEARCH_RESPONSE
      SearchResult[]
    end
  end
end

# File net-imap-0.5.4/lib/net/imap.rb, line 3291
def send_command(cmd, *args, &block)
  synchronize do
    args.each do |i|
      validate_data(i)
    end
    tag = generate_tag
    put_string(tag + " " + cmd)
    args.each do |i|
      put_string(" ")
      send_data(i, tag)
    end
    put_string(CRLF)
    if cmd == "LOGOUT"
      @logout_command_tag = tag
    end
    if block
      add_response_handler(&block)
    end
    begin
      return get_tagged_response(tag, cmd)
    ensure
      if block
        remove_response_handler(block)
      end
    end
  end
end