Merge pull request #30 from driftphp/feature/add-static-bus-creation-methods

Buses are now built inside static methods

Author: mmoreram

.phpunit.result.cache

@@ -0,0 +1 @@
+{"version":1,"defects":{"Drift\\CommandBus\\Tests\\Bus\\QueryHandlerTest::testQueryBus":4,"Drift\\CommandBus\\Tests\\Bus\\QueryHandlerTest::testBusesInjection":5,"Drift\\CommandBus\\Tests\\Bus\\CommandHandlerTest::testBusesInjection":4,"Drift\\CommandBus\\Tests\\Bus\\AsyncCommandHandlerTest::testQueryBus":4},"times":{"Drift\\CommandBus\\Tests\\Bus\\DiscriminableBusTest::testQueryBus":0.003,"Drift\\CommandBus\\Tests\\Bus\\QueryHandlerTest::testQueryBus":0.002,"Drift\\CommandBus\\Tests\\Bus\\QueryHandlerTest::testBadCommand":0,"Drift\\CommandBus\\Tests\\Bus\\QueryHandlerTest::testBusesInjection":0,"Drift\\CommandBus\\Tests\\Bus\\CommandHandlerTest::testQueryBus":0.002,"Drift\\CommandBus\\Tests\\Bus\\CommandHandlerTest::testBusesInjection":0.001,"Drift\\CommandBus\\Tests\\Bus\\AsyncCommandHandlerTest::testQueryBus":0,"Drift\\CommandBus\\Tests\\Bus\\AsyncCommandHandlerTest::testBusesInjection":0.002}}

Tests/Async/RedisAsyncTest.php

@@ -16,9 +16,9 @@
 namespace Drift\CommandBus\Tests\Async;
 
 /**
- * Class RedisAsyncAdapterTest.
+ * Class RedisAsyncTest.
  */
-class RedisAsyncAdapterTest extends AsyncAdapterTest
+class RedisAsyncTest extends AsyncAdapterTest
 {
     /**
      * {@inheritdoc}

Tests/AsyncService.php

@@ -0,0 +1,50 @@
+<?php
+
+/*
+ * This file is part of the DriftPHP Project
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ *
+ * Feel free to edit as you please, and have fun.
+ *
+ * @author Marc Morera <yuhu@mmoreram.com>
+ */
+
+declare(strict_types=1);
+
+namespace Drift\CommandBus\Tests;
+
+use Drift\CommandBus\Bus\AsyncCommandBus;
+use Drift\CommandBus\Bus\CommandBus;
+use Drift\CommandBus\Bus\InlineCommandBus;
+use Drift\CommandBus\Bus\QueryBus;
+
+/**
+ * Class AsyncService.
+ */
+class AsyncService
+{
+    private CommandBus $commandBus;
+    private AsyncCommandBus $asyncCommandBus;
+    private InlineCommandBus $inlineCommandBus;
+    private QueryBus $queryBus;
+
+    /**
+     * @param CommandBus       $commandBus
+     * @param AsyncCommandBus  $asyncCommandBus
+     * @param InlineCommandBus $inlineCommandBus
+     * @param QueryBus         $queryBus
+     */
+    public function __construct(
+        CommandBus $commandBus,
+        AsyncCommandBus $asyncCommandBus,
+        InlineCommandBus $inlineCommandBus,
+        QueryBus $queryBus
+    ) {
+        $this->commandBus = $commandBus;
+        $this->asyncCommandBus = $asyncCommandBus;
+        $this->inlineCommandBus = $inlineCommandBus;
+        $this->queryBus = $queryBus;
+    }
+}

Tests/Bus/AsyncCommandHandlerTest.php

@@ -0,0 +1,65 @@
+<?php
+
+/*
+ * This file is part of the DriftPHP Project
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ *
+ * Feel free to edit as you please, and have fun.
+ *
+ * @author Marc Morera <yuhu@mmoreram.com>
+ */
+
+declare(strict_types=1);
+
+namespace Drift\CommandBus\Tests\Bus;
+
+use Drift\CommandBus\Tests\AsyncService;
+use Drift\CommandBus\Tests\BusFunctionalTest;
+use Drift\CommandBus\Tests\CommandHandler\ChangeAThingHandler;
+use Drift\CommandBus\Tests\Context;
+use Drift\CommandBus\Tests\Service;
+
+/**
+ * Class AsyncCommandHandlerTest.
+ */
+class AsyncCommandHandlerTest extends BusFunctionalTest
+{
+    /**
+     * Decorate configuration.
+     *
+     * @param array $configuration
+     *
+     * @return array
+     */
+    protected static function decorateConfiguration(array $configuration): array
+    {
+        $configuration['services'][AsyncService::class] = [];
+        $configuration['services'][Service::class] = [];
+        $configuration['services'][Context::class] = [];
+        $configuration['services'][ChangeAThingHandler::class] = [
+            'tags' => [
+                ['name' => 'command_handler', 'method' => 'handle'],
+                ['name' => 'another_tag', 'method' => 'anotherMethod'],
+            ],
+        ];
+
+        $configuration['command_bus']['command-bus']['async_adapter'] = [
+            'adapter' => 'in_memory',
+            'in_memory' => [],
+        ];
+
+        return $configuration;
+    }
+
+    /**
+     * Buses injection.
+     */
+    public function testBusesInjection()
+    {
+        $this->expectNotToPerformAssertions();
+        $this->get(Service::class);
+        $this->get(AsyncService::class);
+    }
+}

Tests/Bus/CommandHandlerTest.php

@@ -22,6 +22,7 @@
 use Drift\CommandBus\Tests\Command\ChangeAThing;
 use Drift\CommandBus\Tests\CommandHandler\ChangeAThingHandler;
 use Drift\CommandBus\Tests\Context;
+use Drift\CommandBus\Tests\Service;
 
 /**
  * Class CommandHandlerTest.
@@ -37,6 +38,7 @@ class CommandHandlerTest extends BusFunctionalTest
      */
     protected static function decorateConfiguration(array $configuration): array
     {
+        $configuration['services'][Service::class] = [];
         $configuration['services'][Context::class] = [];
         $configuration['services'][ChangeAThingHandler::class] = [
             'tags' => [
@@ -91,4 +93,13 @@ public function testQueryBus()
             ->getMiddlewareList()
         );
     }
+
+    /**
+     * Buses injection.
+     */
+    public function testBusesInjection()
+    {
+        $this->expectNotToPerformAssertions();
+        $this->get(Service::class);
+    }
 }

Tests/Bus/QueryHandlerTest.php

@@ -22,6 +22,7 @@
 use Drift\CommandBus\Tests\Context;
 use Drift\CommandBus\Tests\Query\GetAThing;
 use Drift\CommandBus\Tests\QueryHandler\GetAThingHandler;
+use Drift\CommandBus\Tests\Service;
 
 /**
  * Class QueryHandlerTest.
@@ -37,6 +38,7 @@ class QueryHandlerTest extends BusFunctionalTest
      */
     protected static function decorateConfiguration(array $configuration): array
     {
+        $configuration['services'][Service::class] = [];
         $configuration['services'][Context::class] = [];
         $configuration['services'][GetAThingHandler::class] = [
             'tags' => [
@@ -89,4 +91,13 @@ public function testBadCommand()
 
         await($promise, $this->getLoop());
     }
+
+    /**
+     * Buses injection.
+     */
+    public function testBusesInjection()
+    {
+        $this->expectNotToPerformAssertions();
+        $this->get(Service::class);
+    }
 }

Tests/Bus/QueryHandlerWithMiddlewareTest.php

@@ -31,7 +31,7 @@
 /**
  * Class QueryHandlerWithMiddleware.
  */
-class QueryHandlerWithMiddleware extends BusFunctionalTest
+class QueryHandlerWithMiddlewareTest extends BusFunctionalTest
 {
     /**
      * Decorate configuration.

Tests/Service.php

@@ -0,0 +1,45 @@
+<?php
+
+/*
+ * This file is part of the DriftPHP Project
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ *
+ * Feel free to edit as you please, and have fun.
+ *
+ * @author Marc Morera <yuhu@mmoreram.com>
+ */
+
+declare(strict_types=1);
+
+namespace Drift\CommandBus\Tests;
+
+use Drift\CommandBus\Bus\CommandBus;
+use Drift\CommandBus\Bus\InlineCommandBus;
+use Drift\CommandBus\Bus\QueryBus;
+
+/**
+ * Class Service.
+ */
+class Service
+{
+    private CommandBus $commandBus;
+    private InlineCommandBus $inlineCommandBus;
+    private QueryBus $queryBus;
+
+    /**
+     * @param CommandBus       $commandBus
+     * @param InlineCommandBus $inlineCommandBus
+     * @param QueryBus         $queryBus
+     */
+    public function __construct(
+        CommandBus $commandBus,
+        InlineCommandBus $inlineCommandBus,
+        QueryBus $queryBus
+    ) {
+        $this->commandBus = $commandBus;
+        $this->inlineCommandBus = $inlineCommandBus;
+        $this->queryBus = $queryBus;
+    }
+}