Sha256: 39f7a22769cd86407020bf5a38f5209de5456334c5d51561683ac68a1c62b4b1
Contents?: true
Size: 1.71 KB
Versions: 21
Compression:
Stored size: 1.71 KB
Contents
module HTTP
class WebMockPerform
def initialize(request, &perform)
@request = request
@perform = perform
@request_signature = nil
end
def exec
replay || perform || halt
end
def request_signature
unless @request_signature
@request_signature = @request.webmock_signature
register_request(@request_signature)
end
@request_signature
end
protected
def response_for_request(signature)
::WebMock::StubRegistry.instance.response_for_request(signature)
end
def register_request(signature)
::WebMock::RequestRegistry.instance.requested_signatures.put(signature)
end
def replay
webmock_response = response_for_request request_signature
return unless webmock_response
raise_timeout_error if webmock_response.should_timeout
webmock_response.raise_error_if_any
invoke_callbacks(webmock_response, real_request: false)
::HTTP::Response.from_webmock @request, webmock_response, request_signature
end
def raise_timeout_error
raise Errno::ETIMEDOUT if HTTP::VERSION < "1.0.0"
raise HTTP::TimeoutError, "connection error: #{Errno::ETIMEDOUT.new}"
end
def perform
return unless ::WebMock.net_connect_allowed?(request_signature.uri)
response = @perform.call
invoke_callbacks(response.to_webmock, real_request: true)
response
end
def halt
raise ::WebMock::NetConnectNotAllowedError.new request_signature
end
def invoke_callbacks(webmock_response, options = {})
::WebMock::CallbackRegistry.invoke_callbacks(
options.merge({ lib: :http_rb }),
request_signature,
webmock_response
)
end
end
end
Version data entries
21 entries across 21 versions & 2 rubygems