class Selenium::Server
Wraps the remote server jar
Usage:
server = Selenium::Server.new('/path/to/selenium-server-standalone.jar') server.start
Automatically download the given version:
server = Selenium::Server.get '2.6.0' server.start
or the latest version:
server = Selenium::Server.get :latest server.start
Run the server in the background:
server = Selenium::Server.new(jar, :background => true) server.start
Add additional arguments:
server = Selenium::Server.new(jar) server << ["--additional", "args"] server.start
Constants
- CL_RESET
Attributes
The Mode of the Server
:standalone, hub, node
The Mode of the Server
:standalone, hub, node
The Mode of the Server
:standalone, hub, node
The Mode of the Server
:standalone, hub, node
The Mode of the Server
:standalone, hub, node
Public Class Methods
@api private
# File lib/selenium/server.rb, line 115 def available_assets @available_assets ||= net_http_start('api.github.com') do |http| json = http.get('/repos/seleniumhq/selenium/releases').body all_assets = JSON.parse(json).map { |release| release['assets'] }.flatten server_assets = all_assets.select { |asset| asset['name'].match(/selenium-server-(\d+\.\d+\.\d+)\.jar/) } server_assets.each_with_object({}) { |asset, hash| hash[asset.delete('name')] = asset } end end
Download the given version of the selenium-server jar and return location
@param [String, Symbol] required_version X.Y.Z defaults to ':latest' @return [String] location of downloaded file
# File lib/selenium/server.rb, line 80 def download(required_version = :latest) required_version = latest if required_version == :latest download_file_name = "selenium-server-#{required_version}.jar" return download_file_name if File.exist? download_file_name begin download_location = available_assets[download_file_name]['browser_download_url'] released = Net::HTTP.get_response(URI.parse(download_location)) redirected = URI.parse released.header['location'] File.open(download_file_name, 'wb') do |destination| download_server(redirected, destination) end rescue StandardError FileUtils.rm download_file_name if File.exist? download_file_name raise end download_file_name end
# File lib/selenium/server.rb, line 136 def download_server(uri, destination) net_http_start('github-releases.githubusercontent.com') do |http| request = Net::HTTP::Get.new uri resp = http.request(request) do |response| total = response.content_length progress = 0 segment_count = 0 response.read_body do |segment| progress += segment.length segment_count += 1 if (segment_count % 15).zero? percent = progress.fdiv(total) * 100 print "#{CL_RESET}Downloading #{destination.path}: #{percent.to_i}% (#{progress} / #{total})" segment_count = 0 end destination.write(segment) end end raise Error, "#{resp.code} for #{destination.path}" unless resp.is_a? Net::HTTPSuccess end end
Download the given version of the selenium-server jar and return instance
@param [String, Symbol] required_version X.Y.Z defaults to ':latest' @param [Hash] opts @return [Selenium::Server]
# File lib/selenium/server.rb, line 69 def get(required_version = :latest, opts = {}) new(download(required_version), opts) end
Ask GitHub what the latest selenium-server version is.
# File lib/selenium/server.rb, line 106 def latest @latest ||= begin available = available_assets.keys.map { |key| key[/selenium-server-(\d+\.\d+\.\d+)\.jar/, 1] } available.map { |asset| Gem::Version.new(asset) }.max.to_s end end
# File lib/selenium/server.rb, line 124 def net_http_start(address, &block) http_proxy = ENV.fetch('http_proxy', nil) || ENV.fetch('HTTP_PROXY', nil) if http_proxy http_proxy = "http://#{http_proxy}" unless http_proxy.start_with?('http://') uri = URI.parse(http_proxy) Net::HTTP.start(address, nil, uri.host, uri.port, &block) else Net::HTTP.start(address, use_ssl: true, &block) end end
@param [String] jar Path to the server jar. @param [Hash] opts the options to create the server process with
@option opts [Integer] :port Port the server should listen on (default: 4444). @option opts [Integer] :timeout Seconds to wait for server launch/shutdown (default: 30) @option opts [true,false] :background Run the server in the background (default: false) @option opts [true,false,String] :log Either a path to a log file,
or true to pass server log to stdout.
@raise [Errno::ENOENT] if the jar file does not exist
# File lib/selenium/server.rb, line 182 def initialize(jar, opts = {}) raise Errno::ENOENT, jar unless File.exist?(jar) @jar = jar @host = '127.0.0.1' @role = opts.fetch(:role, 'standalone') @port = opts.fetch(:port, 4444) @timeout = opts.fetch(:timeout, 30) @background = opts.fetch(:background, false) @log = opts[:log] @log_file = nil @additional_args = [] end
Public Instance Methods
# File lib/selenium/server.rb, line 219 def <<(arg) if arg.is_a?(Array) @additional_args += arg else @additional_args << arg.to_s end end
# File lib/selenium/server.rb, line 196 def start process.start poll_for_service process.wait unless @background end
# File lib/selenium/server.rb, line 203 def stop begin Net::HTTP.get(@host, '/selenium-server/driver/?cmd=shutDownSeleniumServer', @port) rescue Errno::ECONNREFUSED end stop_process if @process poll_for_shutdown @log_file&.close end
# File lib/selenium/server.rb, line 215 def webdriver_url "http://#{@host}:#{@port}/wd/hub" end
Private Instance Methods
# File lib/selenium/server.rb, line 267 def poll_for_service return if socket.connected? raise Error, "remote server not launched in #{@timeout} seconds" end
# File lib/selenium/server.rb, line 273 def poll_for_shutdown return if socket.closed? raise Error, "remote server not stopped in #{@timeout} seconds" end
# File lib/selenium/server.rb, line 243 def process @process ||= begin # extract any additional_args that start with -D as options properties = @additional_args.dup - @additional_args.delete_if { |arg| arg[/^-D/] } args = ['-jar', @jar, @role, '--port', @port.to_s] server_command = ['java'] + properties + args + @additional_args cp = ChildProcess.build(*server_command) WebDriver.logger.debug("Executing Process #{server_command}") io = cp.io if @log.is_a?(String) @log_file = File.open(@log, 'w') io.stdout = io.stderr = @log_file elsif @log io.inherit! end cp.detach = @background cp end end
# File lib/selenium/server.rb, line 279 def socket @socket ||= WebDriver::SocketPoller.new(@host, @port, @timeout) end
# File lib/selenium/server.rb, line 229 def stop_process return unless @process.alive? begin @process.poll_for_exit(5) rescue ChildProcess::TimeoutError @process.stop end rescue Errno::ECHILD # already dead ensure @process = nil end