cultuurnet / udb3-php

src/EventSourcing/DBAL/AggregateAwareDBALEventStore.php

Doc Comments +1 added lines, -1 removed lines

@@ -169,7 +169,7 @@
     }
 
     /**
-     * @return mixed
+     * @return Table
      */
     public function configureTable()
     {

Spacing +4 added lines, -4 removed lines

@@ -70,7 +70,7 @@ 
         $this->payloadSerializer  = $payloadSerializer;
         $this->metadataSerializer = $metadataSerializer;
         $this->tableName          = $tableName;
-        $this->aggregateType      = (string) $aggregateType;
+        $this->aggregateType      = (string)$aggregateType;
     }
 
     /**
@@ -105,7 +105,7 @@ 
         $this->guardStream($eventStream);
 
         // Make the transaction more robust by using the transactional statement.
-        $this->connection->transactional(function (Connection $connection) use ($eventStream) {
+        $this->connection->transactional(function(Connection $connection) use ($eventStream) {
             try {
                 foreach ($eventStream as $domainMessage) {
                     $this->insertMessage($connection, $domainMessage);
@@ -123,7 +123,7 @@ 
     private function insertMessage(Connection $connection, DomainMessage $domainMessage)
     {
         $data = array(
-            'uuid'           => (string) $domainMessage->getId(),
+            'uuid'           => (string)$domainMessage->getId(),
             'playhead'       => $domainMessage->getPlayhead(),
             'metadata'       => json_encode($this->metadataSerializer->serialize($domainMessage->getMetadata())),
             'payload'        => json_encode($this->payloadSerializer->serialize($domainMessage->getPayload())),
@@ -228,7 +228,7 @@ 
     {
         foreach ($eventStream as $domainMessage) {
             /** @var DomainMessage $domainMessage */
-            $id = (string) $domainMessage->getId();
+            $id = (string)$domainMessage->getId();
         }
     }
 }

src/EventSourcing/DBAL/EventStream.php

Spacing +1 added lines, -1 removed lines

@@ -174,7 +174,7 @@
                 ]
             )
                 ->from($this->tableName)
-                ->where($this->primaryKey . ' > :previousId')
+                ->where($this->primaryKey.' > :previousId')
                 ->orderBy($this->primaryKey, 'ASC')
                 ->setMaxResults(1);