Class: WinRM::HTTP::HttpTransport
- Inherits:
-
Object
- Object
- WinRM::HTTP::HttpTransport
- Defined in:
- lib/winrm/http/transport.rb
Overview
A generic HTTP transport that utilized HTTPClient to send messages back and forth. This backend will maintain state for every WinRMWebService instance that is instantiated so it is possible to use GSSAPI with Keep-Alive.
Direct Known Subclasses
Constant Summary collapse
- DEFAULT_RECEIVE_TIMEOUT =
Set this to an unreasonable amount because WinRM has its own timeouts
3600
Instance Attribute Summary collapse
-
#endpoint ⇒ Object
readonly
Returns the value of attribute endpoint.
Instance Method Summary collapse
-
#basic_auth_only! ⇒ Object
We’ll need this to force basic authentication if desired.
-
#initialize(endpoint) ⇒ HttpTransport
constructor
A new instance of HttpTransport.
-
#no_ssl_peer_verification! ⇒ Object
Disable SSL Peer Verification.
-
#no_sspi_auth! ⇒ Object
Disable SSPI Auth.
- #receive_timeout ⇒ Object
-
#receive_timeout=(sec) ⇒ Object
HTTP Client receive timeout.
-
#send_request(message) ⇒ Object
Sends the SOAP payload to the WinRM service and returns the service’s SOAP response.
-
#ssl_peer_fingerprint_verification! ⇒ Object
SSL Peer Fingerprint Verification prior to connecting.
-
#verify_ssl_fingerprint(cert) ⇒ Object
compare @ssl_peer_fingerprint to current ssl context.
-
#with_untrusted_ssl_connection ⇒ Object
Connect without verification to retrieve untrusted ssl context.
Constructor Details
#initialize(endpoint) ⇒ HttpTransport
Returns a new instance of HttpTransport.
30 31 32 33 34 35 |
# File 'lib/winrm/http/transport.rb', line 30 def initialize(endpoint) @endpoint = endpoint.is_a?(String) ? URI.parse(endpoint) : endpoint @httpcli = HTTPClient.new(agent_name: 'Ruby WinRM Client') @httpcli.receive_timeout = DEFAULT_RECEIVE_TIMEOUT @logger = Logging.logger[self] end |
Instance Attribute Details
#endpoint ⇒ Object (readonly)
Returns the value of attribute endpoint.
28 29 30 |
# File 'lib/winrm/http/transport.rb', line 28 def endpoint @endpoint end |
Instance Method Details
#basic_auth_only! ⇒ Object
We’ll need this to force basic authentication if desired
55 56 57 58 |
# File 'lib/winrm/http/transport.rb', line 55 def basic_auth_only! auths = @httpcli.www_auth.instance_variable_get('@authenticator') auths.delete_if { |i| i.scheme !~ /basic/i } end |
#no_ssl_peer_verification! ⇒ Object
Disable SSL Peer Verification
67 68 69 |
# File 'lib/winrm/http/transport.rb', line 67 def no_ssl_peer_verification! @httpcli.ssl_config.verify_mode = OpenSSL::SSL::VERIFY_NONE end |
#no_sspi_auth! ⇒ Object
Disable SSPI Auth
61 62 63 64 |
# File 'lib/winrm/http/transport.rb', line 61 def no_sspi_auth! auths = @httpcli.www_auth.instance_variable_get('@authenticator') auths.delete_if { |i| i.is_a? HTTPClient::SSPINegotiateAuth } end |
#receive_timeout ⇒ Object
112 113 114 |
# File 'lib/winrm/http/transport.rb', line 112 def receive_timeout @httpcli.receive_timeout end |
#receive_timeout=(sec) ⇒ Object
HTTP Client receive timeout. How long should a remote call wait for a for a response from WinRM?
108 109 110 |
# File 'lib/winrm/http/transport.rb', line 108 def receive_timeout=(sec) @httpcli.receive_timeout = sec end |
#send_request(message) ⇒ Object
Sends the SOAP payload to the WinRM service and returns the service’s SOAP response. If an error occurrs an appropriate error is raised.
42 43 44 45 46 47 48 49 50 51 52 |
# File 'lib/winrm/http/transport.rb', line 42 def send_request() ssl_peer_fingerprint_verification! () hdr = { 'Content-Type' => 'application/soap+xml;charset=UTF-8', 'Content-Length' => .length } resp = @httpcli.post(@endpoint, , hdr) (resp.http_body.content) verify_ssl_fingerprint(resp.peer_cert) handler = WinRM::ResponseHandler.new(resp.http_body.content, resp.status) handler.parse_to_xml end |
#ssl_peer_fingerprint_verification! ⇒ Object
SSL Peer Fingerprint Verification prior to connecting
72 73 74 75 76 77 78 79 80 81 82 |
# File 'lib/winrm/http/transport.rb', line 72 def ssl_peer_fingerprint_verification! return unless @ssl_peer_fingerprint && ! @ssl_peer_fingerprint_verified with_untrusted_ssl_connection do |connection| connection_cert = connection.peer_cert_chain.last verify_ssl_fingerprint(connection_cert) end @logger.info("initial ssl fingerprint #{@ssl_peer_fingerprint} verified\n") @ssl_peer_fingerprint_verified = true no_ssl_peer_verification! end |
#verify_ssl_fingerprint(cert) ⇒ Object
compare @ssl_peer_fingerprint to current ssl context
99 100 101 102 103 104 |
# File 'lib/winrm/http/transport.rb', line 99 def verify_ssl_fingerprint(cert) return unless @ssl_peer_fingerprint conn_fingerprint = OpenSSL::Digest::SHA1.new(cert.to_der).to_s return unless @ssl_peer_fingerprint.casecmp(conn_fingerprint) != 0 fail "ssl fingerprint mismatch!!!!\n" end |
#with_untrusted_ssl_connection ⇒ Object
Connect without verification to retrieve untrusted ssl context
85 86 87 88 89 90 91 92 93 94 95 96 |
# File 'lib/winrm/http/transport.rb', line 85 def with_untrusted_ssl_connection noverify_peer_context = OpenSSL::SSL::SSLContext.new noverify_peer_context.verify_mode = OpenSSL::SSL::VERIFY_NONE tcp_connection = TCPSocket.new(@endpoint.host, @endpoint.port) begin ssl_connection = OpenSSL::SSL::SSLSocket.new(tcp_connection, noverify_peer_context) ssl_connection.connect yield ssl_connection ensure tcp_connection.close end end |