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
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
|
require 'rbconfig'
# use Debian-specific Gemfile
ENV['BUNDLE_GEMFILE'] = 'debian/ruby-tests.gemfile'
# generic class for running tests which require a service
class TestService
require 'tmpdir'
require 'socket'
DATADIR = Dir.mktmpdir('moneta')
@@port = nil
def initialize
(1025..3600).to_a.shuffle.each do |port|
begin
s = TCPSocket.new '127.0.0.1', port
s.close
rescue Errno::ECONNREFUSED
@@port = port
break
end
end
unless @@port
$stderr.puts "Unable to find a free TCP port to start the service."
exit 1
end
end
def teardown
if File.exist? DATADIR
FileUtils.remove_entry_secure DATADIR
end
end
end
# prepare mysql and run tests
class TestMysql < TestService
def initialize
super
started = system(File.expand_path('../setup-mysql.sh', __FILE__),
@@port.to_s, DATADIR, 'start')
unless started
$stderr.puts "Unable to start the test MySQL server."
exit 1
end
at_exit do
self.teardown
end
end
def run
ENV['MYSQL_SOCKET'] = File.join(DATADIR, 'mysql.sock')
result = system("bundle exec rspec -t mysql -- spec/moneta")
self.teardown
return result
end
def teardown
system File.expand_path('../setup-mysql.sh', __FILE__),
@@port.to_s, DATADIR, 'stop'
super
end
end
# prepare postgresql and run tests
class TestPostgres < TestService
def initialize
super
started = system(File.expand_path('../setup-pgsql.sh', __FILE__),
DATADIR, @@port.to_s)
unless started
$stderr.puts "Unable to start the test PostgreSQL server."
exit 1
end
at_exit do
self.teardown
end
end
def run
ENV['PGUSER'] = 'moneta'
ENV['PGPORT'] = @@port.to_s
result = system("bundle exec rspec -t postgres -- spec/moneta")
self.teardown
return result
end
def teardown
system("pg_ctl stop -D #{DATADIR} -m immediate")
super
end
end
# run most tests which do not require service setup/teardown
class TestParallel
def run
include_tests = []
include_tests += Dir.glob('spec/moneta/*_spec.rb')
include_tests += Dir.glob('spec/moneta/adapters/*/').reject do |f|
# bindings missing in Debian
f.match(%r{(cassandra|couch|daybreak|fog|gdbm|hbase|leveldb|lmdb|localmemcache|memcached|riak|sdbm|tdb|tokyotyrant)/$}) or
# needs external database to run
f.match(%r{(activerecord|activesupportcache|mongo|redis|sequel)/$}) or
# specific exclusions below
f.match(%r{(memory|client)/$})
end
include_tests += Dir.glob('spec/moneta/adapters/client/*_spec.rb').reject do |f|
# too flaky on ci.debian.net
f.match(%r{standard_client_tcp})
end
include_tests += Dir.glob('spec/moneta/adapters/memory/*_spec.rb').reject do |f|
# ruby snappy binding missing
f.match(%r{with_snappy_compress})
end
include_tests += Dir.glob('spec/moneta/proxies/*/').reject do |f|
# missing gems fog/aws and gdbm gems in Debian
f.match(%r{(shared|weak_create|weak_each_key|weak_increment)/$}) or
# exclusions below
f.match(%r{transformer/$})
end
include_tests += Dir.glob('spec/moneta/proxies/transformer/*_spec.rb').reject do |f|
# missing bindings in Debian
f.match(%r{(bencode|bzip2|city[0-9]+|lz4|lzma|lzo|php|snappy|tnet)_spec}) or
# the yaml specs here are broken currently w/ Ruby 3.1
f.match(%r{yaml_spec})
end
include_tests += Dir.glob('test/*/').reject do |f|
# not packaged in Debian
f.match(%r{action_dispatch/$})
end
# ruby-rack-cache needs updating
#include_tests += Dir.glob('spec/rack/*_spec.rb')
ruby = File.join(RbConfig::CONFIG['bindir'], RbConfig::CONFIG['ruby_install_name'])
return system("#{ruby} script/parallel-tests -- #{include_tests.join(' ')}")
end
end
class TestSqlite
def run
return system("bundle exec rspec -t sqlite -- spec/moneta")
end
end
rc = 0
# TODO: re-enable mysql and postgresql tests
#
for test in [TestParallel, TestSqlite] do
t = test.new
unless t.run
rc = 1
end
end
exit rc
|
