Release 0.2.0

Author: othercodes

.github/workflows/documentation.yml

@@ -0,0 +1,22 @@
+name: Documentation
+
+on:
+  pull_request:
+    branches: [ main ]
+    types: [ closed ]
+
+jobs:
+  publish:
+    if: github.event.pull_request.merged == true
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Checkout source code
+        uses: actions/checkout@v2
+
+      - name: Pusblish Wiki
+        uses: SwiftDocOrg/github-wiki-publish-action@v1
+        with:
+          path: "wiki/"
+        env:
+          GH_PERSONAL_ACCESS_TOKEN: ${{ secrets.GH_PERSONAL_ACCESS_TOKEN }}

.github/workflows/test.yml

@@ -17,7 +17,7 @@ jobs:
       - name: Checkout source code
         uses: actions/checkout@v2
 
-      - name: Install PHP
+      - name: Install PHP ${{ matrix.php-version }}
         uses: shivammathur/setup-php@v2
         with:
           php-version: ${{ matrix.php-version }}
@@ -36,7 +36,6 @@ jobs:
         run: composer validate
 
       - name: Install dependencies
-        if: steps.composer-cache.outputs.cache-hit != 'true'
         run: composer install --prefer-dist --no-progress --no-suggest
 
       - name: Execute tests (Unit and Feature tests) via PHPUnit

README.md

@@ -90,6 +90,8 @@ Check this small example of the usage:
 $response = $queryBus->ask(new GetUserQuery('some-uuid-value'));
 ```
 
+Check the [wiki](https://github.com/othercodes/ComplexHeart/wiki) for more detailed examples.
+
 ## References
 
 - [Pro Codely TV](https://pro.codely.tv/library/)

src/Domain/Bus/Event.php

@@ -24,20 +24,15 @@ abstract class Event extends Message
      */
     public function __construct(string $aggregateId, array $data = [])
     {
-        parent::__construct(
-            [
-                'aggregateId' => $aggregateId,
-                'data'        => $data,
-            ]
-        );
+        parent::__construct(array_merge(['aggregateId' => $aggregateId], $data));
     }
 
     /**
      * Return the Aggregate Id.
      *
      * @return string
      */
-    public function aggregateId()
+    public function aggregateId(): string
     {
         return $this->fromPayload('aggregateId');
     }

src/Domain/Collection.php

@@ -33,11 +33,18 @@ class Collection extends BaseCollection
     private int $perPage;
 
     /**
-     * The type of item in the collection.
+     * The type of each items in the collection.
      *
      * @var string
      */
-    protected string $typeOf = 'mixed';
+    protected string $valueType = 'mixed';
+
+    /**
+     * The type of each keys in the collection.
+     *
+     * @var string
+     */
+    protected string $keyType = 'mixed';
 
     /**
      * Collection constructor.
@@ -85,24 +92,53 @@ protected function invariantAmountOfItemsMustBeLessOrEqualsThanTotalItems(): boo
      * @return bool
      * @throws InvariantViolation
      */
-    protected function invariantItemsMustBeOfSameType(): bool
+    protected function invariantItemsMustMatchTheRequiredType(): bool
     {
-        $primitives = ['integer', 'boolean', 'float', 'string', 'array', 'object', 'callable'];
-        if ($this->typeOf !== 'mixed') {
-            $check = in_array($this->typeOf, $primitives)
-                ? fn($value): bool => gettype($value) !== $this->typeOf
-                : fn($value): bool => !($value instanceof $this->typeOf);
+        if ($this->valueType !== 'mixed') {
+            $primitives = ['integer', 'boolean', 'float', 'string', 'array', 'object', 'callable'];
+            $check = in_array($this->valueType, $primitives)
+                ? fn($value): bool => gettype($value) !== $this->valueType
+                : fn($value): bool => !($value instanceof $this->valueType);
 
             foreach ($this->items as $index => $item) {
                 if ($check($item)) {
-                    throw new InvariantViolation("All items must be type of {$this->typeOf}");
+                    throw new InvariantViolation("All items must be type of {$this->valueType}");
                 }
             }
         }
 
         return true;
     }
 
+    /**
+     * Invariant: Check the collection keys to match the required type.
+     *
+     * Supported types:
+     *  - string
+     *  - integer
+     *
+     * @return bool
+     * @throws InvariantViolation
+     */
+    protected function invariantKeysMustMatchTheRequiredType(): bool
+    {
+        if ($this->keyType !== 'mixed') {
+            $supported = ['string', 'integer'];
+            if (!in_array($this->keyType, $supported)) {
+                throw new InvariantViolation(
+                    "Unsupported key type, must be one of ".implode(', ', $supported)
+                );
+            }
+
+            foreach ($this->items as $index => $item) {
+                if (gettype($index) !== $this->keyType) {
+                    throw new InvariantViolation("All keys must be type of {$this->keyType}");
+                }
+            }
+        }
+        return true;
+    }
+
     /**
      * Return the total amount of items on the data source.
      *

src/Domain/Contracts/Aggregate.php

@@ -4,7 +4,7 @@
 
 namespace OtherCode\ComplexHeart\Domain\Contracts;
 
-use OtherCode\ComplexHeart\Domain\Bus\Event;
+use OtherCode\ComplexHeart\Domain\Contracts\Bus\EventBus;
 
 /**
  * Interface Aggregate
@@ -15,9 +15,14 @@
 interface Aggregate extends Entity
 {
     /**
-     * Pull the registered Domain Events.
+     * Publish the registered Domain Events.
      *
-     * @return Event[]
+     *  $aggregate = new Aggregate();
+     *  // do things and generate events
+     *  $aggregate->publishDomainEvents($eventBus);
+     *
+     * @param  EventBus  $eventBus
+     * @return void
      */
-    public function pullDomainEvents(): array;
+    public function publishDomainEvents(EventBus $eventBus): void;
 }

src/Domain/Contracts/Bus/QueryBus.php

@@ -5,6 +5,7 @@
 namespace OtherCode\ComplexHeart\Domain\Contracts\Bus;
 
 use OtherCode\ComplexHeart\Domain\Bus\Query;
+use OtherCode\ComplexHeart\Domain\Bus\Response;
 
 /**
  * Interface QueryBus
@@ -21,5 +22,5 @@ interface QueryBus
      *
      * @return mixed
      */
-    public function ask(Query $query);
+    public function ask(Query $query): Response;
 }

src/Domain/Traits/HasDomainEvents.php

@@ -5,6 +5,7 @@
 namespace OtherCode\ComplexHeart\Domain\Traits;
 
 use OtherCode\ComplexHeart\Domain\Bus\Event;
+use OtherCode\ComplexHeart\Domain\Contracts\Bus\EventBus;
 
 /**
  * Trait HasDomainEvents
@@ -18,21 +19,20 @@ trait HasDomainEvents
     /**
      * List of registered domain events.
      *
-     * @var array<Event>
+     * @var Event[]
      */
     private array $_domainEvents = [];
 
     /**
-     * Pull out all the registered domain events.
+     * Publish the registered Domain Events.
      *
-     * @return array<Event>
+     * @param  EventBus  $eventBus
+     * @return void
      */
-    final public function pullDomainEvents(): array
+    final public function publishDomainEvents(EventBus $eventBus): void
     {
-        $domainEvents = $this->_domainEvents;
+        $eventBus->publish(...$this->_domainEvents);
         $this->_domainEvents = [];
-
-        return $domainEvents;
     }
 
     /**

src/Domain/Traits/HasServiceBus.php

@@ -33,6 +33,16 @@ final public function bind(ServiceBus $bus): void
         $this->_serviceBus = $bus;
     }
 
+    /**
+     * Return true if the Service Bus is bound to the object, false otherwise.
+     *
+     * @return bool
+     */
+    final public function isBound(): bool
+    {
+        return isset($this->_serviceBus);
+    }
+
     /**
      * Return the Command Bus implementation.
      *

tests/Domain/CollectionTest.php

@@ -20,7 +20,7 @@ class CollectionTest extends MockeryTestCase
     public function testShouldSuccessfullyInstantiateACollection(): void
     {
         $c = new class (['foo', 'bar']) extends Collection {
-            protected string $typeOf = 'string';
+            protected string $valueType = 'string';
         };
 
         $this->assertInstanceOf(Collection::class, $c);
@@ -31,7 +31,7 @@ public function testShouldFailWithWrongPrimitiveValueItemTypes(): void
         $this->expectException(InvariantViolation::class);
 
         new class ([1, '2']) extends Collection {
-            protected string $typeOf = 'integer';
+            protected string $valueType = 'integer';
         };
     }
 
@@ -40,7 +40,7 @@ public function testShouldFailWithWrongClassValueItemTypes(): void
         $this->expectException(InvariantViolation::class);
 
         new class ([new stdClass(), '2']) extends Collection {
-            protected string $typeOf = stdClass::class;
+            protected string $valueType = stdClass::class;
         };
     }
 
@@ -57,4 +57,22 @@ public function testShouldFailDueToAmountOfItemsIsGreaterThanTotalItems(): void
 
         new Collection([0, 1, 2, 3, 4], 2, 5);
     }
+
+    public function testShouldFailDueToUnsupportedKeyType(): void
+    {
+        $this->expectException(InvariantViolation::class);
+
+        new class (['foo', 'bar']) extends Collection {
+            protected string $keyType = 'boolean';
+        };
+    }
+
+    public function testShouldFailDueToWrongKeyType(): void
+    {
+        $this->expectException(InvariantViolation::class);
+
+        new class (['foo', 'bar']) extends Collection {
+            protected string $keyType = 'string';
+        };
+    }
 }