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
# 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)

  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)
  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: net_connect_allowed
      },
      request_signature,
      webmock_response
    )
  end

  response
end

#closeObject


85
86
87
88
# File 'lib/webmock/http_lib_adapters/async_http_client_adapter.rb', line 85

def close
  @network_client.close
  @webmock_client.close
end