Class: Async::HTTP::WebMockClientWrapper

Inherits:
Client
  • Object
show all
Defined in:
lib/webmock/http_lib_adapters/async_http_client_adapter.rb

Instance Method Summary collapse

Constructor Details

#initialize(endpoint, protocol = endpoint.protocol, scheme = endpoint.scheme, authority = endpoint.authority, **options) ⇒ WebMockClientWrapper

Returns a new instance of WebMockClientWrapper.



34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/webmock/http_lib_adapters/async_http_client_adapter.rb', line 34

def initialize(
  endpoint,
  protocol = endpoint.protocol,
  scheme = endpoint.scheme,
  authority = endpoint.authority,
  **options
)
  webmock_endpoint = WebMockEndpoint.new(scheme, authority, protocol)

  @network_client = WebMockClient.new(endpoint, **options)
  @webmock_client = WebMockClient.new(webmock_endpoint, **options)

  @scheme = scheme
  @authority = authority
end

Instance Method Details

#call(request) ⇒ Object 



50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
 
# File 'lib/webmock/http_lib_adapters/async_http_client_adapter.rb', line 50

def call(request)
  request.scheme ||= self.scheme
  request.authority ||= self.authority

  request_signature = build_request_signature(request)
  WebMock::RequestRegistry.instance.requested_signatures.put(request_signature)
  webmock_response = WebMock::StubRegistry.instance.response_for_request(request_signature)
  net_connect_allowed = WebMock.net_connect_allowed?(request_signature.uri)
  real_request = false

  if webmock_response
    webmock_response.raise_error_if_any
    raise Async::TimeoutError, 'WebMock timeout error' if webmock_response.should_timeout
    WebMockApplication.add_webmock_response(request, webmock_response)
    response = @webmock_client.call(request)
  elsif net_connect_allowed
    response = @network_client.call(request)
    real_request = true
  else
    raise WebMock::NetConnectNotAllowedError.new(request_signature) unless webmock_response
  end

  if WebMock::CallbackRegistry.any_callbacks?
    webmock_response ||= build_webmock_response(response)
    WebMock::CallbackRegistry.invoke_callbacks(
      {
        lib: :async_http_client,
        real_request: real_request
      },
      request_signature,
      webmock_response
    )
  end

  response
end

#close ⇒ Object 



87
88
89
90
 
# File 'lib/webmock/http_lib_adapters/async_http_client_adapter.rb', line 87

def close
  @network_client.close
  @webmock_client.close
end