Add delete and expire methods

lib/redis_cacheable.rb

@@ -67,6 +67,12 @@ def find_from_redis(key)
       end
     end
 
+    def del_from_redis(key)
+      redis do |conn|
+        conn.del(key)
+      end
+    end
+
     # @private
     # for internal use
     def __redis_cache_key__
@@ -80,9 +86,37 @@ def __redis_cache_attrs__
     end
   end
 
-  def cache_to_redis
+  def cache_to_redis(expire: nil)
+    redis do |conn|
+      if expire
+        conn.setex(redis_cache_key, expire, MultiJson.dump(redis_cache_data))
+      else
+        conn.set(redis_cache_key, MultiJson.dump(redis_cache_data))
+      end
+    end
+  end
+
+  def del_from_redis
+    redis do |conn|
+      conn.del(redis_cache_key)
+    end
+  end
+
+  def expire_redis(sec)
+    redis do |conn|
+      conn.expire(redis_cache_key, sec)
+    end
+  end
+
+  def expireat_redis(unix_time)
+    redis do |conn|
+      conn.expireat(redis_cache_key, unix_time)
+    end
+  end
+
+  def ttl_redis
     redis do |conn|
-      conn.set(redis_cache_key, MultiJson.dump(redis_cache_data))
+      conn.ttl(redis_cache_key)
     end
   end
 

redis-cacheable.gemspec

@@ -19,7 +19,7 @@ Gem::Specification.new do |spec|
   spec.require_paths = ["lib"]
 
   spec.add_dependency "activesupport", ">= 3"
-  spec.add_dependency "redis"
+  spec.add_dependency "redis", ">= 3"
   spec.add_dependency "redis-namespace"
   spec.add_dependency "connection_pool"
   spec.add_dependency "multi_json"

spec/lib/redis_cacheable_spec.rb

@@ -32,6 +32,10 @@ class InheritBase < CacheableObject
 class InheritChild < InheritBase; end
 
 describe RedisCacheable do
+  before do
+    Redis.new.flushall
+  end
+
   describe "Object including RedisCacheable" do
     describe "#cache_to_redis" do
       context "if redis_attrs is symbols" do
@@ -70,5 +74,49 @@ class InheritChild < InheritBase; end
         end
       end
     end
+
+    describe "#del_from_redis" do
+      it "delete cached data from redis" do
+        object = CacheableObject.new(id: 1, name: "target")
+        object.cache_to_redis
+        expect(CacheableObject.find_from_redis(1)).to eq({"id" => 1, "name" => "target"})
+        object.del_from_redis
+
+        expect(CacheableObject.find_from_redis(1)).to be_nil
+      end
+    end
+
+    describe "#expire_redis" do
+      it "set expire time to cached data" do
+        object = CacheableObject.new(id: 1, name: "target")
+        object.cache_to_redis
+        expect(CacheableObject.find_from_redis(1)).to eq({"id" => 1, "name" => "target"})
+        object.expire_redis(2)
+        expect(CacheableObject.find_from_redis(1)).to eq({"id" => 1, "name" => "target"})
+        sleep 2
+        expect(CacheableObject.find_from_redis(1)).to be_nil
+      end
+    end
+
+    describe "#expireat_redis" do
+      it "set expire time to cached data by unix_time" do
+        object = CacheableObject.new(id: 1, name: "target")
+        object.cache_to_redis
+        expect(CacheableObject.find_from_redis(1)).to eq({"id" => 1, "name" => "target"})
+        object.expireat_redis((Time.now + 2).to_i)
+        expect(CacheableObject.find_from_redis(1)).to eq({"id" => 1, "name" => "target"})
+        sleep 2
+        expect(CacheableObject.find_from_redis(1)).to be_nil
+      end
+    end
+
+    describe "#ttl_redis" do
+      it "returns time to expire as second" do
+        object = CacheableObject.new(id: 1, name: "target")
+        object.cache_to_redis
+        object.expire_redis(2)
+        expect((1.0..2.0).cover?(object.ttl_redis)).to be_true
+      end
+    end
   end
 end