Merge pull request #1251 from wholien/jc/add-pexpiretime

Add PEXPIRETIME

Author: byroot

lib/redis/commands/keys.rb

@@ -105,10 +105,10 @@ def expireat(key, unix_time, nx: nil, xx: nil, gt: nil, lt: nil)
         send_command(args, &Boolify)
       end
 
-      # Get a key's expiration time as an absolute Unix timestamp (since January 1, 1970) in seconds
+      # Get a key's expiry time specified as number of seconds from UNIX Epoch
       #
       # @param  [String] key
-      # @return [Integer] expiry time of the key, specified as a UNIX timestamp
+      # @return [Integer] expiry time specified as number of seconds from UNIX Epoch
       def expiretime(key)
         send_command([:expiretime, key])
       end
@@ -169,6 +169,14 @@ def pexpireat(key, ms_unix_time, nx: nil, xx: nil, gt: nil, lt: nil)
         send_command(args, &Boolify)
       end
 
+      # Get a key's expiry time specified as number of milliseconds from UNIX Epoch
+      #
+      # @param  [String] key
+      # @return [Integer] expiry time specified as number of milliseconds from UNIX Epoch
+      def pexpiretime(key)
+        send_command([:pexpiretime, key])
+      end
+
       # Get the time to live (in milliseconds) for a key.
       #
       # @param [String] key

lib/redis/distributed.rb

@@ -150,6 +150,11 @@ def pexpireat(key, ms_unix_time, **kwarg)
       node_for(key).pexpireat(key, ms_unix_time, **kwarg)
     end
 
+    # Get the expiration for a key as number of milliseconds from UNIX Epoch.
+    def pexpiretime(key)
+      node_for(key).pexpiretime(key)
+    end
+
     # Get the time to live (in milliseconds) for a key.
     def pttl(key)
       node_for(key).pttl(key)

test/lint/value_types.rb

@@ -153,6 +153,19 @@ def test_pexpireat_keywords
       end
     end
 
+    def test_pexpiretime
+      target_version "7.0.0" do
+        r.set("foo", "blar")
+        assert_equal(-1, r.pexpiretime("foo"))
+
+        exp_time = (Time.now + 2).to_i * 1_000
+        r.pexpireat("foo", exp_time)
+        assert_equal exp_time, r.pexpiretime("foo")
+
+        assert_equal(-2, r.pexpiretime("key-that-exists-not"))
+      end
+    end
+
     def test_persist
       r.set("foo", "s1")
       r.expire("foo", 1)