class Net::SMTP

# File lib/net/smtp.rb, line 175
def SMTP.default_port
  25
end

# File lib/net/smtp.rb, line 193
def SMTP.default_ssl_context
  OpenSSL::SSL::SSLContext.new
end

# File lib/net/smtp.rb, line 180
def SMTP.default_submission_port
  587
end

# File lib/net/smtp.rb, line 185
def SMTP.default_tls_port
  465
end

# File lib/net/smtp.rb, line 208
def initialize(address, port = nil)
  @address = address
  @port = (port || SMTP.default_port)
  @esmtp = true
  @capabilities = nil
  @socket = nil
  @started = false
  @open_timeout = 30
  @read_timeout = 60
  @error_occurred = false
  @debug_output = nil
  @tls = false
  @starttls = false
  @ssl_context = nil
end

# File lib/net/smtp.rb, line 452
def SMTP.start(address, port = nil, helo = 'localhost',
               user = nil, secret = nil, authtype = nil,
               &block)   # :yield: smtp
  new(address, port).start(helo, user, secret, authtype, &block)
end

# File lib/net/smtp.rb, line 271
def auth_capable?(type)
  return nil unless @capabilities
  return false unless @capabilities['AUTH']
  @capabilities['AUTH'].include?(type)
end

# File lib/net/smtp.rb, line 771
def auth_method(type)
  "auth_#{type.to_s.downcase}".intern
end

# File lib/net/smtp.rb, line 784
def base64_encode(str)
  # expects "str" may not become too long
  [str].pack('m0')
end

# File lib/net/smtp.rb, line 247
def capable?(key)
  return nil unless @capabilities
  @capabilities[key] ? true : false
end

# File lib/net/smtp.rb, line 775
def check_auth_args(user, secret, authtype = DEFAULT_AUTH_TYPE)
  unless user
    raise ArgumentError, 'SMTP-AUTH requested but missing user name'
  end
  unless secret
    raise ArgumentError, 'SMTP-AUTH requested but missing secret phrase'
  end
end

# File lib/net/smtp.rb, line 985
def check_auth_continue(res)
  unless res.continue?
    raise res.exception_class, res.message
  end
end

# File lib/net/smtp.rb, line 765
def check_auth_method(type)
  unless respond_to?(auth_method(type), true)
    raise ArgumentError, "wrong authentication type #{type}"
  end
end

# File lib/net/smtp.rb, line 979
def check_auth_response(res)
  unless res.success?
    raise SMTPAuthenticationError, res.message
  end
end

# File lib/net/smtp.rb, line 973
def check_continue(res)
  unless res.continue?
    raise SMTPUnknownError, "could not get 3xx (#{res.status}: #{res.string})"
  end
end

# File lib/net/smtp.rb, line 967
def check_response(res)
  unless res.success?
    raise res.exception_class, res.message
  end
end

# File lib/net/smtp.rb, line 793
def cram_md5_response(secret, challenge)
  tmp = Digest::MD5.digest(cram_secret(secret, IMASK) + challenge)
  Digest::MD5.hexdigest(cram_secret(secret, OMASK) + tmp)
end

# File lib/net/smtp.rb, line 800
def cram_secret(secret, mask)
  secret = Digest::MD5.digest(secret) if secret.size > CRAM_BUFSIZE
  buf = secret.ljust(CRAM_BUFSIZE, "\0")
  0.upto(buf.size - 1) do |i|
    buf[i] = (buf[i].ord ^ mask).chr
  end
  buf
end

# File lib/net/smtp.rb, line 957
def critical
  return Response.parse('200 dummy reply code') if @error_occurred
  begin
    return yield()
  rescue Exception
    @error_occurred = true
    raise
  end
end

# File lib/net/smtp.rb, line 611
def do_finish
  quit if @socket and not @socket.closed? and not @error_occurred
ensure
  @started = false
  @error_occurred = false
  @socket.close if @socket
  @socket = nil
end

# File lib/net/smtp.rb, line 599
def do_helo(helo_domain)
  res = @esmtp ? ehlo(helo_domain) : helo(helo_domain)
  @capabilities = res.capabilities
rescue SMTPError
  if @esmtp
    @esmtp = false
    @error_occurred = false
    retry
  end
  raise
end

# File lib/net/smtp.rb, line 542
def do_start(helo_domain, user, secret, authtype)
  raise IOError, 'SMTP session already started' if @started
  if user or secret
    check_auth_method(authtype || DEFAULT_AUTH_TYPE)
    check_auth_args user, secret
  end
  s = Timeout.timeout(@open_timeout, Net::OpenTimeout) do
    tcp_socket(@address, @port)
  end
  logging "Connection opened: #{@address}:#{@port}"
  @socket = new_internet_message_io(tls? ? tlsconnect(s) : s)
  check_response critical { recv_response() }
  do_helo helo_domain
  if starttls_always? or (capable_starttls? and starttls_auto?)
    unless capable_starttls?
      raise SMTPUnsupportedCommand,
          "STARTTLS is not supported on this server"
    end
    starttls
    @socket = new_internet_message_io(tlsconnect(s))
    # helo response may be different after STARTTLS
    do_helo helo_domain
  end
  authenticate user, secret, (authtype || DEFAULT_AUTH_TYPE) if user
  @started = true
ensure
  unless @started
    # authentication failed, cancel connection.
    s.close if s
    @socket = nil
  end
end

# File lib/net/smtp.rb, line 941
def get_response(reqline)
  validate_line reqline
  @socket.writeline reqline
  recv_response()
end

# File lib/net/smtp.rb, line 931
def getok(reqline)
  validate_line reqline
  res = critical {
    @socket.writeline reqline
    recv_response()
  }
  check_response res
  res
end

# File lib/net/smtp.rb, line 1070
def logging(msg)
  @debug_output << msg + "\n" if @debug_output
end

# File lib/net/smtp.rb, line 594
def new_internet_message_io(s)
  InternetMessageIO.new(s, read_timeout: @read_timeout,
                        debug_output: @debug_output)
end

# File lib/net/smtp.rb, line 947
def recv_response
  buf = ''.dup
  while true
    line = @socket.readline
    buf << line << "\n"
    break unless line[3,1] == '-'   # "210-PIPELINING"
  end
  Response.parse(buf)
end

# File lib/net/smtp.rb, line 575
def ssl_socket(socket, context)
  OpenSSL::SSL::SSLSocket.new socket, context
end

# File lib/net/smtp.rb, line 538
def tcp_socket(address, port)
  TCPSocket.open address, port
end

# File lib/net/smtp.rb, line 579
def tlsconnect(s)
  verified = false
  s = ssl_socket(s, @ssl_context)
  logging "TLS connection started"
  s.sync_close = true
  ssl_socket_connect(s, @open_timeout)
  if @ssl_context.verify_mode != OpenSSL::SSL::VERIFY_NONE
    s.post_connection_check(@address)
  end
  verified = true
  s
ensure
  s.close unless verified
end

# File lib/net/smtp.rb, line 924
def validate_line(line)
  # A bare CR or LF is not allowed in RFC5321.
  if /[\r\n]/ =~ line
    raise ArgumentError, "A line must not contain CR or LF"
  end
end