2.1.1 (2023-03-20) - Update setex to set, add TTL to stats

Author: idanoo

CHANGELOG.md

@@ -1,3 +1,7 @@
+# 2.1.1 (2023-03-20)
+- Changed setex to set with EX values
+- Added TTLs to missing keys
+
 ## 2.1.0 (2023-02-07)
 - Add PHP 8.1 / 8.2 unit tests
 - Updated code to be PHP 8.2 compliant

src/Resque/Job/Status.php

@@ -59,7 +59,11 @@ public static function create($id)
             'updated' => time(),
             'started' => time(),
         ];
-        \Resque\Resque::redis()->setex('job:' . $id . ':status', 86400, json_encode($statusPacket));
+        \Resque\Resque::redis()->set(
+            'job:' . $id . ':status',
+            json_encode($statusPacket),
+            ['ex' => time() + 86400],
+        );
     }
 
     /**
@@ -98,12 +102,12 @@ public function update($status)
             'status' => $status,
             'updated' => time(),
         ];
-        \Resque\Resque::redis()->setex((string)$this, 86400, json_encode($statusPacket));
 
-        // Expire the status for completed jobs after 24 hours
-        if (in_array($status, self::$completeStatuses)) {
-            \Resque\Resque::redis()->expire((string)$this, 86400);
-        }
+        \Resque\Resque::redis()->set(
+            (string)$this,
+            json_encode($statusPacket),
+            ['ex' => time() + 86400],
+        );
     }
 
     /**

src/Resque/Stat.php

@@ -29,21 +29,35 @@ public static function get(string $stat): int
      *
      * @param string $stat The name of the statistic to increment.
      * @param int $by The amount to increment the statistic by.
-     * @return boolean True if successful, false if not.
+     *
+     * @return bool True if successful, false if not.
      */
-    public static function incr($stat, $by = 1): bool
+    public static function incr(string $stat, int $by = 1): bool
     {
-        return (bool)Resque::redis()->incrby('stat:' . $stat, $by);
+        // Make sure we set a TTL by default
+        $set = Resque::redis()->set(
+            'stat:' . $stat,
+            $by,
+            ['ex' => time() + 86400, 'nx'],
+        );
+
+        // If it already exists, return the incrby value
+        if (!$set) {
+            return (bool)Resque::redis()->incrby('stat:' . $stat, $by);
+        }
+
+        return true;
     }
 
     /**
      * Decrement the value of the specified statistic by a certain amount (default is 1)
      *
      * @param string $stat The name of the statistic to decrement.
      * @param int $by The amount to decrement the statistic by.
-     * @return boolean True if successful, false if not.
+     *
+     * @return bool True if successful, false if not.
      */
-    public static function decr($stat, $by = 1): bool
+    public static function decr(string $stat, int $by = 1): bool
     {
         return (bool)Resque::redis()->decrby('stat:' . $stat, $by);
     }
@@ -52,10 +66,11 @@ public static function decr($stat, $by = 1): bool
      * Delete a statistic with the given name.
      *
      * @param string $stat The name of the statistic to delete.
-     * @return boolean True if successful, false if not.
+     *
+     * @return bool True if successful, false if not.
      */
-    public static function clear($stat): bool
+    public static function clear(string $stat): bool
     {
-        return (bool)Resque::redis()->del('stat:' . $stat);
+        return (bool)Resque::redis()->unlink('stat:' . $stat);
     }
 }

src/Resque/Worker.php

@@ -491,7 +491,11 @@ public function workerPids()
     public function registerWorker()
     {
         Resque::redis()->sadd('workers', (string)$this);
-        Resque::redis()->setex('worker:' . (string)$this . ':started', 86400, date('D M d H:i:s T Y'));
+        Resque::redis()->set(
+            'worker:' . (string)$this . ':started',
+            date('D M d H:i:s T Y'),
+            ['ex' => time() + 86400],
+        );
     }
 
     /**
@@ -527,7 +531,12 @@ public function workingOn(\Resque\Job\Job $job)
             'run_at' => date('D M d H:i:s T Y'),
             'payload' => $job->payload
         ]);
-        Resque::redis()->setex('worker:' . $job->worker, 86400, $data);
+
+        Resque::redis()->set(
+            'worker:' . $job->worker, 
+            $data,
+            ['ex' => time() + 86400],
+        );
     }
 
     /**

tests/Resque/Tests/RedisTest.php

@@ -14,7 +14,12 @@ class RedisTest extends TestCase
 {
     public function testRedisGetSet()
     {
-        $this->redis->setex("testKey", 3600, 24);
+        $this->redis->set(
+            'testKey',
+            24,
+            ['ex' => time() + 3600],
+        );
+
         $val = $this->redis->get("testKey");
         $this->assertEquals(24, $val);
     }