require_relative "../test_helper" class RedisStoreTest < Minitest::Test def setup @scope = ["walrus", "1234"] @progress = Progressrus.new( scope: @scope, id: "oemg", total: 100, name: "oemg-name" ) @another_progress = Progressrus.new( scope: @scope, id: "oemg-two", total: 100, name: "oemg-name-two" ) @store = Progressrus::Store::Redis.new(::Redis.new(host: ENV["PROGRESSRUS_REDIS_HOST"] || "localhost")) end def teardown @store.flush(@scope) end def test_persist_should_set_key_value_if_outdated @store.persist(@progress) assert_equal 'oemg', @store.find(['walrus', '1234'], 'oemg').id end def test_persist_should_not_set_key_value_if_not_outdated @store.redis.expects(:hset).once @store.persist(@progress) @store.persist(@progress) end def test_scope_should_return_progressruses_indexed_by_id @store.persist(@progress) @store.persist(@another_progress) actual = @store.scope(@scope) assert_equal @progress.id, actual['oemg'].id assert actual['oemg'].persisted? assert_equal @another_progress.id, actual['oemg-two'].id assert actual['oemg-two'].persisted? end def test_scope_should_return_an_empty_hash_if_nothing_is_found assert_equal({}, @store.scope(@scope)) end def test_find_should_return_a_single_progressrus_for_scope_and_id @store.persist(@progress) stored_progress = @store.find(@scope, 'oemg') assert_equal @progress.id, stored_progress.id assert stored_progress.persisted? end def test_find_should_return_nil_if_nothing_is_found assert_equal nil, @store.find(@scope, 'oemg') end def test_flush_should_delete_by_scope @store.persist(@progress) @store.persist(@another_progress) @store.flush(@scope) assert_equal({}, @store.scope(@scope)) end def test_flush_should_delete_by_scope_and_id @store.persist(@progress) @store.persist(@another_progress) @store.flush(@scope, 'oemg') assert_equal nil, @store.find(@scope, 'oemg') assert @store.find(@scope, 'oemg-two') end def test_initializes_name_to_redis assert_equal :redis, @store.name end def test_persist_should_not_write_by_default @store.redis.expects(:hset).once @store.persist(@progress) @store.persist(@progress) end def test_persist_should_write_if_forced @store.redis.expects(:hset).twice @store.persist(@progress) @store.persist(@progress, force: true) end end