Sha256: 61011d817f2d21de610b7896d87ff549c0d523a7b9a0cf41db09c188748561d7
Contents?: true
Size: 1.89 KB
Versions: 3
Compression:
Stored size: 1.89 KB
Contents
require 'uri' require 'net/http' require 'rack' module Capybara class Server class Middleware attr_accessor :error def initialize(app) @app = app end def call(env) if env["PATH_INFO"] == "/__identify__" [200, {}, [@app.object_id.to_s]] else begin @app.call(env) rescue StandardError => e @error = e unless @error raise e end end end end class << self def ports @ports ||= {} end end attr_reader :app, :port def initialize(app, port=Capybara.server_port) @app = app @middleware = Middleware.new(@app) @server_thread = nil # supress warnings @port = port @port ||= Capybara::Server.ports[@app.object_id] @port ||= find_available_port end def reset_error! @middleware.error = nil end def error @middleware.error end def host Capybara.server_host || "127.0.0.1" end def responsive? return false if @server_thread && @server_thread.join(0) res = Net::HTTP.start(host, @port) { |http| http.get('/__identify__') } if res.is_a?(Net::HTTPSuccess) or res.is_a?(Net::HTTPRedirection) return res.body == @app.object_id.to_s end rescue SystemCallError return false end def boot unless responsive? Capybara::Server.ports[@app.object_id] = @port @server_thread = Thread.new do Capybara.server.call(@middleware, @port) end Timeout.timeout(60) { @server_thread.join(0.1) until responsive? } end rescue Timeout::Error raise "Rack application timed out during boot" else self end private def find_available_port server = TCPServer.new('127.0.0.1', 0) server.addr[1] ensure server.close if server end end end
Version data entries
3 entries across 3 versions & 2 rubygems
Version | Path |
---|---|
swipe-rails-0.0.5 | vendor/bundle/gems/capybara-2.1.0/lib/capybara/server.rb |
capybara-2.1.0 | lib/capybara/server.rb |
capybara-2.1.0.rc1 | lib/capybara/server.rb |