enable json serialization

composer.json

@@ -22,7 +22,9 @@
         "illuminate/console": "5.6.*",
         "illuminate/database": "5.6.*",
         "illuminate/events": "5.6.*",
-        "illuminate/support": "5.6.*"
+        "illuminate/support": "5.6.*",
+        "symfony/property-access": "^4.0",
+        "symfony/serializer": "^4.0"
     },
     "require-dev": {
         "mockery/mockery": "^1.1",

src/EventSerializer.php

@@ -0,0 +1,37 @@
+<?php
+
+namespace Spatie\EventProjector;
+
+use Symfony\Component\Serializer\Encoder\JsonEncoder;
+use Symfony\Component\Serializer\Normalizer\ObjectNormalizer;
+use Symfony\Component\Serializer\Serializer;
+
+class EventSerializer
+{
+    /** @var \Symfony\Component\Serializer\Serializer */
+    protected $serializer;
+
+    public function __construct()
+    {
+        $encoders = array(new JsonEncoder());
+        $normalizers = array(new ObjectNormalizer());
+
+        $this->serializer = new Serializer($normalizers, $encoders);
+    }
+
+    public function serialize(ShouldBeStored $event): string
+    {
+        $event->__sleep();
+
+        $json = $this->serializer->serialize($event, 'json');
+
+        return $json;
+    }
+
+    public function deserialize(string $eventClass, string $json): ShouldBeStored
+    {
+        $restoredEvent = $this->serializer->deserialize($json, $eventClass, 'json');
+
+        return unserialize(serialize($restoredEvent));
+    }
+}

src/StoredEvent.php

@@ -4,6 +4,7 @@
 
 use Illuminate\Database\Eloquent\Model;
 
+
 class StoredEvent extends Model
 {
     public $guarded = [];
@@ -14,14 +15,18 @@ class StoredEvent extends Model
 
     public static function createForEvent(ShouldBeStored $event): self
     {
-        return static::create([
-            'event_class' => get_class($event),
-            'serialized_event' => serialize(clone $event),
-        ]);
+        $storedEvent = new StoredEvent();
+        $storedEvent->event_class = get_class($event);
+        $storedEvent->attributes['serialized_event'] = (new EventSerializer())->serialize(clone $event);
+        $storedEvent->save();
+
+       return $storedEvent;
     }
 
     public function getEventAttribute(): ShouldBeStored
     {
-        return unserialize($this->serialized_event);
+       return (new EventSerializer())->deserialize($this->event_class, $this->getOriginal('serialized_event'));
+
+
     }
 }

tests/Console/ReplayEventsCommandTest.php

@@ -18,7 +18,7 @@ public function setUp()
 
         $account = Account::create();
 
-        foreach(range(1,10) as $i) {
+        foreach(range(1,3) as $i) {
             event(new MoneyAdded($account, 1234));
         }
     }
@@ -28,7 +28,7 @@ public function it_will_replay_events_to_the_given_projectors()
     {
         $projector = Mockery::mock(BalanceProjector::class);
 
-        $projector->shouldReceive('onMoneyAdded')->andReturnNull()->times(10);
+        $projector->shouldReceive('onMoneyAdded')->andReturnNull()->times(3);
 
         EventProjectionist::addProjector($projector);