Class: Sauce::TestBroker

Inherits:
Object
  • Object
show all
Defined in:
lib/sauce/parallel/test_broker.rb

Constant Summary collapse

CUCUMBER_CONFIG_FILES = 
["./features/support/sauce_helper.rb"]
RSPEC_CONFIG_FILES = 
["./spec/sauce_helper.rb", "./spec/spec_helper.rb", "./helper/sauce_helper.rb"]
SAUCE_USERNAME = 

      
        
SAUCE_ACCESS_KEY =
          
        

        

      
        
AUTH_DETAILS =
          
        

        
"#{SAUCE_USERNAME}:#{SAUCE_ACCESS_KEY}"

      
    

  







  
    

      Class Method Summary
      collapse
    


    
  



  

    
Class Method Details


    
      

  

  
    .concurrency  ⇒ Object 
  

  

  




  

    
      


69
70
71
72

    		
    
      
# File 'lib/sauce/parallel/test_broker.rb', line 69

def self.concurrency
  response = RestClient.get "#{rest_jobs_url}/#{SAUCE_USERNAME}/limits"
  res = JSON.parse(response)["concurrency"]
end

    		
  





    
      

  

  
    .environment_mutex  ⇒ Object 
  

  

  




  

    
      


19
20
21

    		
    
      
# File 'lib/sauce/parallel/test_broker.rb', line 19

def self.environment_mutex
  @@m ||= Mutex.new
end

    		
  





    
      

  

  
    .find_config_file(primary_files, secondary_files)  ⇒ Object 
  

  

  




  

    
      


98
99
100

    		
    
      
# File 'lib/sauce/parallel/test_broker.rb', line 98

def self.find_config_file(primary_files, secondary_files)
  find_in_file_list(primary_files) || find_in_file_list(secondary_files)
end

    		
  





    
      

  

  
    .find_in_file_list(list)  ⇒ Object 
  

  

  




  

    
      


102
103
104

    		
    
      
# File 'lib/sauce/parallel/test_broker.rb', line 102

def self.find_in_file_list(list)
  list.find { |file_path| File.exists?(file_path) }
end

    		
  





    
      

  

  
    .group_index(group)  ⇒ Object 
  

  

  




  

    
      


57
58
59

    		
    
      
# File 'lib/sauce/parallel/test_broker.rb', line 57

def self.group_index(group)
  @group_indexes[group].shift
end

    		
  





    
      

  

  
    .load_sauce_config(tool = :rspec)  ⇒ Object 
  

  

  




  

    
      


78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96

    		
    
      
# File 'lib/sauce/parallel/test_broker.rb', line 78

def self.load_sauce_config(tool=:rspec)
  case tool
    when :rspec
      primary_files = RSPEC_CONFIG_FILES
      secondary_files = CUCUMBER_CONFIG_FILES
    when :cucumber
      primary_files = CUCUMBER_CONFIG_FILES
      secondary_files = RSPEC_CONFIG_FILES
  end

  configuration_file = self.find_config_file(primary_files, secondary_files)
  unless configuration_file
    possible_config_files = primary_files + secondary_files
    error_message = "Could not find Sauce configuration. Please make sure one of the following files exists:\n"
    error_message << possible_config_files.map { |file_path| "  - #{file_path}" }.join("\n")
    raise error_message
  end
  require configuration_file
end

    		
  





    
      

  

  
    .next_environment(group)  ⇒ Object 
  

  

  




  

    
      


23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

    		
    
      
# File 'lib/sauce/parallel/test_broker.rb', line 23

def self.next_environment(group)
  environment_mutex.synchronize do
    browsers = {}
    group.each do |file|
      file = "./" + file
      test_groups[file] ||= TestGroup.new(self.test_platforms)
      browsers[file] ||= []
      browsers[file] << test_groups[file].next_platform
    end

    on_windows = RbConfig::CONFIG['host_os'] =~ /cygwin|mswin|mingw|bccwin|wince|emx/
    format_string = on_windows ? "%s" : "'%s'"
    perfile_browsers = format_string % [JSON.generate(browsers)]

    return {:SAUCE_PERFILE_BROWSERS => perfile_browsers}
  end
end

    		
  





    
      

  

  
    .reset  ⇒ Object 
  

  

  




  

    
      


12
13
14
15
16
17

    		
    
      
# File 'lib/sauce/parallel/test_broker.rb', line 12

def self.reset
  if defined? @@platforms
    remove_class_variable(:@@platforms)
  end
  @groups = {}
end

    		
  





    
      

  

  
    .rest_jobs_url  ⇒ Object 
  

  

  




  

    
      


74
75
76

    		
    
      
# File 'lib/sauce/parallel/test_broker.rb', line 74

def self.rest_jobs_url
  "https://#{AUTH_DETAILS}@saucelabs.com/rest/v1"
end

    		
  





    
      

  

  
    .test_groups  ⇒ Object 
  

  

  




  

    
      


41
42
43

    		
    
      
# File 'lib/sauce/parallel/test_broker.rb', line 41

def self.test_groups
  @groups ||= {}
end

    		
  





    
      

  

  
    .test_groups=(groups)  ⇒ Object 
  

  

  




  

    
      


45
46
47
48
49
50
51
52
53
54
55

    		
    
      
# File 'lib/sauce/parallel/test_broker.rb', line 45

def self.test_groups=(groups)
  @groups = groups.reduce({}) do |hash, g|
    hash[g] = TestGroup.new(self.test_platforms)
    hash
  end

  @group_indexes = groups.uniq.reduce({}) do |rh, g|
    rh[g] =(groups.each_index.select {|i| groups[i] == g})
    rh
  end
end

    		
  





    
      

  

  
    .test_platforms(tool = :rspec)  ⇒ Object 
  

  

  




  

    
      


61
62
63
64
65
66
67

    		
    
      
# File 'lib/sauce/parallel/test_broker.rb', line 61

def self.test_platforms(tool=:rspec)
  unless defined? @@platforms
    load_sauce_config(tool)
    @@platforms ||= Sauce.get_config[:browsers]
  end
  @@platforms
end