mirror of
https://github.com/endofunky/sidetiq.git
synced 2022-11-09 13:53:30 -05:00
90 lines
2 KiB
Ruby
90 lines
2 KiB
Ruby
require_relative 'helper'
|
|
|
|
class TestLockMetaData < Sidetiq::TestCase
|
|
def new_without_params
|
|
md = Sidetiq::Lock::MetaData.new
|
|
|
|
assert_nil md.owner
|
|
assert_nil md.timestamp
|
|
assert_nil md.key
|
|
end
|
|
|
|
def new_with_empty_hash
|
|
md = Sidetiq::Lock::MetaData.new({})
|
|
|
|
assert_nil md.owner
|
|
assert_nil md.timestamp
|
|
assert_nil md.key
|
|
end
|
|
|
|
def test_from_json
|
|
json = { timestamp: 42, owner: "me", key: "foobar" }.to_json
|
|
md = Sidetiq::Lock::MetaData.from_json(json)
|
|
|
|
assert_equal 42, md.timestamp
|
|
assert_equal "me", md.owner
|
|
assert_equal "foobar", md.key
|
|
end
|
|
|
|
def test_from_json_with_empty_string_json
|
|
md = Sidetiq::Lock::MetaData.from_json(nil)
|
|
|
|
assert_nil md.owner
|
|
assert_nil md.timestamp
|
|
assert_nil md.key
|
|
end
|
|
|
|
def test_from_json_with_nil_json
|
|
md = Sidetiq::Lock::MetaData.from_json("")
|
|
|
|
assert_nil md.owner
|
|
assert_nil md.timestamp
|
|
assert_nil md.key
|
|
end
|
|
|
|
def test_pttl
|
|
lock = Sidetiq::Lock::Redis.new("foobar", 1000000)
|
|
md = Sidekiq.redis do |r|
|
|
lock.lock
|
|
Sidetiq::Lock::MetaData.from_json(r.get(lock.key))
|
|
end
|
|
|
|
# Allow 10 ms.
|
|
assert md.pttl <= 1000000
|
|
assert md.pttl > 999990
|
|
end
|
|
|
|
def test_from_json_with_malformed_json
|
|
Sidetiq::Lock::MetaData.expects(:handle_exception).once
|
|
|
|
md = Sidetiq::Lock::MetaData.from_json('invalid')
|
|
|
|
assert_nil md.owner
|
|
assert_nil md.timestamp
|
|
assert_nil md.key
|
|
end
|
|
|
|
def test_for_new_lock
|
|
md = Sidetiq::Lock::MetaData.for_new_lock("baz")
|
|
|
|
assert_equal Sidetiq::Lock::MetaData::OWNER, md.owner
|
|
assert_equal "baz", md.key
|
|
|
|
assert md.timestamp > 0
|
|
assert md.timestamp <= Time.now.to_f
|
|
end
|
|
|
|
def test_to_json
|
|
hash = { timestamp: 42, owner: "me", key: "foobar" }
|
|
md = Sidetiq::Lock::MetaData.new(hash)
|
|
|
|
assert_equal hash, Sidekiq.load_json(md.to_json).symbolize_keys
|
|
end
|
|
|
|
def test_to_s
|
|
md = Sidetiq::Lock::MetaData.new(timestamp: 42, owner: "me", key: "foobar")
|
|
|
|
assert_equal "Sidetiq::Lock on foobar set at 42 by me", md.to_s
|
|
end
|
|
end
|
|
|