more tests

michalsn · michalsn · commit abd123585ff7 · 2023-11-11T22:10:10.000+01:00
diff --git a/tests/DatabaseHandlerTest.php b/tests/DatabaseHandlerTest.php
@@ -94,6 +94,38 @@ public function testPushWithPriority()
         ]);
     }
 
+    public function testPushAndPopWithPriority()
+    {
+        $handler = new DatabaseHandler($this->config);
+        $result  = $handler->push('queue', 'success', ['key1' => 'value1']);
+
+        $this->assertTrue($result);
+        $this->seeInDatabase('queue_jobs', [
+            'queue'    => 'queue',
+            'payload'  => json_encode(['job' => 'success', 'data' => ['key1' => 'value1']]),
+            'priority' => 'low',
+        ]);
+
+        $result = $handler->setPriority('high')->push('queue', 'success', ['key2' => 'value2']);
+
+        $this->assertTrue($result);
+        $this->seeInDatabase('queue_jobs', [
+            'queue'    => 'queue',
+            'payload'  => json_encode(['job' => 'success', 'data' => ['key2' => 'value2']]),
+            'priority' => 'high',
+        ]);
+
+        $result = $handler->pop('queue', ['high', 'low']);
+        $this->assertInstanceOf(QueueJob::class, $result);
+        $payload = ['job' => 'success', 'data' => ['key2' => 'value2']];
+        $this->assertSame($payload, $result->payload);
+
+        $result = $handler->pop('queue', ['high', 'low']);
+        $this->assertInstanceOf(QueueJob::class, $result);
+        $payload = ['job' => 'success', 'data' => ['key1' => 'value1']];
+        $this->assertSame($payload, $result->payload);
+    }
+
     /**
      * @throws ReflectionException
      */
@@ -118,6 +150,30 @@ public function testPushWithPriorityException()
         $handler->setPriority('invalid')->push('queue', 'success', ['key' => 'value']);
     }
 
+    /**
+     * @throws ReflectionException
+     */
+    public function testPushWithIncorrectQueueFormatException()
+    {
+        $this->expectException(QueueException::class);
+        $this->expectExceptionMessage('The queue name should consists only lowercase letters or numbers.');
+
+        $handler = new DatabaseHandler($this->config);
+        $handler->push('queue*', 'success', ['key' => 'value']);
+    }
+
+    /**
+     * @throws ReflectionException
+     */
+    public function testPushWithTooLongQueueNameException()
+    {
+        $this->expectException(QueueException::class);
+        $this->expectExceptionMessage('The queue name is too long. It should be no longer than 64 letters.');
+
+        $handler = new DatabaseHandler($this->config);
+        $handler->push(str_repeat('a',65), 'success', ['key' => 'value']);
+    }
+
     /**
      * @throws ReflectionException
      */
@@ -284,6 +340,14 @@ public function testForget()
         ]);
     }
 
+    public function testForgetFalse()
+    {
+        $handler = new DatabaseHandler($this->config);
+        $result  = $handler->forget(1111);
+
+        $this->assertFalse($result);
+    }
+
     /**
      * @throws ReflectionException
      */
diff --git a/tests/PredisHandlerTest.php b/tests/PredisHandlerTest.php
@@ -247,6 +247,26 @@ public function testClear()
 
         $predis = self::getPrivateProperty($handler, 'predis');
         $this->assertSame(0, $predis->zcard('queues:queue1:default'));
+
+        $result = $handler->clear('queue1');
+        $this->assertTrue($result);
+    }
+
+    /**
+     * @throws ReflectionException
+     */
+    public function testClearAll()
+    {
+        $handler = new PredisHandler($this->config);
+        $result  = $handler->clear();
+
+        $this->assertTrue($result);
+
+        $predis = self::getPrivateProperty($handler, 'predis');
+        $this->assertCount(0, $predis->keys('queues:*'));
+
+        $result = $handler->clear();
+        $this->assertTrue($result);
     }
 
     /**
diff --git a/tests/RedisHandlerTest.php b/tests/RedisHandlerTest.php
@@ -219,6 +219,23 @@ public function testClear()
 
         $redis = self::getPrivateProperty($handler, 'redis');
         $this->assertSame(0, $redis->zCard('queues:queue1:default'));
+
+        $result = $handler->clear('queue1');
+        $this->assertTrue($result);
+    }
+
+    public function testClearAll()
+    {
+        $handler = new RedisHandler($this->config);
+
+        $result = $handler->clear();
+        $this->assertTrue($result);
+
+        $redis = self::getPrivateProperty($handler, 'redis');
+        $this->assertCount(0, $redis->keys('queues:*'));
+
+        $result = $handler->clear();
+        $this->assertTrue($result);
     }
 
     public function testRetry()
