Module: Analysand::ConnectionTesting

Includes:
Celluloid::Logger
Included in:
ChangeWatcher
Defined in:
lib/analysand/connection_testing.rb

Instance Method Summary collapse

Instance Method Details

#test_http_connection(uri) ⇒ Object

Issues a HEAD request to the given URI. If it responds with a success or redirection code, returns true; otherwise, returns false.

If a block is given, yields the request object for customization.



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/analysand/connection_testing.rb', line 12

def test_http_connection(uri)
  begin
    resp = Net::HTTP.start(uri.host, uri.port) do |h|
      req = Net::HTTP::Head.new(uri.request_uri)
      yield req if block_given?
      h.request(req)
    end

    case resp
    when Net::HTTPSuccess then true
    when Net::HTTPRedirection then true
    else
      error "Expected HEAD #{uri.to_s} to return 200, got #{resp.code} (#{resp.body}) instead"
      false
    end
  rescue => e
    error "#{e.class} (#{e.message}) caught while attempting connection to #{uri.to_s}"
    error e.backtrace.join("\n")
    false
  end
end

#wait_for_http_service(uri, timeout = 30) ⇒ Object

Periodically checks a URI for success using test_http_connection, and raises an error if test_http_connection does not return success before the timeout is reached.



38
39
40
41
42
43
44
45
46
47
48
49
50
 
# File 'lib/analysand/connection_testing.rb', line 38

def wait_for_http_service(uri, timeout = 30)
  state = 1.upto(timeout) do
    if test_http_connection(Catalog::Settings.solr_uri)
      break :started
    else
      sleep 1
    end
  end

  unless state == :started
    raise "#{uri.to_s} took longer than #{timeout} seconds to return a success response"
  end
end