Changed to new version

Author: italolelis

src/CommandBus/TacticianCommandBus.php

@@ -2,10 +2,6 @@
 
 namespace HelloFresh\Engine\CommandBus;
 
-use Assert\Assertion;
-use Collections\Dictionary;
-use Collections\MapInterface;
-use Collections\Queue;
 use League\Tactician\CommandBus;
 
 class TacticianCommandBus implements CommandBusInterface

src/Domain/EventStream.php

@@ -2,9 +2,9 @@
 
 namespace HelloFresh\Engine\Domain;
 
-use Collections\Immutable\ImmArrayList;
+use Collections\Immutable\ImmVector;
 
-class EventStream extends ImmArrayList
+class EventStream extends ImmVector
 {
     /**
      * @var StreamName

src/EventBus/SimpleEventBus.php

@@ -2,7 +2,7 @@
 
 namespace HelloFresh\Engine\EventBus;
 
-use Collections\ArrayList;
+use Collections\Vector;
 use Collections\Queue;
 use Collections\VectorInterface;
 use HelloFresh\Engine\Domain\DomainEventInterface;
@@ -32,7 +32,7 @@ class SimpleEventBus implements EventBusInterface
      */
     public function __construct()
     {
-        $this->eventListeners = new ArrayList();
+        $this->eventListeners = new Vector();
         $this->queue = new Queue();
     }
 

src/EventDispatcher/InMemoryDispatcher.php

@@ -2,9 +2,10 @@
 
 namespace HelloFresh\Engine\EventDispatcher;
 
-use Collections\ArrayList;
-use Collections\Dictionary;
+use Collections\Map;
 use Collections\MapInterface;
+use Collections\Pair;
+use Collections\Vector;
 
 /**
  * In Memory Event dispatcher implementation.
@@ -21,7 +22,7 @@ class InMemoryDispatcher implements EventDispatcherInterface, EventListenerInter
      */
     public function __construct()
     {
-        $this->listeners = new Dictionary();
+        $this->listeners = new Map();
     }
 
     /**
@@ -44,7 +45,7 @@ public function dispatch($eventName, ...$arguments)
     public function addListener($eventName, callable $callable)
     {
         if (!$this->listeners->containsKey($eventName)) {
-            $this->listeners->add($eventName, new ArrayList());
+            $this->listeners->add(new Pair($eventName, new Vector()));
         }
 
         $this->listeners->get($eventName)->add($callable);

src/EventSourcing/AggregateRepositoryFactory.php

@@ -2,7 +2,7 @@
 
 namespace HelloFresh\Engine\EventSourcing;
 
-use Collections\Dictionary;
+use Collections\Map;
 use Collections\MapInterface;
 use HelloFresh\Engine\EventBus\SimpleEventBus;
 use HelloFresh\Engine\EventStore\Adapter\InMemoryAdapter;
@@ -26,10 +26,10 @@ class AggregateRepositoryFactory implements AggregateRepositoryFactoryInterface
     public function __construct($config = null)
     {
         if (!$config instanceof MapInterface) {
-            $config = new Dictionary($config);
+            $config = new Map($config);
         }
 
-        $this->config = new Dictionary([
+        $this->config = new Map([
             'event_bus' => [
                 'service' => new SimpleEventBus()
             ],
@@ -74,7 +74,7 @@ public function build()
     private function configureEventStore(MapInterface $config)
     {
         $adapterName = $config->get('adapter');
-        $arguments = $config->tryGet('arguments', []);
+        $arguments = $config->get('arguments') ? $config->get('arguments') : [];
 
         $adapter = new $adapterName(...$arguments);
 
@@ -84,7 +84,7 @@ private function configureEventStore(MapInterface $config)
     private function configureSnapshotStore(MapInterface $config)
     {
         $adapterName = $config->get('adapter');
-        $arguments = $config->tryGet('arguments', []);
+        $arguments = $config->get('arguments') ? $config->get('arguments') : [];
 
         $adapter = new $adapterName(...$arguments);
 
@@ -94,7 +94,7 @@ private function configureSnapshotStore(MapInterface $config)
     private function configureSnapshotStrategy(MapInterface $config)
     {
         $adapterName = $config->get('name');
-        $arguments = $config->tryGet('arguments', []);
+        $arguments = $config->get('arguments') ? $config->get('arguments') : [];
 
         return new $adapterName(...$arguments);
     }

src/EventStore/Adapter/InMemoryAdapter.php

@@ -2,9 +2,10 @@
 
 namespace HelloFresh\Engine\EventStore\Adapter;
 
-use Collections\ArrayList;
-use Collections\Dictionary;
+use Collections\Map;
 use Collections\MapInterface;
+use Collections\Pair;
+use Collections\Vector;
 use Collections\VectorInterface;
 use HelloFresh\Engine\Domain\AggregateIdInterface;
 use HelloFresh\Engine\Domain\DomainMessage;
@@ -20,22 +21,22 @@ class InMemoryAdapter implements EventStoreAdapterInterface
 
     public function __construct()
     {
-        $this->events = new Dictionary();
+        $this->events = new Map();
     }
 
     public function save(StreamName $streamName, DomainMessage $event)
     {
         $id = (string)$event->getId();
         $name = (string)$streamName;
-        $events = $this->events->tryGet($name);
+        $events = $this->events->get($name);
 
-        if (!$events) {
-            $events = new Dictionary();
-            $this->events->add($name, $events);
+        if (null === $events) {
+            $events = new Map();
+            $this->events->add(new Pair($name, $events));
         }
 
         if (!$events->containsKey($id)) {
-            $events->add($id, new ArrayList());
+            $events->add(new Pair($id, new Vector()));
         }
 
         $events->get($id)->add($event);
@@ -47,7 +48,7 @@ public function getEventsFor(StreamName $streamName, $id)
         $name = (string)$streamName;
         /** @var MapInterface $events */
         try {
-            $events = $this->events->get($name);
+            $events = $this->events->at($name);
         } catch (\OutOfBoundsException $e) {
             throw new EventStreamNotFoundException("Stream $name not found", $e->getCode(), $e);
         }

src/EventStore/Snapshot/Adapter/InMemorySnapshotAdapter.php

@@ -2,8 +2,9 @@
 
 namespace HelloFresh\Engine\EventStore\Snapshot\Adapter;
 
-use Collections\Dictionary;
+use Collections\Map;
 use Collections\MapInterface;
+use Collections\Pair;
 use HelloFresh\Engine\Domain\AggregateIdInterface;
 use HelloFresh\Engine\EventStore\Snapshot\Snapshot;
 
@@ -16,17 +17,17 @@ class InMemorySnapshotAdapter implements SnapshotStoreAdapterInterface
 
     public function __construct()
     {
-        $this->snapshots = new Dictionary();
+        $this->snapshots = new Map();
     }
 
     public function byId(AggregateIdInterface $id)
     {
-        return $this->snapshots->tryGet((string)$id);
+        return $this->snapshots->get((string)$id);
     }
 
     public function save(Snapshot $snapshot)
     {
-        $this->snapshots->add((string)$snapshot->getAggregateId(), $snapshot);
+        $this->snapshots->add(new Pair((string)$snapshot->getAggregateId(), $snapshot));
     }
 
     public function has(AggregateIdInterface $id, $version)

src/Serializer/README.md

@@ -21,7 +21,7 @@ use HelloFresh\Engine\Serializer\Adapter\JmsSerializerAdapter;
 $jmsSerializer = SerializerBuilder::create()
     ->setMetadataDirs(['' => __DIR__ . '/metadata'])
     ->configureHandlers(function (HandlerRegistry $registry) {
-        $registry->registerSubscribingHandler(new ArrayListHandler());
+        $registry->registerSubscribingHandler(new VectorHandler());
         $registry->registerSubscribingHandler(new UuidSerializerHandler());
     })
     ->addDefaultHandlers()

tests/EventStore/EventStoreTest.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace HelloFresh\Tests\Engine\EventSourcing;
+namespace HelloFresh\Tests\Engine\EventStore;
 
 use HelloFresh\Engine\Domain\AggregateId;
 use HelloFresh\Engine\Domain\DomainMessage;

tests/EventStore/InMemoryEventStoreTest.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace HelloFresh\Tests\Engine\EventSourcing;
+namespace HelloFresh\Tests\Engine\EventStore;
 
 use HelloFresh\Engine\EventStore\Adapter\InMemoryAdapter;
 use HelloFresh\Engine\EventStore\EventStore;