0.0.3 __sleep for AsyncExecuteTask, redis queue names fix

Author: bazilio91

models/AsyncExecuteTask.php

@@ -6,6 +6,11 @@
  */
 class AsyncExecuteTask extends AsyncTask
 {
+    function __sleep()
+    {
+        return $this->attributeNames();
+    }
+
     public $class;
     public $method;
     public $arguments = [];

tests/unit/BaseTestClass.php

@@ -47,10 +47,13 @@ public function testPurge()
         $task = new TestTask();
         $this->async->sendTask($task);
 
-        $this->assertEquals(TestTask::className(), get_class($this->async->receiveTask(TestTask::$queueName)));
+        $task = $this->async->receiveTask(TestTask::$queueName);
+        $this->assertEquals(TestTask::className(), get_class($task));
 
         $this->assertTrue($this->async->purge(TestTask::$queueName));
         $this->assertFalse($this->async->receiveTask(TestTask::$queueName));
+
+        $this->assertTrue($this->async->acknowledgeTask($task));
     }
 
     public function testLifeCycle()
@@ -91,6 +94,7 @@ public function testAsyncExecuteTask()
             $rTask->execute();
         } catch (TestException $e) {
             $this->assertEquals($e->getMessage(), 'through the space');
+            $this->assertTrue($this->async->acknowledgeTask($rTask));
             return true;
         }
 

tests/unit/RedisTest.php

@@ -4,4 +4,10 @@
 class RedisTest extends BaseTestClass
 {
     public $appConfig = '@tests/unit/_config.redis.php';
+
+    public function setUp()
+    {
+        parent::setUp();
+        \Yii::$app->redis->executeCommand('FLUSHDB');
+    }
 }

transports/AsyncRedisTransport.php

@@ -21,9 +21,9 @@ function __construct($transportConfig)
         $this->connection = \Yii::$app->{$transportConfig['connection']};
     }
 
-    private static function getQueueKey($queueName, $progress = false)
+    public static function getQueueKey($queueName, $progress = false)
     {
-        return "queue:$queueName";
+        return "queue:$queueName" . ($progress ? ':progress' : null);
     }
 
     /**
@@ -78,6 +78,7 @@ public function acknowledge(AsyncTask $task)
      */
     public function purge($queueName)
     {
-        return $this->connection->executeCommand('DEL', [self::getQueueKey($queueName)]) === '1';
+        $this->connection->executeCommand('DEL', [self::getQueueKey($queueName)]);
+        return true;
     }
 }