Class: Tes::Request::RSpec::CiSlicer

Inherits:
Object
  • Object
show all
Defined in:
lib/tes/request/rspec/ci_slicer.rb

Constant Summary collapse

SUPPORT_FILE_TYPES = 
[:yaml, :yml, :json, :properties]

Instance Method Summary collapse

Constructor Details

#initialize(file_type, project_dir, res_replace_map_json_file = nil) ⇒ CiSlicer

Returns a new instance of CiSlicer.



10
11
12
13
14
15
16
17
18
19
 
# File 'lib/tes/request/rspec/ci_slicer.rb', line 10

def initialize(file_type, project_dir, res_replace_map_json_file=nil)
  unless SUPPORT_FILE_TYPES.include?(file_type.to_sym)
    raise(ArgumentError, "Not supported file type:#{file_type}!")
  end

  @cfg_file_type = file_type
  @project_dir = project_dir
  @res_addition_attr_map = (res_replace_map_json_file && JSON.parse(File.read(res_replace_map_json_file)))
  @cfg_target_dir = File.join(@project_dir, '.ci_jobs')
end

Instance Method Details

#gen_job_ci_params(job) ⇒ Object 



78
79
80
 
# File 'lib/tes/request/rspec/ci_slicer.rb', line 78

def gen_job_ci_params(job)
  {'RSPEC_PARAM' => get_job_rspec_run_args_str(job), 'REQUEST_ASKS' => get_job_env_profile_str(job)}
end

#get_job_env_profile_str(job, split = ';') ⇒ Object 



74
75
76
 
# File 'lib/tes/request/rspec/ci_slicer.rb', line 74

def get_job_env_profile_str(job, split=';')
  job[:profile].to_s(split)
end

#get_job_rspec_run_args_str(job, split = ' ') ⇒ Object 



68
69
70
71
72
 
# File 'lib/tes/request/rspec/ci_slicer.rb', line 68

def get_job_rspec_run_args_str(job, split=' ')
  tags_str = spec_tag_param_str(job[:tag])
  paths_str = job[:specs].join(split)
  tags_str ? (tags_str + split + paths_str) : paths_str
end

#run(ci_type, slice_count) ⇒ Object 



21
22
23
24
25
26
27
 
# File 'lib/tes/request/rspec/ci_slicer.rb', line 21

def run(ci_type, slice_count)
  puts "Generate RSpec distribute jobs #{@cfg_file_type} file for CI"
  rspec_distribute = Distribute.new(@project_dir)
  jobs = rspec_distribute.distribute_jobs(ci_type, slice_count, @res_addition_attr_map)
  save_job_files(jobs, @cfg_target_dir, @cfg_file_type)
  @cfg_target_dir
end

#save_job_files(jobs, target_dir, file_type) ⇒ Object 



42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/tes/request/rspec/ci_slicer.rb', line 42

def save_job_files(jobs, target_dir, file_type)
  unless SUPPORT_FILE_TYPES.include?(file_type)
    raise(ArgumentError, "Not supported file type:#{file_type}!")
  end

  job_configs_for_ci = jobs.map { |j| gen_job_ci_params(j) }
  FileUtils.rm_rf(target_dir)
  FileUtils.mkdir(target_dir)
  case file_type
    when :json
      save_file = File.join(target_dir, 'ci_tasks.json')
      File.open(save_file, 'w') { |f| f.write job_configs_for_ci.to_json }
      puts "Generated #{jobs.size} jobs, Stored in:#{save_file} ."
    when :yml, :yaml
      save_file = File.join(target_dir, 'ci_tasks.yml')
      File.open(save_file, 'w') { |f| f.write job_configs_for_ci.to_yaml }
      puts "Generated #{jobs.size} jobs, Stored in:#{save_file} ."
    when :properties
      job_configs_for_ci.each_with_index do |params, i|
        file = File.join(target_dir, "#{i}.properties")
        JavaProperties.write(params, file)
      end
      puts "Generated #{jobs.size} jobs, Stored in:#{target_dir}/*.properties ."
  end
end

#spec_tag_param_str(tags) ⇒ Object 



29
30
31
32
33
34
35
36
37
38
39
40
 
# File 'lib/tes/request/rspec/ci_slicer.rb', line 29

def spec_tag_param_str(tags)
  case tags
    when Array
      tags.map { |t| "--tag #{t}" }.join(' ')
    when String
      "--tag #{tags}"
    when nil
      nil
    else
      raise("不支持的类型:#{tags.class}")
  end
end