1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
require 'gem2deb/rake/spectask'
require 'socket'
require 'tmpdir'
#FIXME: revisit the skipped spec/higher_level_api/integration/message_properties_access_spec.rb
# A bug was reported upstream: https://github.com/ruby-amqp/bunny/issues/594
$skip =%w[
spec/higher_level_api/integration/message_properties_access_spec.rb
spec/higher_level_api/integration/connection_recovery_spec.rb
spec/higher_level_api/integration/connection_stop_spec.rb
spec/higher_level_api/integration/consistent_hash_exchange_spec.rb
spec/higher_level_api/integration/tls_connection_spec.rb
spec/higher_level_api/integration/toxiproxy_spec.rb
spec/higher_level_api/integration/connection_spec.rb
spec/higher_level_api/integration/publishing_edge_cases_spec.rb
spec/higher_level_api/integration/queue_declare_spec.rb
spec/issues/issue549_spec.rb
spec/unit/concurrent/synchronized_sorted_set_spec.rb
] + Dir['spec/stress/*_spec.rb']
puts "****************************************************************"
puts "WARNING: THE FOLLOWING TESTS ARE BEING SKIPPED:"
puts $skip
puts "****************************************************************"
Gem2Deb::Rake::RSpecTask.new(:spec) do |spec|
spec.pattern = Dir['spec/**/*_spec.rb'] - $skip
end
$tmpdir = Dir.mktmpdir
configfile = File.join($tmpdir, 'rabbitmq.conf')
conf = File.read('spec/config/rabbitmq.conf').gsub('/spec/tls', File.expand_path('spec/tls'))
conf.gsub!('5672', '16688')
conf.gsub!('5671', '16689')
File.open(configfile, 'w') do |f|
f.write(conf)
end
plugins = File.join($tmpdir, 'enabled_plugins')
FileUtils.cp('spec/config/enabled_plugins', plugins)
rabbitmq_env = {
'HOME' => $tmpdir,
'RABBITMQ_MNESIA_BASE' => File.join($tmpdir, 'mnesia'),
'RABBITMQ_LOG_BASE' => File.join($tmpdir, 'log'),
'RABBITMQ_NODE_IP_ADDRESS' => '127.0.0.1',
'RABBITMQ_NODENAME' => 'bunny',
'RABBITMQ_CONFIG_FILE' => configfile,
'RABBITMQ_ENABLED_PLUGINS_FILE' => plugins,
'RABBITMQ_SCHEMA_DIR' => File.join($tmpdir, 'schema'),
'RABBITMQ_GENERATED_CONFIG_DIR' => File.join($tmpdir, 'config'),
'RABBITMQ_NODE_PORT' => '16688',
'BUNNY_RABBITMQ_HOSTNAME' => '127.0.0.1:16688',
'RABBITMQ_PORT' => '16688',
'RABBITMQ_URL' => 'amqp://127.0.0.1:16688/bunny_testbed',
'ERL_EPMD_PORT' => '62222',
'BUNNY_RABBITMQCTL' => '/usr/lib/rabbitmq/bin/rabbitmqctl',
'BUNNY_RABBITMQ_PLUGINS' => '/usr/lib/rabbitmq/bin/rabbitmq-plugins',
}
puts "Setting environment:"
rabbitmq_env.each do |k,v|
puts "#{k}=#{v}"
end
ENV.update(rabbitmq_env)
$epmd = system('pgrep' , '-u', Process.uid.to_s, '-fa', 'epmd', :out => '/dev/null')
def run(*cmd)
system(*cmd) or fail("command failed: %s" % cmd.inspect)
end
def start_rabbitmq_server
fork do
exec('/usr/lib/rabbitmq/bin/rabbitmq-server')
end
pidfile = File.join($tmpdir, 'mnesia', 'bunny@' + Socket.gethostname + '.pid')
run('/usr/lib/rabbitmq/bin/rabbitmqctl', 'wait', pidfile)
run('./bin/ci/before_build')
end
def stop_rabbitmq_server
run('/usr/lib/rabbitmq/bin/rabbitmqctl', 'stop')
run('pkill', 'epmd') unless $epmd
FileUtils.rm_rf($tmpdir)
end
task :default do
start_rabbitmq_server
begin
FileUtils.cp_r("spec", $tmpdir)
chdir $tmpdir do
sh 'sed', '-i', '-e', 's/Bunny.new(/Bunny.new(port: 16688, /', *Dir['spec/**/*.rb']
Rake::Task[:spec].invoke
end
ensure
stop_rabbitmq_server
end
end
|
