Sha256: 1b2692e11bd2e60bcd9db3cffc58e919b8017ec044c173fc01840161469ac3d2
Contents?: true
Size: 1.41 KB
Versions: 12
Compression:
Stored size: 1.41 KB
Contents
module Pact
module Consumer
class MockServiceClient
def initialize name, port
@http = Net::HTTP.new('localhost', port)
end
def verify example_description
response = http.request_get("/verify?example_description=#{URI.encode(example_description)}")
raise response.body unless response.is_a? Net::HTTPSuccess
end
def wait_for_interactions wait_max_seconds, poll_interval
wait_until_true(wait_max_seconds, poll_interval) do
response = http.request_get("/number_of_missing_interactions")
response.body == '0'
end
end
def clear_interactions example_description
http.delete("/interactions?example_description=#{URI.encode(example_description)}")
end
def add_expected_interaction interaction
http.request_post('/interactions', interaction.to_json_for_mock_service)
end
def self.clear_interactions port, example_description
Net::HTTP.new("localhost", port).delete("/interactions?example_description=#{URI.encode(example_description)}")
end
private
attr_reader :http
#todo: in need a better home (where can we move it?)
def wait_until_true timeout=3, interval=0.1
time_limit = Time.now + timeout
loop do
result = yield
return if result || Time.now >= time_limit
sleep interval
end
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems