Add tests

Author: Nick Spelt

.DS_Store

@@ -15,8 +15,8 @@
   ],
   "require": {
     "php": "^7.1",
-    "psr/container": "1.0.0",
-    "event-sourcery/event-sourcery": "^0"
+    "event-sourcery/event-sourcery": "dev-master",
+    "psr/container": "1.0.0"
   },
   "require-dev": {
     "orchestra/testbench": "^3.6",

composer.json

@@ -1,13 +1,13 @@
 <?php namespace EventSourcery\Laravel;
 
+use EventSourcery\EventSourcery\EventDispatch\EventDispatcher;
+use EventSourcery\EventSourcery\Serialization\DomainEventSerializer;
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldQueue;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
 use EventSourcery\EventSourcery\EventSourcing\DomainEvent;
 use EventSourcery\EventSourcery\EventSourcing\DomainEvents;
-use EventSourcery\EventSourcery\EventSourcing\DomainEventSerializer;
-use EventSourcery\EventSourcery\EventSourcing\EventDispatcher;
 
 class DispatchDomainEvents implements ShouldQueue {
 
@@ -20,8 +20,10 @@ public function __construct(DomainEvents $events) {
             return $this->nameOfEvent($event);
         })->toArray();
 
-        $serializedEvents = $events->map(function (DomainEvent $event) {
-            return $event->serialize();
+        /** @var DomainEventSerializer $serializer */
+        $serializer = app(DomainEventSerializer::class);
+        $serializedEvents = $events->map(function (DomainEvent $event) use ($serializer) {
+            return $serializer->serialize($event);
         })->toArray();
 
         for ($i = 0; $i < $events->count(); $i++) {
@@ -50,10 +52,7 @@ private function deserializeEvents(DomainEventSerializer $serializer) {
         $events = [];
         foreach ($this->serializedEvents as $serializedEvent) {
             list($eventName, $eventData) = $serializedEvent;
-            $events[] = $serializer->deserialize((object) [
-                'event_name' => $eventName,
-                'event_data' => $eventData,
-            ]);
+            $events[] = $serializer->deserialize(json_decode($eventData, true));
         }
         return DomainEvents::make($events);
     }
@@ -71,4 +70,4 @@ private function tryToDeserializeEvents(DomainEventSerializer $serializer) {
             throw $e;
         }
     }
-}
+}

composer.lock

@@ -32,7 +32,7 @@ public function getStream(StreamId $id): StreamEvents {
                     return new StreamEvent(
                         StreamId::fromString($e->stream_id),
                         StreamVersion::fromInt($e->stream_version),
-                        $this->serializer->deserialize($e)
+                        $this->serializer->deserialize($e->event_data)
                     );
                 })
                 ->toArray()

src/DispatchDomainEvents.php

@@ -0,0 +1,68 @@
+<?php namespace Tests\EventSourcery\Laravel;
+
+use EventSourcery\EventSourcery\EventSourcing\StreamId;
+use EventSourcery\EventSourcery\PersonalData\CryptographicDetails;
+use EventSourcery\EventSourcery\PersonalData\EncryptionKey;
+use EventSourcery\EventSourcery\PersonalData\InitializationVector;
+use EventSourcery\EventSourcery\PersonalData\PersonalKey;
+use EventSourcery\Laravel\LaravelPersonalCryptographyStore;
+use EventSourcery\Laravel\RelationalEventStore;
+use Illuminate\Foundation\Testing\Concerns\InteractsWithDatabase;
+use Tests\EventSourcery\Laravel\Stubs\TestEmail;
+use Tests\EventSourcery\Laravel\Stubs\TestPersonalEvent;
+use Tests\EventSourcery\Laravel\Stubs\TestEvent;
+
+class RelationalEventStoreTest extends TestCase {
+
+    use InteractsWithDatabase;
+
+    /** @var RelationalEventStore */
+    private $dataStore;
+
+    /** @var LaravelPersonalCryptographyStore */
+    private $cryptoStore;
+
+    function setUp() {
+        parent::setUp();
+        $this->dataStore = $this->app->make(RelationalEventStore::class);
+        $this->cryptoStore = new LaravelPersonalCryptographyStore();
+
+        $person = PersonalKey::fromString("123");
+
+        $crypto = new CryptographicDetails(
+            EncryptionKey::generate(),
+            InitializationVector::generate()
+        );
+
+        $this->cryptoStore->addPerson($person, $crypto);
+    }
+
+    public function testItCanStoreAnEventWithPersonalData() {
+        $event = new TestPersonalEvent(new TestEmail(PersonalKey::fromString("123"), "test@abc.com"));
+        $this->dataStore->storeEvent($event);
+        $this->assertDatabaseHas('event_store', [
+            'event_name' => "TestPersonalEvent",
+        ]);
+    }
+
+    public function testItCanDeSerializeAnEventWithPersonalData() {
+        $event = new TestPersonalEvent(new TestEmail(PersonalKey::fromString("123"), "test@abc.com"));
+        $this->dataStore->storeEvent($event);
+        $events = $this->dataStore->getStream(StreamId::fromString(0));
+        $this->assertTrue($event == $events->toDomainEvents()->first());
+    }
+
+   public function testItCanStoreASimpleEvent() {
+        $event = new TestEvent(1);
+        $this->dataStore->storeEvent($event);
+        $this->assertDatabaseHas('event_store', [
+            'event_name' => "TestEvent",
+            'event_data' => json_encode([
+                'eventName' => "TestEvent",
+                'fields' => [
+                    'number' => 1
+                ]
+            ])
+        ]);
+    }
+}

src/RelationalEventStore.php

@@ -0,0 +1,36 @@
+<?php namespace Tests\EventSourcery\Laravel\Stubs;
+
+use EventSourcery\EventSourcery\PersonalData\PersonalKey;
+use EventSourcery\EventSourcery\PersonalData\SerializablePersonalDataValue;
+
+class TestEmail implements SerializablePersonalDataValue {
+    /**
+     * @var PersonalKey
+     */
+    private $personalKey;
+    /**
+     * @var string
+     */
+    private $email;
+
+    public function __construct(PersonalKey $personalKey, string $email) {
+        $this->personalKey = $personalKey;
+        $this->email = $email;
+    }
+
+    public function personalKey(): PersonalKey {
+        return $this->personalKey;
+    }
+
+    public function serialize(): string {
+        return json_encode([
+            'personalKey' => $this->personalKey->toString(),
+            'email' => $this->email,
+        ]);
+    }
+
+    public static function deserialize(string $string) {
+        $values = json_decode($string);
+        return new static(PersonalKey::fromString($values->personalKey), $values->email);
+    }
+}

tests/RelationalEventStoreTest.php

@@ -0,0 +1,13 @@
+<?php namespace Tests\EventSourcery\Laravel\Stubs;
+
+use EventSourcery\EventSourcery\EventSourcing\DomainEvent;
+
+class TestEvent implements DomainEvent {
+
+    /** @var int $number */
+    public $number;
+
+    public function __construct(int $number = 0) {
+        $this->number = $number;
+    }
+}

tests/Stubs/TestEmail.php

@@ -0,0 +1,5 @@
+<?php namespace Tests\EventSourcery\Laravel\Stubs;
+
+use EventSourcery\EventSourcery\EventSourcing\Id;
+
+class TestId extends Id  {}

tests/Stubs/TestEvent.php

@@ -0,0 +1,15 @@
+<?php namespace Tests\EventSourcery\Laravel\Stubs;
+
+use EventSourcery\EventSourcery\EventSourcing\DomainEvent;
+
+class TestPersonalEvent implements DomainEvent {
+
+    /**
+     * @var TestEmail
+     */
+    public $email;
+
+    public function __construct(TestEmail $email) {
+        $this->email = $email;
+    }
+}