updated to v2.0.0

mauretto78 · Aug 25, 2017 · 8b69f1b · 8b69f1b
1 parent d4a017f
commit 8b69f1b
Show file tree

Hide file tree

Showing 10 changed files with 234 additions and 136 deletions.
diff --git a/Controller/EventStoreManagerBundleController.php b/Controller/EventStoreManagerBundleController.php
@@ -1,6 +1,6 @@
 <?php
 /**
- * This file is part of the Simple EventStore Manager package.
+ * This file is part of the Simple EventStore EventStoreManager package.
  *
  * (c) Mauro Cassani<https://github.com/mauretto78>
  *
@@ -11,8 +11,9 @@
 namespace SimpleEventStoreManager\Bundle\Controller;
 
 use JMS\Serializer\SerializerBuilder;
+use SimpleEventStoreManager\Application\Event\EventRepresentation;
 use SimpleEventStoreManager\Application\EventQuery;
-use SimpleEventStoreManager\Bundle\Service\Manager;
+use SimpleEventStoreManager\Bundle\Service\EventStoreManager;
 use Symfony\Bundle\FrameworkBundle\Controller\Controller;
 use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\Routing\Annotation\Route;
@@ -27,13 +28,13 @@ class EventStoreManagerBundleController extends Controller
      */
     public function aggregateAction(Request $request, $aggregate, $page = null)
     {
-        /** @var Manager $manager */
-        $manager = $this->container->get('simple_event_store_manager');
-        $eventManager = $manager->getMananger();
+        /** @var EventStoreManager $eventStoreManager */
+        $eventStoreManager = $this->container->get('simple_event_store_manager');
+        $eventManager = $eventStoreManager->getEventMananger();
 
         $config = $this->container->getParameter('simple_event_store_manager');
         $dataTransformer = 'SimpleEventStoreManager\\Infrastructure\\DataTransformers\\'.ucfirst($config['api_format']).'EventDataTransformer';
-        $eventsQuery = new EventQuery(
+        $eventsQuery = new EventRepresentation(
             $eventManager,
             new $dataTransformer(
                 SerializerBuilder::create()->build(),

diff --git a/DependencyInjection/Configuration.php b/DependencyInjection/Configuration.php
@@ -1,6 +1,6 @@
 <?php
 /**
- * This file is part of the Simple EventStore Manager package.
+ * This file is part of the Simple EventStore EventStoreManager package.
  *
  * (c) Mauro Cassani<https://github.com/mauretto78>
  *
@@ -44,6 +44,13 @@ public function getConfigTreeBuilder()
                     ])
                     ->defaultValue('json')
                 ->end()
+                ->enumNode('return_type')
+                ->values([
+                    'array',
+                    'object'
+                ])
+                ->defaultValue('array')
+                ->end()
                 ->arrayNode('parameters')
                     ->isRequired()
                     ->prototype('variable')

diff --git a/DependencyInjection/SimpleEventStoreManagerExtension.php b/DependencyInjection/SimpleEventStoreManagerExtension.php
@@ -1,6 +1,6 @@
 <?php
 /**
- * This file is part of the Simple EventStore Manager package.
+ * This file is part of the Simple EventStore EventStoreManager package.
  *
  * (c) Mauro Cassani<https://github.com/mauretto78>
  *

diff --git a/README.md b/README.md
@@ -29,11 +29,13 @@ simple_event_store_manager:
         password: ~
         database: 'eventstore_demo'
         port: '27017'
+    return_type: 'array'   
     elastic:
         host: 'localhost'
         port: '9200'
 ```
 
+* `return_type` is an optional parameter; you can choose between array or object to return aggregates
 * `api_format` is an optional parameter; you can choose between `json` (default), `xml` or `yaml`
 * `elastic` is an optional parameter; you can send your events to a Elastic server
 
@@ -63,7 +65,7 @@ You can use `EventsManager` in your Controllers:
 // ..
 
 $manager = $this->container->get('simple_event_store_manager');
-$eventManager = $manager->getMananger();
+$eventManager = $manager->getEventMananger();
 
 // store events in an aggregate
 $eventManager->storeEvents(
@@ -73,6 +75,14 @@ $eventManager->storeEvents(
     ]
 );
 
+// get event streams
+$eventQuery = $eventStoreManager->getEventQuery();
+
+$stream = $eventQuery->fromAggregate('Your aggregate');
+foreach ($stream as $event){
+    // ..
+}
+
 ```
 
 Or inject it into your services and classes:

diff --git a/Resources/config/services.yml b/Resources/config/services.yml
@@ -1,5 +1,5 @@
 parameters:
-    simple_event_store_manager.class: SimpleEventStoreManager\Bundle\Service\Manager
+    simple_event_store_manager.class: SimpleEventStoreManager\Bundle\Service\EventStoreManager
 
 services:
     simple_event_store_manager:

diff --git a/Service/EventStoreManager.php b/Service/EventStoreManager.php
@@ -0,0 +1,80 @@
+<?php
+/**
+ * This file is part of the Simple EventStore EventStoreManager package.
+ *
+ * (c) Mauro Cassani<https://github.com/mauretto78>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace SimpleEventStoreManager\Bundle\Service;
+
+use SimpleEventStoreManager\Application\Event\EventManager as EM;
+use SimpleEventStoreManager\Application\Event\EventQuery as EQ;
+use SimpleEventStoreManager\Application\Event\EventQuery;
+use SimpleEventStoreManager\Domain\Model\Contracts\EventAggregateRepositoryInterface;
+
+class EventStoreManager
+{
+    /**
+     * @var EM
+     */
+    private $eventManager;
+
+    /**
+     * @var EQ
+     */
+    private $eventQuery;
+
+    /**
+     * EventStoreManager constructor.
+     *
+     * @param array $config
+     */
+    public function __construct(array $config = [])
+    {
+        $this->setEventMananger($config);
+        $this->setEventQuery($this->eventManager);
+    }
+
+    /**
+     * @param $config
+     */
+    private function setEventMananger($config)
+    {
+        $returnType = ($config['return_type'] === 'array') ? EventAggregateRepositoryInterface::RETURN_AS_ARRAY : EventAggregateRepositoryInterface::RETURN_AS_OBJECT;
+        $this->eventManager = EM::build()
+            ->setDriver($config['driver'])
+            ->setConnection($config['parameters'])
+            ->setReturnType($returnType);
+
+        if($config['elastic']){
+            $this->eventManager->setElasticServer($config['elastic']);
+        }
+    }
+
+    /**
+     * @return EM
+     */
+    public function getEventMananger()
+    {
+        return $this->eventManager;
+    }
+
+    /**
+     * @param EM $eventManager
+     */
+    private function setEventQuery(EM $eventManager)
+    {
+        $this->eventQuery = new EventQuery($eventManager);
+    }
+
+    /**
+     * @return EQ
+     */
+    public function getEventQuery()
+    {
+        return $this->eventQuery;
+    }
+}
diff --git a/Service/Manager.php b/Service/Manager.php
diff --git a/SimpleEventStoreManagerBundle.php b/SimpleEventStoreManagerBundle.php
@@ -1,6 +1,6 @@
 <?php
 /**
- * This file is part of the Simple EventStore Manager package.
+ * This file is part of the Simple EventStore EventStoreManager package.
  *
  * (c) Mauro Cassani<https://github.com/mauretto78>
  *
@@ -14,5 +14,5 @@
 
 class SimpleEventStoreManagerBundle extends Bundle
 {
-    const VERSION = '1.0.1';
+    const VERSION = '2.0.0ß';
 }
diff --git a/composer.json b/composer.json
@@ -24,7 +24,7 @@
         }
     ],
     "require": {
-        "mauretto78/simple-event-store-manager": "^1.2",
+        "mauretto78/simple-event-store-manager": "^2.0",
         "symfony/http-kernel": "~2.3|~3.0",
         "symfony/dependency-injection": "~2.3|~3.0",
         "symfony/yaml": "~2.3|~3.0",