Class: HTTPX::SSL

Inherits:
TCP
  • Object
show all
Defined in:
lib/httpx/io/ssl.rb

Direct Known Subclasses

ProxySSL

Constant Summary collapse

TLS_OPTIONS = 
if OpenSSL::SSL::SSLContext.instance_methods.include?(:alpn_protocols)
  { alpn_protocols: %w[h2 http/1.1] }
else
  {}
end

Constants included from Loggable

Loggable::COLORS

Instance Attribute Summary

Attributes inherited from TCP

#ip, #port

Instance Method Summary collapse

Methods inherited from TCP

#closed?, #to_io

Methods included from Loggable

#log

Constructor Details

#initialize(_, options) ⇒ SSL

Returns a new instance of SSL.



13
14
15
16
17
18
19
 
# File 'lib/httpx/io/ssl.rb', line 13

def initialize(_, options)
  @ctx = OpenSSL::SSL::SSLContext.new
  ctx_options = TLS_OPTIONS.merge(options.ssl)
  @ctx.set_params(ctx_options) unless ctx_options.empty?
  super
  @state = :negotiated if @keep_open
end

Instance Method Details

#close ⇒ Object 



31
32
33
34
35
36
37
 
# File 'lib/httpx/io/ssl.rb', line 31

def close
  super
  # allow reconnections
  # connect only works if initial @io is a socket
  @io = @io.io if @io.respond_to?(:io)
  @negotiated = false
end

#connect ⇒ Object 



43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
 
# File 'lib/httpx/io/ssl.rb', line 43

def connect
  super
  if @keep_open
    @state = :negotiated
    return
  end
  return if @state == :negotiated ||
            @state != :connected
  unless @io.is_a?(OpenSSL::SSL::SSLSocket)
    @io = OpenSSL::SSL::SSLSocket.new(@io, @ctx)
    @io.hostname = @hostname
    @io.sync_close = true
  end
  @io.connect_nonblock
  @io.post_connection_check(@hostname) if @ctx.verify_mode != OpenSSL::SSL::VERIFY_NONE
  transition(:negotiated)
rescue ::IO::WaitReadable,
       ::IO::WaitWritable
end

#connected? ⇒ Boolean

Returns:

  • (Boolean) 


39
40
41
 
# File 'lib/httpx/io/ssl.rb', line 39

def connected?
  @state == :negotiated
end

#inspect ⇒ Object 



89
90
91
92
 
# File 'lib/httpx/io/ssl.rb', line 89

def inspect
  id = @io.closed? ? "closed" : @io.to_io.fileno
  "#<SSL(fd: #{id}): #{@ip}:#{@port} state: #{@state}>"
end

#protocol ⇒ Object 



25
26
27
28
29
 
# File 'lib/httpx/io/ssl.rb', line 25

def protocol
  @io.alpn_protocol || super
rescue StandardError
  super
end

#read(size, buffer) ⇒ Object 



64
65
66
67
68
 
# File 'lib/httpx/io/ssl.rb', line 64

def read(*)
  super
rescue ::IO::WaitWritable
  0
end

#scheme ⇒ Object 



21
22
23
 
# File 'lib/httpx/io/ssl.rb', line 21

def scheme
  "https"
end

#write ⇒ Object 



70
71
72
73
74
 
# File 'lib/httpx/io/ssl.rb', line 70

def write(*)
  super
rescue ::IO::WaitReadable
  0
end