Merge pull request #22 from cakephp/more-tests

Add more tests.

Author: markstory

src/QueueManager.php

@@ -90,11 +90,11 @@ public static function setConfig($key, $config = null): void
 
         if (isset(static::$_config[$key])) {
             /** @psalm-suppress PossiblyInvalidArgument */
-            throw new BadMethodCallException(sprintf('Cannot reconfigure existing key "%s"', $key));
+            throw new BadMethodCallException(sprintf('Cannot reconfigure existing key `%s`', $key));
         }
 
         if (empty($config['url'])) {
-            throw new BadMethodCallException('Must specify "url" key');
+            throw new BadMethodCallException('Must specify `url` key.');
         }
 
         /** @psalm-suppress InvalidPropertyAssignmentValue */
@@ -112,6 +112,17 @@ public static function getConfig(string $key)
         return static::$_config[$key] ?? null;
     }
 
+    /**
+     * Remove a configured queue adapter.
+     *
+     * @param string $key The config name to drop.
+     * @return void
+     */
+    public static function drop(string $key): void
+    {
+        unset(static::$_clients[$key], static::$_config[$key]);
+    }
+
     /**
      * Get a queueing engine
      *

tests/TestCase/QueueManagerTest.php

@@ -0,0 +1,85 @@
+<?php
+declare(strict_types=1);
+
+/**
+ * CakePHP(tm) : Rapid Development Framework (http://cakephp.org)
+ * Copyright (c) Cake Software Foundation, Inc. (http://cakefoundation.org)
+ *
+ * Licensed under The MIT License
+ * For full copyright and license information, please see the LICENSE.txt
+ * Redistributions of files must retain the above copyright notice.
+ *
+ * @copyright Copyright (c) Cake Software Foundation, Inc. (http://cakefoundation.org)
+ * @link http://cakephp.org CakePHP(tm) Project
+ * @since 0.1.0
+ * @license http://www.opensource.org/licenses/mit-license.php MIT License
+ */
+namespace Queue\Test\TestCase;
+
+use BadMethodCallException;
+use Cake\Log\Log;
+use Cake\TestSuite\TestCase;
+use Enqueue\SimpleClient\SimpleClient;
+use LogicException;
+use Queue\QueueManager;
+
+/**
+ * QueueManager test
+ */
+class QueueManagerTest extends TestCase
+{
+    public function tearDown(): void
+    {
+        parent::tearDown();
+        QueueManager::drop('test');
+        Log::drop('test');
+    }
+
+    public function testSetConfig()
+    {
+        $result = QueueManager::setConfig('test', [
+            'url' => 'null:',
+        ]);
+        $this->assertNull($result);
+
+        $config = QueueManager::getConfig('test');
+        $this->assertSame('null:', $config['url']);
+    }
+
+    public function testSetConfigInvalidValue()
+    {
+        $this->expectException(LogicException::class);
+        QueueManager::setConfig('test', null);
+    }
+
+    public function testSetConfigNoUrl()
+    {
+        $this->expectException(BadMethodCallException::class);
+        $this->expectExceptionMessage('Must specify `url`');
+        QueueManager::setConfig('test', ['queue' => 'test']);
+    }
+
+    public function testSetConfigOverwrite()
+    {
+        QueueManager::setConfig('test', [
+            'url' => 'null:',
+        ]);
+        $this->expectException(BadMethodCallException::class);
+        $this->expectExceptionMessage('Cannot reconfigure');
+        QueueManager::setConfig('test', [
+            'url' => 'redis:',
+        ]);
+    }
+
+    public function testEngine()
+    {
+        QueueManager::setConfig('test', [
+            'queue' => 'default',
+            'url' => 'null:',
+        ]);
+        $engine = QueueManager::engine('test');
+        $this->assertInstanceOf(SimpleClient::class, $engine);
+
+        $this->assertSame($engine, QueueManager::engine('test'));
+    }
+}