MySQL transport support. Closes #3

.travis.yml

@@ -19,6 +19,7 @@ matrix:
 services:
   - redis-server
   - rabbitmq
+  - mysql
 
 # faster builds on new travis setup not using sudo
 sudo: false
@@ -37,6 +38,7 @@ install:
   - travis_retry composer install --prefer-dist --no-interaction
 
 before_script:
+  - mysql -e 'create database `async-test`;'
 
 script:
   - vendor/bin/codecept run

CHANGELOG.md

@@ -1,3 +1,7 @@
+0.2.0
+=====
+- Mysql transport support
+
 0.0.5
 =====
 - [Fix first message send in AMQP provider + travis ci](https://github.com/bazilio91/yii2-async/commit/961fc05bf4776509074c062f944124fe090e1b6f)

Dockerfile

@@ -1,9 +1,8 @@
-FROM php:cli
+FROM php:5.6-cli
 
-RUN apt-get update && apt-get install -y redis-server \
-    rabbitmq-server librabbitmq-dev
+RUN apt-get update && apt-get install -y librabbitmq-dev
 RUN php -r "readfile('https://getcomposer.org/installer');" | php
-RUN docker-php-ext-install pcntl shmop mbstring
+RUN docker-php-ext-install pcntl shmop mbstring pdo_mysql
 RUN pecl install amqp && echo "extension=amqp.so" >> /usr/local/etc/php/conf.d/amqp.ini
 
 ADD . /var/code

README.md

@@ -19,6 +19,7 @@ Install: `php composer.phar require bazilio/yii2-async:dev-master`
 #####Using with AMQP:
 `php composer.phar require pdezwart/php-amqp:dev-master`
 
+main.php:
 ```php
 'components' => [
     'async' => [
@@ -39,6 +40,7 @@ Install: `php composer.phar require bazilio/yii2-async:dev-master`
 #####Using with Redis:
 `php composer.phar require yiisoft/yii2-redis:*`
 
+main.php:
 ```php
 'components' => [
     'redis' => [
@@ -58,7 +60,32 @@ Install: `php composer.phar require bazilio/yii2-async:dev-master`
 ]
 ```
 
+#####Using with MySQL (probably any sql, but tested only with mysql)
 
+main.php:
+```php
+'components' => [
+    'db' => [
+        'class' => 'yii\db\Connection',
+        'dsn' => 'mysql:host=localhost;dbname=yii2advenced',
+        'username' => 'root',
+        'password' => '',
+        'charset' => 'utf8',
+    ],
+    'async' => [
+        'class' => 'bazilio\async\AsyncComponent',
+        'transportClass' => 'bazilio\async\transports\AsyncMysqlTransport',
+        'transportConfig' => [
+            'connection' => 'db',
+        ]
+    ]
+]
+```
+
+Apply migrations:
+```php
+./yii migrate/up --migrationPath=@vendor/bazilio/yii2-async/migrations
+```
 
 #####Usage:
 

docker-compose.yml

@@ -0,0 +1,18 @@
+yii2-async:
+  build: .
+  links:
+    - mysql
+    - redis
+    - rabbitmq
+
+mysql:
+  image: mysql
+  environment:
+    MYSQL_ALLOW_EMPTY_PASSWORD: "yes"
+    MYSQL_DATABASE: "async-test"
+
+redis:
+  image: redis
+
+rabbitmq:
+  image: rabbitmq

migrations/m160401_090723_async.php

@@ -0,0 +1,29 @@
+<?php
+
+use yii\db\Migration;
+
+class m160401_090723_async extends Migration
+{
+    public function up()
+    {
+        $this->createTable(
+            '{{%async}}',
+            [
+                'id' => 'pk',
+                'data' => 'longblob',
+                'status' => 'int(1) UNSIGNED DEFAULT 0',
+                'queue' => 'varchar(255) NOT NULL'
+            ]
+        );
+
+        $this->createIndex('queue', '{{%async}}', 'queue');
+        $this->createIndex('queue_status', '{{%async}}', ['queue', 'status']);
+    }
+
+    public function down()
+    {
+        $this->dropIndex('queue', '{{%async}}');
+        $this->dropIndex('queue_status', '{{%async}}');
+        $this->dropTable('{{%async}}');
+    }
+}

test.sh

@@ -3,5 +3,5 @@ set -x
 #docker rmi yii2-async
 set -e
 
-docker build -t yii2-async .
-docker run --rm yii2-async
+docker-compose build yii2-async
+docker-compose run --rm yii2-async

tests/docker-test.sh

@@ -3,11 +3,6 @@ set -e
 set -x
 cd /var/code
 
-redis-server &
-rabbitmq-server &
-
-sleep 5
-
 /composer.phar install
 
 vendor/bin/codecept run

tests/unit/BaseTestClass.php

@@ -222,8 +222,8 @@ public function testSubscribe()
     }
 
     public function testConsoleCommandDaemon() {
-        if (get_called_class() == 'bazilio\async\tests\unit\AmqpTest') {
-            $this->markTestSkipped('No support for AMQP yet');
+        if (get_called_class() !== 'bazilio\async\tests\unit\RedisTest') {
+            $this->markTestSkipped('No support for this transport yet');
             return;
         }
 

tests/unit/MysqlTest.php

@@ -0,0 +1,28 @@
+<?php
+namespace bazilio\async\tests\unit;
+
+class MysqlTest extends BaseTestClass
+{
+    public $appConfig = '@tests/unit/_config.mysql.php';
+
+    protected static $migrated = false;
+
+    public static function migrate()
+    {
+        if (self::$migrated) {
+            return;
+        }
+
+        $migrateController = new \yii\console\controllers\MigrateController('migrate', \Yii::$app);
+        $migrateController->migrationPath = '@tests/../migrations';
+        $migrateController->runAction('up', ['interactive' => 0]);
+
+        self::$migrated = true;
+    }
+
+    public function loadFixtures($fixtures = null)
+    {
+        $this->migrate();
+        parent::loadFixtures($fixtures);
+    }
+}

tests/unit/_config.amqp.php

@@ -1,11 +1,14 @@
 <?php
+$host = getenv('RABBITMQ_PORT_5672_TCP_ADDR') ? getenv('RABBITMQ_PORT_5672_TCP_ADDR') : 'localhost';
+
 return [
     'id' => 'test',
     'basePath' => dirname(__DIR__),
     'components' => [
         'async' => [
             'class' => 'bazilio\async\AsyncComponent',
             'transportConfig' => [
+                'host' => $host,
                 'vhost' => '/',
                 'exchangeName' => 'test'
             ]

tests/unit/_config.mysql.php

@@ -0,0 +1,24 @@
+<?php
+$host = getenv('MYSQL_PORT_3306_TCP_ADDR') ? getenv('MYSQL_PORT_3306_TCP_ADDR') : 'localhost';
+
+return [
+    'id' => 'test',
+    'basePath' => dirname(__DIR__),
+    'components' => [
+        'db' => [
+            'class' => 'yii\db\Connection',
+            'dsn' => "mysql:host=$host;dbname=async-test",
+            'username' => 'root',
+            'password' => '',
+            'charset' => 'utf8',
+        ],
+        'async' => [
+            'class' => 'bazilio\async\AsyncComponent',
+            'transportClass' => 'bazilio\async\transports\AsyncMysqlTransport',
+            'transportConfig' => [
+                'connection' => 'db',
+            ]
+        ]
+    ]
+
+];

tests/unit/_config.redis.php

@@ -1,11 +1,13 @@
 <?php
+$host = getenv('REDIS_PORT_6379_TCP_ADDR') ? getenv('REDIS_PORT_6379_TCP_ADDR') : 'localhost';
+
 return [
     'id' => 'test',
     'basePath' => dirname(__DIR__),
     'components' => [
         'redis' => [
             'class' => 'yii\redis\Connection',
-            'hostname' => 'localhost',
+            'hostname' => $host,
             'port' => 6379,
             'database' => 5,
             'connectionTimeout' => 1,
@@ -18,20 +20,6 @@
                 'connection' => 'redis',
             ]
         ],
-        // This components are for blocking receive testing
-        'redisFork' => [
-            'class' => 'yii\redis\Connection',
-            'hostname' => 'localhost',
-            'port' => 6379,
-            'database' => 5,
-        ],
-        'asyncFork' => [
-            'class' => 'bazilio\async\AsyncComponent',
-            'transportClass' => 'bazilio\async\transports\AsyncRedisTransport',
-            'transportConfig' => [
-                'connection' => 'redisFork',
-            ]
-        ]
     ]
 
 ];