Couldn\\'t load #{env["PATH_INFO"]}!
');" - ] - end - end - - class FocusedSuite - def initialize(spec_files_or_proc, options) - @spec_files_or_proc = Jasmine.files(spec_files_or_proc) || [] - @options = options - end - - def call(env) - spec_files = @spec_files_or_proc - matching_specs = spec_files.select {|spec_file| spec_file =~ /#{Regexp.escape(env["PATH_INFO"])}/ }.compact - if !matching_specs.empty? - run_adapter = Jasmine::RunAdapter.new(matching_specs, @options) - run_adapter.run - else - [ - 200, - { 'Content-Type' => 'application/javascript' }, - "document.write('Couldn\\'t find any specs matching #{env["PATH_INFO"]}!
');" - ] - end - end - - end - - class SimpleServer - def self.start(port, spec_files_or_proc, mappings, options = {}) - require 'thin' - config = { - '/__suite__' => Jasmine::FocusedSuite.new(spec_files_or_proc, options), - '/run.html' => Jasmine::Redirect.new('/'), - '/' => Jasmine::RunAdapter.new(spec_files_or_proc, options) - } - mappings.each do |from, to| - config[from] = Rack::File.new(to) - end - - config["/__JASMINE_ROOT__"] = Rack::File.new(Jasmine.root) - - app = Rack::Cascade.new([ - Rack::URLMap.new(config), - JsAlert.new - ]) - - begin - Thin::Server.start('0.0.0.0', port, app) - rescue RuntimeError => e - raise e unless e.message == 'no acceptor' - raise RuntimeError.new("A server is already running on port #{port}") - end - end - end - - class SimpleClient - def initialize(selenium_host, selenium_port, selenium_browser_start_command, http_address) - require 'selenium/client' - @driver = Selenium::Client::Driver.new( - selenium_host, - selenium_port, - selenium_browser_start_command, - http_address - ) - @http_address = http_address - end - - def tests_have_finished? - @driver.get_eval("window.jasmine.getEnv().currentRunner.finished") == "true" - end - - def connect - @driver.start - @driver.open("/") - end - - def disconnect - @driver.stop - end - - def run - until tests_have_finished? do - sleep 0.1 - end - - puts @driver.get_eval("window.results()") - failed_count = @driver.get_eval("window.jasmine.getEnv().currentRunner.results().failedCount").to_i - failed_count == 0 - end - - def eval_js(script) - escaped_script = "'" + script.gsub(/(['\\])/) { '\\' + $1 } + "'" - - result = @driver.get_eval(" try { eval(#{escaped_script}, window); } catch(err) { window.eval(#{escaped_script}); }") - JSON.parse("[#{result}]")[0] - end - end - - class Runner - def initialize(selenium_jar_path, spec_files, dir_mappings, options={}) - @selenium_jar_path = selenium_jar_path - @spec_files = spec_files - @dir_mappings = dir_mappings - @options = options - - @browser = options[:browser] ? options[:browser].delete(:browser) : 'firefox' - @selenium_pid = nil - @jasmine_server_pid = nil - @selenium_host = 'localhost' - @jasmine_server_port = Jasmine::find_unused_port - @selenium_server_port = Jasmine::find_unused_port - end - - def start - start_jasmine_server - start_selenium_server - @client = Jasmine::SimpleClient.new(@selenium_host, @selenium_server_port, "*#{@browser}", "http://localhost:#{@jasmine_server_port}/") - @client.connect - end - - def stop - @client.disconnect - stop_selenium_server - stop_jasmine_server - end - - def start_jasmine_server - @jasmine_server_pid = fork do - Process.setpgrp - Jasmine::SimpleServer.start(@jasmine_server_port, @spec_files, @dir_mappings, @options) - exit! 0 - end - puts "jasmine server started. pid is #{@jasmine_server_pid}" - Jasmine::wait_for_listener(@jasmine_server_port, "jasmine server") - end - - def start_selenium_server - @selenium_pid = fork do - Process.setpgrp - exec "java -jar #{@selenium_jar_path} -port #{@selenium_server_port} > /dev/null 2>&1" - end - puts "selenium started. pid is #{@selenium_pid}" - Jasmine::wait_for_listener(@selenium_server_port, "selenium server") - end - - def stop_jasmine_server - puts "shutting down Jasmine server..." - Jasmine::kill_process_group(@jasmine_server_pid) if @jasmine_server_pid - end - - def stop_selenium_server - puts "shutting down Selenium server..." - Jasmine::kill_process_group(@selenium_pid) if @selenium_pid - end - - def run - begin - start - puts "servers are listening on their ports -- running the test script..." - tests_passed = @client.run - ensure - stop - end - return tests_passed - end - - def eval_js(script) - @client.eval_js(script) - end - end - - class SauceLabsRunner < Runner - def initialize(spec_files, dir_mappings, options={}) - @spec_files = spec_files - @dir_mappings = dir_mappings - @options = options - - @browser = options[:browser] ? options[:browser].delete(:browser) : 'firefox' - @jasmine_server_pid = nil - @jasmine_server_port = Jasmine::find_unused_port - @saucelabs_config = SeleniumConfig.new(options[:saucelabs_config], options[:saucelabs_config_file], @jasmine_server_port) - end - - def start_selenium_server - @sauce_tunnel = SauceTunnel.new(@saucelabs_config) - end - - def start - start_jasmine_server - start_selenium_server - @client = Jasmine::SimpleClient.new(@saucelabs_config['selenium_server_address'], - 4444, - @saucelabs_config['selenium_browser_key'], - "http://#{@saucelabs_config['application_address']}") - @client.connect - end - - def stop - @client.disconnect - @sauce_tunnel.shutdown - stop_jasmine_server - end - - end - - def self.files(f) - result = f - result = result.call if result.respond_to?(:call) - result - end - -end diff --git a/contrib/ruby/jasmine_spec_builder.rb b/contrib/ruby/jasmine_spec_builder.rb deleted file mode 100644 index 260c9e2..0000000 --- a/contrib/ruby/jasmine_spec_builder.rb +++ /dev/null @@ -1,153 +0,0 @@ -require File.expand_path(File.join(File.dirname(__FILE__), "jasmine_runner.rb")) -require 'enumerator' -module Jasmine - - class SpecBuilder - attr_accessor :suites - - def initialize(spec_files, runner) - @spec_files = spec_files - @runner = runner - @spec_ids = [] - end - - def start - guess_example_locations - - @runner.start - load_suite_info - wait_for_suites_to_finish_running - end - - def stop - @runner.stop - end - - def script_path - File.expand_path(__FILE__) - end - - def guess_example_locations - @example_locations = {} - - example_name_parts = [] - previous_indent_level = 0 - @spec_files.each do |filename| - line_number = 1 - File.open(filename, "r") do |file| - file.readlines.each do |line| - match = /^(\s*)(describe|it)\s*\(\s*["'](.*)["']\s*,\s*function/.match(line) - if (match) - indent_level = match[1].length / 2 - example_name = match[3] - example_name_parts[indent_level] = example_name - - full_example_name = example_name_parts.slice(0, indent_level + 1).join(" ") - @example_locations[full_example_name] = "#{filename}:#{line_number}: in `it'" - end - line_number += 1 - end - end - end - end - - def load_suite_info - started = Time.now - while !eval_js('jsApiReporter && jsApiReporter.started') do - raise "couldn't connect to Jasmine after 60 seconds" if (started + 60 < Time.now) - sleep 0.1 - end - - @suites = eval_js('JSON.stringify(jsApiReporter.suites())') - end - - def results_for(spec_id) - @spec_results ||= load_results - @spec_results[spec_id.to_s] - end - - def load_results - @spec_results = {} - @spec_ids.each_slice(50) do |slice| - @spec_results.merge!(eval_js("JSON.stringify(jsApiReporter.resultsForSpecs(#{JSON.generate(slice)}))")) - end - @spec_results - end - - def wait_for_suites_to_finish_running - puts "Waiting for suite to finish in browser ..." - while !eval_js('jsApiReporter.finished') do - sleep 0.1 - end - end - - def declare_suites - me = self - suites.each do |suite| - declare_suite(self, suite) - end - end - - def declare_suite(parent, suite) - me = self - parent.describe suite["name"] do - suite["children"].each do |suite_or_spec| - type = suite_or_spec["type"] - if type == "suite" - me.declare_suite(self, suite_or_spec) - elsif type == "spec" - me.declare_spec(self, suite_or_spec) - else - raise "unknown type #{type} for #{suite_or_spec.inspect}" - end - end - end - end - - def declare_spec(parent, spec) - me = self - example_name = spec["name"] - @spec_ids << spec["id"] - backtrace = @example_locations[parent.description + " " + example_name] - parent.it example_name, {}, backtrace do - me.report_spec(spec["id"]) - end - end - - def report_spec(spec_id) - spec_results = results_for(spec_id) - - out = "" - messages = spec_results['messages'].each do |message| - case - when message["type"] == "MessageResult" - puts message["text"] - puts "\n" - else - unless message["message"] =~ /^Passed.$/ - STDERR << message["message"] - STDERR << "\n" - - out << message["message"] - out << "\n" - end - - if !message["passed"] && message["trace"]["stack"] - stack_trace = message["trace"]["stack"].gsub(/