Phpunit

Author: Galin Denev

composer.lock

@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<phpunit xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:noNamespaceSchemaLocation="http://schema.phpunit.de/4.5/phpunit.xsd"
+         backupGlobals="false"
+         colors="true"
+         bootstrap="vendor/autoload.php"
+>
+    <php>
+        <ini name="error_reporting" value="-1" />
+    </php>
+    <testsuites>
+        <testsuite name="AnyB1s DDD Framework">
+            <directory>./tests</directory>
+        </testsuite>
+    </testsuites>
+    <filter>
+        <whitelist>
+            <directory>./src</directory>
+            <exclude>
+                <directory>./tests</directory>
+            </exclude>
+        </whitelist>
+    </filter>
+</phpunit>

phpunit.xml

@@ -8,7 +8,11 @@
 use PDO;
 use Symfony\Component\Serializer\NameConverter\CamelCaseToSnakeCaseNameConverter;
 
-final class DatabaseStorageFacility implements StorageFacility
+/**
+ * Class MysqlStorageFacility
+ * @package AnyB1s\Data\Common\EventSourcing\EventStore\Storage
+ */
+final class MysqlStorageFacility implements StorageFacility
 {
     /** @var PDO $connection */
     private $connection;
@@ -31,6 +35,11 @@ public function __construct(PDO $connection, string $table)
         $this->table = $table;
     }
 
+    /**
+     * @param string $aggregateType
+     * @param string $aggregateId
+     * @return array
+     */
     public function loadEventsOf(string $aggregateType, string $aggregateId): array
     {
         $statement = $this->connection->prepare(
@@ -42,13 +51,19 @@ public function loadEventsOf(string $aggregateType, string $aggregateId): array
         return $statement->fetchAll(PDO::FETCH_COLUMN);
     }
 
+    /**
+     * @return array
+     */
     public function loadAllEvents(): array
     {
         return $this->connection
             ->prepare("SELECT `payload` FROM `{$this->table}`")
             ->fetchAll(PDO::FETCH_COLUMN);
     }
 
+    /**
+     * @param EventEnvelope $eventEnvelope
+     */
     public function append(EventEnvelope $eventEnvelope): void
     {
         $statement = $this->connection->prepare("INSERT INTO `{$this->table}` VALUES (?, ?)");
@@ -58,6 +73,9 @@ public function append(EventEnvelope $eventEnvelope): void
         $statement->execute();
     }
 
+    /**
+     *
+     */
     public function deleteAll(): void
     {
         $this->connection->query("DELETE FROM `{$this->table}`");