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
|
# frozen_string_literal: true
# encoding: utf-8
require_relative 'helper'
class TestSidekiq < Sidekiq::Test
describe 'json processing' do
it 'handles json' do
assert_equal({"foo" => "bar"}, Sidekiq.load_json("{\"foo\":\"bar\"}"))
assert_equal "{\"foo\":\"bar\"}", Sidekiq.dump_json({ "foo" => "bar" })
end
end
describe "redis connection" do
it "returns error without creating a connection if block is not given" do
assert_raises(ArgumentError) do
Sidekiq.redis
end
end
end
describe "❨╯°□°❩╯︵┻━┻" do
before { $stdout = StringIO.new }
after { $stdout = STDOUT }
it "allows angry developers to express their emotional constitution and remedies it" do
Sidekiq.❨╯°□°❩╯︵┻━┻
assert_equal "Calm down, yo.\n", $stdout.string
end
end
describe 'lifecycle events' do
it 'handles invalid input' do
Sidekiq.options[:lifecycle_events][:startup].clear
e = assert_raises ArgumentError do
Sidekiq.on(:startp)
end
assert_match(/Invalid event name/, e.message)
e = assert_raises ArgumentError do
Sidekiq.on('startup')
end
assert_match(/Symbols only/, e.message)
Sidekiq.on(:startup) do
1 + 1
end
assert_equal 2, Sidekiq.options[:lifecycle_events][:startup].first.call
end
end
describe 'default_worker_options' do
it 'stringifies keys' do
@old_options = Sidekiq.default_worker_options
begin
Sidekiq.default_worker_options = { queue: 'cat'}
assert_equal 'cat', Sidekiq.default_worker_options['queue']
ensure
Sidekiq.default_worker_options = @old_options
end
end
end
describe 'error handling' do
it 'deals with user-specified error handlers which raise errors' do
output = capture_logging do
begin
Sidekiq.error_handlers << proc {|x, hash|
raise 'boom'
}
cli = Sidekiq::CLI.new
cli.handle_exception(RuntimeError.new("hello"))
ensure
Sidekiq.error_handlers.pop
end
end
assert_includes output, "boom"
assert_includes output, "ERROR"
end
end
describe 'redis connection' do
it 'does not continually retry' do
assert_raises Redis::CommandError do
Sidekiq.redis do |c|
raise Redis::CommandError, "READONLY You can't write against a read only slave."
end
end
end
it 'reconnects if connection is flagged as readonly' do
counts = []
Sidekiq.redis do |c|
counts << c.info['total_connections_received'].to_i
raise Redis::CommandError, "READONLY You can't write against a read only slave." if counts.size == 1
end
assert_equal 2, counts.size
assert_equal counts[0] + 1, counts[1]
end
end
describe 'redis info' do
it 'calls the INFO command which returns at least redis_version' do
output = Sidekiq.redis_info
assert_includes output.keys, "redis_version"
end
end
end
|
