Merge pull request #59 from prooph/projection_manager

Projection manager, Updates & Bugfixes

Author: prolic

composer.json

@@ -29,7 +29,7 @@
     },
     "suggest": {
         "psr/container": "^1.0 for usage of provided factories",
-        "sandrokeil/interop-config": "For usage of provided factories",
+        "sandrokeil/interop-config": "^2.0.1 for usage of provided factories",
         "ext-pdo_mysql": "For usage with MySQL",
         "ext-pdo_pgsql": "For usage with PostgreSQL"
     },

phpunit.xml.pdo_mysql

@@ -22,9 +22,7 @@
                 <file>./src/PersistenceStrategy/PostgresAggregateStreamStrategy.php</file>
                 <file>./src/PersistenceStrategy/PostgresSimpleStreamStrategy.php</file>
                 <file>./src/PersistenceStrategy/PostgresSingleStreamStrategy.php</file>
-                <file>./src/Projection/PostgresEventStoreProjection.php</file>
-                <file>./src/Projection/PostgresEventStoreQuery.php</file>
-                <file>./src/Projection/PostgresEventStoreReadModelProjection.php</file>
+                <file>./src/Projection/PostgresProjectionManager.php</file>
                 <file>./src/PostgresEventStore.php</file>
             </exclude>
         </whitelist>

phpunit.xml.pdo_pgsql

@@ -22,9 +22,7 @@
                 <file>./src/PersistenceStrategy/MySqlAggregateStreamStrategy.php</file>
                 <file>./src/PersistenceStrategy/MySqlSimpleStreamStrategy.php</file>
                 <file>./src/PersistenceStrategy/MySqlSingleStreamStrategy.php</file>
-                <file>./src/Projection/MySqlEventStoreProjection.php</file>
-                <file>./src/Projection/MySqlEventStoreQuery.php</file>
-                <file>./src/Projection/MySqlEventStoreReadModelProjection.php</file>
+                <file>./src/Projection/MySqlProjectionManager.php</file>
                 <file>./src/MySqlEventStore.php</file>
             </exclude>
         </whitelist>

src/Container/AbstractEventStoreFactory.php

@@ -95,8 +95,7 @@ public function __invoke(ContainerInterface $container): EventStore
             $connection,
             $container->get($config['persistence_strategy']),
             $config['load_batch_size'],
-            $config['event_streams_table'],
-            $config['projections_table']
+            $config['event_streams_table']
         );
 
         if (! $config['wrap_action_event_emitter']) {

src/Container/MySqlEventStoreFactory.php

@@ -33,12 +33,10 @@ protected function createActionEventEmitterEventStore(EventStore $eventStore): A
                 ActionEventEmitterEventStore::EVENT_HAS_STREAM,
                 ActionEventEmitterEventStore::EVENT_FETCH_STREAM_METADATA,
                 ActionEventEmitterEventStore::EVENT_UPDATE_STREAM_METADATA,
-                ActionEventEmitterEventStore::EVENT_DELETE_PROJECTION,
-                ActionEventEmitterEventStore::EVENT_RESET_PROJECTION,
-                ActionEventEmitterEventStore::EVENT_STOP_PROJECTION,
                 ActionEventEmitterEventStore::EVENT_FETCH_STREAM_NAMES,
+                ActionEventEmitterEventStore::EVENT_FETCH_STREAM_NAMES_REGEX,
                 ActionEventEmitterEventStore::EVENT_FETCH_CATEGORY_NAMES,
-                ActionEventEmitterEventStore::EVENT_FETCH_PROJECTION_NAMES,
+                ActionEventEmitterEventStore::EVENT_FETCH_CATEGORY_NAMES_REGEX,
             ])
         );
     }
@@ -84,7 +82,6 @@ public function defaultOptions(): iterable
             ],
             'load_batch_size' => 1000,
             'event_streams_table' => 'event_streams',
-            'projections_table' => 'projections',
             'message_factory' => FQCNMessageFactory::class,
             'wrap_action_event_emitter' => true,
             'metadata_enrichers' => [],

src/Container/PostgresEventStoreFactory.php

@@ -34,12 +34,10 @@ protected function createActionEventEmitterEventStore(EventStore $eventStore): A
                 TransactionalActionEventEmitterEventStore::EVENT_HAS_STREAM,
                 TransactionalActionEventEmitterEventStore::EVENT_FETCH_STREAM_METADATA,
                 TransactionalActionEventEmitterEventStore::EVENT_UPDATE_STREAM_METADATA,
-                TransactionalActionEventEmitterEventStore::EVENT_DELETE_PROJECTION,
-                TransactionalActionEventEmitterEventStore::EVENT_RESET_PROJECTION,
-                TransactionalActionEventEmitterEventStore::EVENT_STOP_PROJECTION,
                 TransactionalActionEventEmitterEventStore::EVENT_FETCH_STREAM_NAMES,
+                TransactionalActionEventEmitterEventStore::EVENT_FETCH_STREAM_NAMES_REGEX,
                 TransactionalActionEventEmitterEventStore::EVENT_FETCH_CATEGORY_NAMES,
-                TransactionalActionEventEmitterEventStore::EVENT_FETCH_PROJECTION_NAMES,
+                TransactionalActionEventEmitterEventStore::EVENT_FETCH_CATEGORY_NAMES_REGEX,
                 TransactionalActionEventEmitterEventStore::EVENT_BEGIN_TRANSACTION,
                 TransactionalActionEventEmitterEventStore::EVENT_COMMIT,
                 TransactionalActionEventEmitterEventStore::EVENT_ROLLBACK,
@@ -88,7 +86,6 @@ public function defaultOptions(): iterable
             ],
             'load_batch_size' => 1000,
             'event_streams_table' => 'event_streams',
-            'projections_table' => 'projections',
             'message_factory' => FQCNMessageFactory::class,
             'wrap_action_event_emitter' => true,
             'metadata_enrichers' => [],