replace pipeline with subscription

deptrac.yaml

@@ -64,10 +64,6 @@ deptrac:
               value: MetadataMessage
             - type: layer
               value: MetadataSubscriber
-    - name: Pipeline
-      collectors:
-        - type: directory
-          value: src/Pipeline/.*
     - name: Repository
       collectors:
         - type: directory
@@ -117,8 +113,10 @@ deptrac:
       - Attribute
       - Message
     Message:
+      - Aggregate
       - MetadataMessage
       - Serializer
+      - Store
     Metadata:
     MetadataAggregate:
       - Aggregate
@@ -134,12 +132,6 @@ deptrac:
       - Attribute
       - Metadata
       - Subscription
-    Pipeline:
-      - Aggregate
-      - EventBus
-      - Message
-      - Store
-      - Subscription
     Subscription:
       - Attribute
       - Clock

docs/pages/pipeline.md

@@ -10,12 +10,7 @@ whether the migration worked.
 In this example the event `PrivacyAdded` is removed and the event `OldVisited` is replaced by `NewVisited`:
 
 ```php
-use Patchlevel\EventSourcing\Pipeline\Middleware\ExcludeEventMiddleware;
-use Patchlevel\EventSourcing\Pipeline\Middleware\RecalculatePlayheadMiddleware;
-use Patchlevel\EventSourcing\Pipeline\Middleware\ReplaceEventMiddleware;
-use Patchlevel\EventSourcing\Pipeline\Pipeline;
-use Patchlevel\EventSourcing\Pipeline\Source\StoreSource;
-use Patchlevel\EventSourcing\Pipeline\Target\StoreTarget;
+use Patchlevel\EventSourcing\Message\Middleware\ExcludeEventMiddleware;use Patchlevel\EventSourcing\Message\Middleware\RecalculatePlayheadMiddleware;use Patchlevel\EventSourcing\Message\Middleware\ReplaceEventMiddleware;use Patchlevel\EventSourcing\Pipeline\Pipeline;use Patchlevel\EventSourcing\Pipeline\Source\StoreSource;use Patchlevel\EventSourcing\Pipeline\Target\StoreTarget;
 
 $pipeline = new Pipeline(
     new StoreSource($oldStore),
@@ -211,7 +206,7 @@ Middelwares can be used to manipulate, delete or expand messages or events durin
 With this middleware you can exclude certain events.
 
 ```php
-use Patchlevel\EventSourcing\Pipeline\Middleware\ExcludeEventMiddleware;
+use Patchlevel\EventSourcing\Message\Middleware\ExcludeEventMiddleware;
 
 $middleware = new ExcludeEventMiddleware([EmailChanged::class]);
 ```
@@ -226,7 +221,7 @@ $middleware = new ExcludeEventMiddleware([EmailChanged::class]);
 With this middleware you can only allow certain events.
 
 ```php
-use Patchlevel\EventSourcing\Pipeline\Middleware\IncludeEventMiddleware;
+use Patchlevel\EventSourcing\Message\Middleware\IncludeEventMiddleware;
 
 $middleware = new IncludeEventMiddleware([ProfileCreated::class]);
 ```
@@ -242,8 +237,7 @@ you can also write your own filter.
 This middleware expects a callback that returns either true to allow events or false to not allow them.
 
 ```php
-use Patchlevel\EventSourcing\Aggregate\AggregateChanged;
-use Patchlevel\EventSourcing\Pipeline\Middleware\FilterEventMiddleware;
+use Patchlevel\EventSourcing\Aggregate\AggregateChanged;use Patchlevel\EventSourcing\Message\Middleware\FilterEventMiddleware;
 
 $middleware = new FilterEventMiddleware(function (AggregateChanged $event) {
     if (!$event instanceof ProfileCreated) {
@@ -263,7 +257,7 @@ $middleware = new FilterEventMiddleware(function (AggregateChanged $event) {
 With this middleware you can exclude archived events.
 
 ```php
-use Patchlevel\EventSourcing\Pipeline\Middleware\ExcludeArchivedEventMiddleware;
+use Patchlevel\EventSourcing\Message\Middleware\ExcludeArchivedEventMiddleware;
 
 $middleware = new ExcludeArchivedEventMiddleware();
 ```
@@ -277,7 +271,7 @@ $middleware = new ExcludeArchivedEventMiddleware();
 With this middleware you can only allow archived events.
 
 ```php
-use Patchlevel\EventSourcing\Pipeline\Middleware\OnlyArchivedEventMiddleware;
+use Patchlevel\EventSourcing\Message\Middleware\OnlyArchivedEventMiddleware;
 
 $middleware = new OnlyArchivedEventMiddleware();
 ```
@@ -293,7 +287,7 @@ The first parameter you have to define is the event class that you want to repla
 And as a second parameter a callback, that the old event awaits and a new event returns.
 
 ```php
-use Patchlevel\EventSourcing\Pipeline\Middleware\ReplaceEventMiddleware;
+use Patchlevel\EventSourcing\Message\Middleware\ReplaceEventMiddleware;
 
 $middleware = new ReplaceEventMiddleware(OldVisited::class, static function (OldVisited $oldVisited) {
     return new NewVisited($oldVisited->profileId());
@@ -326,7 +320,7 @@ The playhead must always be in ascending order so that the data is valid.
 Some middleware can break this order and the middleware `RecalculatePlayheadMiddleware` can fix this problem.
 
 ```php
-use Patchlevel\EventSourcing\Pipeline\Middleware\RecalculatePlayheadMiddleware;
+use Patchlevel\EventSourcing\Message\Middleware\RecalculatePlayheadMiddleware;
 
 $middleware = new RecalculatePlayheadMiddleware();
 ```
@@ -340,9 +334,7 @@ $middleware = new RecalculatePlayheadMiddleware();
 If you want to group your middleware, you can use one or more `ChainMiddleware`.
 
 ```php
-use Patchlevel\EventSourcing\Pipeline\Middleware\ChainMiddleware;
-use Patchlevel\EventSourcing\Pipeline\Middleware\ExcludeEventMiddleware;
-use Patchlevel\EventSourcing\Pipeline\Middleware\RecalculatePlayheadMiddleware;
+use Patchlevel\EventSourcing\Message\Middleware\ChainMiddleware;use Patchlevel\EventSourcing\Message\Middleware\ExcludeEventMiddleware;use Patchlevel\EventSourcing\Message\Middleware\RecalculatePlayheadMiddleware;
 
 $middleware = new ChainMiddleware([
     new ExcludeEventMiddleware([EmailChanged::class]),
@@ -366,8 +358,7 @@ Now we have a `ProfileRegistered` and a `ProfileActivated` event,
 which should replace the `ProfileCreated` event.
 
 ```php
-use Patchlevel\EventSourcing\Message\Message;
-use Patchlevel\EventSourcing\Pipeline\Middleware\Middleware;
+use Patchlevel\EventSourcing\Message\Message;use Patchlevel\EventSourcing\Message\Middleware\Middleware;
 
 final class SplitProfileCreatedMiddleware implements Middleware
 {

src/Pipeline/Middleware/ChainMiddleware.php → src/Message/Middleware/ChainMiddleware.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Patchlevel\EventSourcing\Pipeline\Middleware;
+namespace Patchlevel\EventSourcing\Message\Middleware;
 
 use Patchlevel\EventSourcing\Message\Message;
 

src/Pipeline/Middleware/ExcludeArchivedEventMiddleware.php → src/Message/Middleware/ExcludeArchivedEventMiddleware.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Patchlevel\EventSourcing\Pipeline\Middleware;
+namespace Patchlevel\EventSourcing\Message\Middleware;
 
 use Patchlevel\EventSourcing\Message\HeaderNotFound;
 use Patchlevel\EventSourcing\Message\Message;

src/Pipeline/Middleware/ExcludeEventMiddleware.php → src/Message/Middleware/ExcludeEventMiddleware.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Patchlevel\EventSourcing\Pipeline\Middleware;
+namespace Patchlevel\EventSourcing\Message\Middleware;
 
 use Patchlevel\EventSourcing\Message\Message;
 

src/Pipeline/Middleware/FilterEventMiddleware.php → src/Message/Middleware/FilterEventMiddleware.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Patchlevel\EventSourcing\Pipeline\Middleware;
+namespace Patchlevel\EventSourcing\Message\Middleware;
 
 use Patchlevel\EventSourcing\Message\Message;
 

src/Pipeline/Middleware/IncludeEventMiddleware.php → src/Message/Middleware/IncludeEventMiddleware.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Patchlevel\EventSourcing\Pipeline\Middleware;
+namespace Patchlevel\EventSourcing\Message\Middleware;
 
 use Patchlevel\EventSourcing\Message\Message;
 

src/Pipeline/Middleware/Middleware.php → src/Message/Middleware/Middleware.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Patchlevel\EventSourcing\Pipeline\Middleware;
+namespace Patchlevel\EventSourcing\Message\Middleware;
 
 use Patchlevel\EventSourcing\Message\Message;
 

src/Pipeline/Middleware/OnlyArchivedEventMiddleware.php → src/Message/Middleware/OnlyArchivedEventMiddleware.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Patchlevel\EventSourcing\Pipeline\Middleware;
+namespace Patchlevel\EventSourcing\Message\Middleware;
 
 use Patchlevel\EventSourcing\Message\HeaderNotFound;
 use Patchlevel\EventSourcing\Message\Message;

src/Pipeline/Middleware/RecalculatePlayheadMiddleware.php → src/Message/Middleware/RecalculatePlayheadMiddleware.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Patchlevel\EventSourcing\Pipeline\Middleware;
+namespace Patchlevel\EventSourcing\Message\Middleware;
 
 use Patchlevel\EventSourcing\Aggregate\AggregateHeader;
 use Patchlevel\EventSourcing\Message\Message;

src/Pipeline/Middleware/ReplaceEventMiddleware.php → src/Message/Middleware/ReplaceEventMiddleware.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Patchlevel\EventSourcing\Pipeline\Middleware;
+namespace Patchlevel\EventSourcing\Message\Middleware;
 
 use Patchlevel\EventSourcing\Message\Message;
 

src/Pipeline/Middleware/UntilEventMiddleware.php → src/Message/Middleware/UntilEventMiddleware.php

@@ -2,7 +2,7 @@
 
 declare(strict_types=1);
 
-namespace Patchlevel\EventSourcing\Pipeline\Middleware;
+namespace Patchlevel\EventSourcing\Message\Middleware;
 
 use DateTimeImmutable;
 use Patchlevel\EventSourcing\Aggregate\AggregateHeader;