Class: Testjour::CLI::LocalRun
Instance Attribute Summary
Attributes inherited from BaseCommand
#non_options, #options
Class Method Summary
collapse
Instance Method Summary
collapse
Methods inherited from BaseCommand
detailed_help, help, inherited, #option_parser, options, #testjour_bin_path
Constructor Details
#initialize(parser, args) ⇒ LocalRun
Returns a new instance of LocalRun.
18
19
20
21
22
|
# File 'lib/testjour/commands/local_run.rb', line 18
def initialize(parser, args)
Testjour.logger.debug "Runner command #{self.class}..."
super
@queue = @non_options.shift
end
|
Class Method Details
.command ⇒ Object
14
15
16
|
# File 'lib/testjour/commands/local_run.rb', line 14
def self.command
"local:run"
end
|
Instance Method Details
#drb_uri ⇒ Object
78
79
80
81
82
83
84
|
# File 'lib/testjour/commands/local_run.rb', line 78
def drb_uri
uri = URI.parse(@queue)
uri.scheme = "druby"
uri.path = ""
uri.user = nil
uri.to_s
end
|
#feature_parser ⇒ Object
86
87
88
|
# File 'lib/testjour/commands/local_run.rb', line 86
def feature_parser
@feature_parser ||= Cucumber::TreetopParser::FeatureParser.new
end
|
#options_for_cucumber ⇒ Object
61
62
63
|
# File 'lib/testjour/commands/local_run.rb', line 61
def options_for_cucumber
@non_options
end
|
#queue_server ⇒ Object
71
72
73
74
75
76
|
# File 'lib/testjour/commands/local_run.rb', line 71
def queue_server
@queue_server ||= begin
DRb.start_service
DRbObject.new(nil, drb_uri)
end
end
|
#require_files ⇒ Object
54
55
56
57
58
59
|
# File 'lib/testjour/commands/local_run.rb', line 54
def require_files
cli = Cucumber::CLI.new
Testjour.logger.debug "Cucumber options: #{options_for_cucumber.inspect}"
cli.parse_options!(options_for_cucumber)
cli.send(:require_files)
end
|
#run ⇒ Object
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
|
# File 'lib/testjour/commands/local_run.rb', line 24
def run
ARGV.clear Testjour.load_cucumber
status, stdout, stderr = systemu("#{testjour_bin_path} mysql:create")
database_name = stdout.split.last.strip
Testjour.logger.info "MySQL db name: #{database_name.inspect}"
Cucumber::CLI.executor.formatters = Testjour::DRbFormatter.new(queue_server)
require_files
work
status, stdout, stderr = systemu("#{testjour_bin_path} mysql:drop #{database_name}")
Testjour.logger.info "Dropped MySQL db: #{status.inspect}, #{stdout.inspect}, #{stderr.inspect}"
end
|
#run_file(file) ⇒ Object
65
66
67
68
69
|
# File 'lib/testjour/commands/local_run.rb', line 65
def run_file(file)
Testjour.logger.debug "Running feature file: #{file}"
features = feature_parser.parse_feature(File.expand_path(file))
Cucumber::CLI.executor.visit_features(features)
end
|
#work ⇒ Object
40
41
42
43
44
45
46
47
48
49
50
51
52
|
# File 'lib/testjour/commands/local_run.rb', line 40
def work
begin
loop do
begin
run_file(queue_server.take_work)
rescue Testjour::QueueServer::NoWorkUnitsAvailableError
end
end
rescue DRb::DRbConnError
Testjour.logger.debug "DRb connection error. (This is normal.) Exiting runner."
end
end
|