AsyncExecuteTask

Author: bazilio91

AsyncComponent.php

@@ -34,7 +34,7 @@ public function sendTask(AsyncTask $task)
         if ($task->validate()) {
             return $this->transport->send(serialize($task), $task::$queueName);
         } else {
-            throw new Exception(implode(',', $task->errors));
+            throw new Exception(var_export($task->errors, true));
         }
     }
 

Exception.php

@@ -1,7 +1,7 @@
 <?php
 namespace bazilio\async;
 
-class Exception extends yii\base\Exception
+class Exception extends \yii\base\Exception
 {
 
 } 

composer.json

@@ -16,11 +16,24 @@
     "require-dev": {
         "phpunit/phpunit": "3.7.*",
         "yiisoft/yii2-codeception": "*",
-        "codeception/codeception": "*"
+        "codeception/codeception": "*",
+        "pdezwart/php-amqp": "dev-master"
     },
     "autoload": {
         "psr-4": {
             "bazilio\\async\\": ""
         }
-    }
+    },
+    "repositories": [{
+        "type": "package",
+        "package": {
+            "name": "pdezwart/php-amqp",
+            "version": "dev-master",
+            "source": {
+                "url": "https://github.com/pdezwart/php-amqp",
+                "type": "git",
+                "reference": "origin/master"
+            }
+        }
+    }]
 }

models/AsyncExecuteTask.php

@@ -0,0 +1,72 @@
+<?php
+namespace bazilio\async\models;
+
+/**
+ * Class AsyncExecuteTask
+ */
+class AsyncExecuteTask extends AsyncTask
+{
+    public $class;
+    public $method;
+    public $arguments = [];
+
+    public function rules()
+    {
+        return array(
+            [['class', 'method', 'arguments'], 'required'],
+            [['class', 'method'], 'string'],
+            [['class'], 'validateClass'],
+            [['method'], 'validateMethod'],
+            [['arguments'], 'validateArguments'],
+        );
+    }
+
+    public function validateClass($attribute, $params)
+    {
+        if (!class_exists($this->$attribute)) {
+            $this->addError($attribute, "Class {$this->$attribute} does not exist");
+        }
+    }
+
+    public function validateMethod($attribute, $params)
+    {
+        if (!isset(array_flip(get_class_methods($this->class))[$this->$attribute])) {
+            $this->addError(
+                $attribute,
+                "Method {$this->$attribute} of class {$this->class} does not exist"
+            );
+        }
+    }
+
+    public function validateArguments($attribute, $params) {
+        if (!isset(array_flip(get_class_methods($this->class))[$this->method])) {
+            $this->addError(
+                $attribute,
+                "Method {$this->method} of class {$this->class} does not exist"
+            );
+        }
+    }
+
+    /**
+     * Returns the list of attribute names of the model.
+     * @return array list of attribute names.
+     */
+    public function attributeNames()
+    {
+        return [
+            'class',
+            'method',
+            'arguments'
+        ];
+    }
+
+    static function nope($return)
+    {
+        return $return;
+    }
+
+    public function execute()
+    {
+        return call_user_func_array(array($this->class, $this->method), $this->arguments);
+    }
+}

tests/unit.suite.yml

@@ -3,4 +3,4 @@
 # suite for unit (internal) tests.
 class_name: UnitTester
 modules:
-    enabled: [Asserts, UnitHelper]
+    enabled: [Asserts, UnitHelper, Mockery]

tests/unit/AmqpTest.php

@@ -1,16 +1,28 @@
 <?php
-
 use bazilio\async\AsyncComponent;
+use bazilio\async\models\AsyncExecuteTask;
+use bazilio\async\models\AsyncTask;
 
-class TestTask extends \bazilio\async\models\AsyncTask
+class TestTask extends AsyncTask
 {
     public $id;
 
     public function execute()
     {
         return $this->id;
     }
+}
 
+class TestException extends \Exception
+{
+}
+
+class BlackHole
+{
+    public function run($param)
+    {
+        throw new TestException($param);
+    }
 }
 
 class AmqpTest extends \yii\codeception\TestCase
@@ -56,4 +68,30 @@ public function testLifeCycle()
 
         $this->assertFalse($this->async->receiveTask(TestTask::$queueName));
     }
+
+    public function testAsyncExecuteTask()
+    {
+        $aTask = new AsyncExecuteTask();
+        $aTask->setAttributes(
+            [
+                'class' => '\BlackHole',
+                'method' => 'run',
+                'arguments' => ['param' => 'through the space']
+            ]
+        );
+
+        $this->async->sendTask($aTask);
+
+        $rTask = $this->async->receiveTask($aTask::$queueName);
+        $this->assertInstanceOf('bazilio\async\models\AsyncExecuteTask', $rTask);
+
+        try {
+            $rTask->execute();
+        } catch (TestException $e) {
+            $this->assertEquals($e->getMessage(), 'through the space');
+            return true;
+        }
+
+        $this->fail('BlackHole method wasn\'t called.');
+    }
 }

tests/unit/UnitTester.php

@@ -1,4 +1,4 @@
-<?php //[STAMP] 6cd8435c53a77903754e35ca70c87c63
+<?php //[STAMP] 7090f4f20ecbb9880d52b8a3056e9b0b
 
 // This class was automatically generated by build task
 // You should not change it manually as it will be overwritten on next build
@@ -7,6 +7,7 @@
 
 use Codeception\Module\Asserts;
 use Codeception\Module\UnitHelper;
+use Codeception\Module\Mockery;
 
 /**
  * Inherited Methods