finish DI & update readme

Author: DavidBadura

README.md

@@ -1,42 +1,38 @@
-[![Type Coverage](https://shepherd.dev/github/patchlevel/event-sourcing-bundle/coverage.svg)](https://shepherd.dev/github/patchlevel/event-sourcing-bundle)
-[![Latest Stable Version](https://poser.pugx.org/patchlevel/event-sourcing-bundle/v)](//packagist.org/packages/patchlevel/event-sourcing-bundle)
-[![License](https://poser.pugx.org/patchlevel/event-sourcing-bundle/license)](//packagist.org/packages/patchlevel/event-sourcing-bundle)
+[![Type Coverage](https://shepherd.dev/github/patchlevel/laravel-event-sourcing/coverage.svg)](https://shepherd.dev/github/patchlevel/laravel-event-sourcing)
+[![Latest Stable Version](https://poser.pugx.org/patchlevel/laravel-event-sourcing/v)](//packagist.org/packages/patchlevel/laravel-event-sourcing)
+[![License](https://poser.pugx.org/patchlevel/laravel-event-sourcing/license)](//packagist.org/packages/patchlevel/laravel-event-sourcing)
 
-# Event-Sourcing-Bundle
+# Laravel-Event-Sourcing
 
-An event sourcing bundle, complete with all the essential features,
+An event sourcing laravel package, complete with all the essential features,
 powered by the reliable Doctrine ecosystem and focused on developer experience.
-This bundle is a [symfony](https://symfony.com/) integration 
+This package is a [laravel](https://laravel.com/) integration 
 for [event-sourcing](https://github.com/patchlevel/event-sourcing) library.
 
 ## Features
 
 * Everything is included in the package for event sourcing
 * Based on [doctrine dbal](https://github.com/doctrine/dbal) and their ecosystem
 * Developer experience oriented and fully typed
-* Automatic [snapshot](https://patchlevel.github.io/event-sourcing-docs/latest/snapshots/)-system to boost your performance
-* [Split](https://patchlevel.github.io/event-sourcing-docs/latest/split_stream/) big aggregates into multiple streams
-* Versioned and managed lifecycle of [subscriptions](https://patchlevel.github.io/event-sourcing-docs/latest/subscription/) like projections and processors
-* Safe usage of [Personal Data](https://patchlevel.github.io/event-sourcing-docs/latest/personal_data/) with crypto-shredding
-* Smooth [upcasting](https://patchlevel.github.io/event-sourcing-docs/latest/upcasting/) of old events
-* Simple setup with [scheme management](https://patchlevel.github.io/event-sourcing-docs/latest/store/) and [doctrine migration](https://patchlevel.github.io/event-sourcing-docs/latest/store/)
-* Built in [cli commands](https://patchlevel.github.io/event-sourcing-docs/latest/cli/) with [symfony](https://symfony.com/)
+* Automatic [snapshot](https://event-sourcing.patchlevel.io/latest/snapshots/)-system to boost your performance
+* [Split](https://event-sourcing.patchlevel.io/latest/split_stream/) big aggregates into multiple streams
+* Versioned and managed lifecycle of [subscriptions](https://event-sourcing.patchlevel.io/latest/subscription/) like projections and processors
+* Safe usage of [Personal Data](https://event-sourcing.patchlevel.io/latest/personal_data/) with crypto-shredding
+* Smooth [upcasting](https://event-sourcing.patchlevel.io/latest/upcasting/) of old events
+* Simple setup with [scheme management](https://event-sourcing.patchlevel.io/latest/store/) and [doctrine migration](https://event-sourcing.patchlevel.io/latest/store/)
+* Built in [cli commands](https://event-sourcing.patchlevel.io/latest/cli/) with [symfony](https://symfony.com/)
 * and much more...
 
 ## Installation
 
 ```bash
-composer require patchlevel/event-sourcing-bundle
+composer require patchlevel/laravel-event-sourcing
 ```
 
-> [!WARNING]
-> If you don't use the symfony flex recipe for this bundle, you need to follow
-this [installation documentation](https://patchlevel.github.io/event-sourcing-bundle-docs/latest/installation/).
-
 ## Documentation
 
-* [Bundle Documentation](https://patchlevel.github.io/event-sourcing-bundle-docs/latest/)
-* [Library Documentation](https://patchlevel.github.io/event-sourcing-docs/latest)
+* [Bundle Documentation](https://event-sourcing-bundle.patchlevel.io/latest/)
+* [Library Documentation](https://event-sourcing.patchlevel.io/latest/)
 * [Related Blog](https://patchlevel.de/blog)
 
 ## Integration

config/event-sourcing.php

@@ -13,7 +13,6 @@
         'service' => null,
         'options' => []
     ],
-    '' => '',
     'events' => [app_path()],
     'aggregates' => [app_path()],
     'headers' => [app_path()],
@@ -26,25 +25,28 @@
             'max_attempts' => 5,
         ],
         'run_after_aggregate_save' => [
-            'enabled' => true,
             'ids' => null,
             'groups' => null,
             'limit' => null
         ],
     ],
+    'cryptography' => [
+        'enabled' => true,
+        'algorithm' => 'aes256'
+    ],
     'upcaster' => [
         // App\Upcaster\YourUpcaster::class
     ],
     'message_decorator' => [
-        // App\MessageDecorator\YourUpcaster::class
+        // App\MessageDecorator\YourMessageDecorator::class
     ],
     'listeners' => [
         // App\Listener\YourListener::class
     ],
     'subscribers' => [
-        // App\Subscribers\YourListener::class
+        // App\Subscribers\YourSubscriber::class
     ],
     'argument_resolvers' => [
-        // App\ArgumentResolvers\YourListener::class
+        // App\ArgumentResolvers\YourResolver::class
     ],
 ];

src/EventSourcingServiceProvider.php

@@ -29,6 +29,7 @@
 use Patchlevel\EventSourcing\Console\Command\SubscriptionTeardownCommand;
 use Patchlevel\EventSourcing\Console\Command\WatchCommand;
 use Patchlevel\EventSourcing\Console\DoctrineHelper;
+use Patchlevel\EventSourcing\Cryptography\DoctrineCipherKeyStore;
 use Patchlevel\EventSourcing\EventBus\AttributeListenerProvider;
 use Patchlevel\EventSourcing\EventBus\Consumer;
 use Patchlevel\EventSourcing\EventBus\DefaultConsumer;
@@ -83,9 +84,18 @@
 use Patchlevel\EventSourcing\Subscription\Subscriber\MetadataSubscriberAccessorRepository;
 use Patchlevel\EventSourcing\Subscription\Subscriber\SubscriberAccessorRepository;
 use Patchlevel\EventSourcing\Subscription\Subscriber\SubscriberHelper;
+use Patchlevel\Hydrator\Cryptography\Cipher\Cipher;
+use Patchlevel\Hydrator\Cryptography\Cipher\CipherKeyFactory;
+use Patchlevel\Hydrator\Cryptography\Cipher\OpensslCipher;
+use Patchlevel\Hydrator\Cryptography\Cipher\OpensslCipherKeyFactory;
+use Patchlevel\Hydrator\Cryptography\PayloadCryptographer;
+use Patchlevel\Hydrator\Cryptography\PersonalDataPayloadCryptographer;
+use Patchlevel\Hydrator\Cryptography\Store\CipherKeyStore;
 use Patchlevel\Hydrator\Hydrator;
 use Patchlevel\Hydrator\Metadata\AttributeMetadataFactory;
 use Patchlevel\Hydrator\MetadataHydrator;
+use Patchlevel\LaravelEventSourcing\Middleware\AutoSetupMiddleware;
+use Patchlevel\LaravelEventSourcing\Middleware\SubscriptionRebuildAfterFileChangeMiddleware;
 
 use function array_key_exists;
 use function sprintf;
@@ -105,7 +115,11 @@ public function boot(): void
     {
         $this->publishes([
             __DIR__ . '/../config/event-sourcing.php' => config_path('event-sourcing.php'),
-        ]);
+        ], 'patchlevel-config');
+
+        $this->publishesMigrations([
+            __DIR__.'/../database/migrations/' => database_path('migrations')
+        ], 'patchlevel-migrations');
 
         if (!$this->app->runningInConsole()) {
             return;
@@ -149,6 +163,7 @@ public function register(): void
         $this->registerEventBus();
         $this->registerSnapshots();
         $this->registerSubscription();
+        $this->registerCryptography();
     }
 
     private function registerConnection(): void
@@ -270,7 +285,7 @@ private function registerHydrator(): void
         $this->app->singleton(Hydrator::class, static function () {
             return new MetadataHydrator(
                 new AttributeMetadataFactory(),
-                null, //app(PayloadCryptographer::class),
+                config('event-sourcing.cryptography.enabled') ? app(PayloadCryptographer::class) : null,
             );
         });
     }
@@ -309,7 +324,7 @@ private function registerAggregates(): void
                 app(MessageDecorator::class),
                 app('event_sourcing.clock'),
                 app(AggregateRootMetadataFactory::class),
-                null, // app('logger', null),
+                app('log'),
             );
         });
     }
@@ -446,14 +461,14 @@ private function registerEventBus(): void
         $this->app->singleton(Consumer::class, static function () {
             return new DefaultConsumer(
                 app(ListenerProvider::class),
-                null, // app('logger', null),
+                app('log'),
             );
         });
 
         $this->app->singleton(EventBus::class, static function () {
             return new DefaultEventBus(
                 app(Consumer::class),
-                null, // app('logger', null),
+                app('log'),
             );
         });
     }
@@ -516,7 +531,7 @@ private function registerSubscription(): void
                 app(SubscriptionStore::class),
                 app(SubscriberAccessorRepository::class),
                 app(RetryStrategy::class),
-                null, // app('logger', null),
+                app('log'),
             );
         });
 
@@ -544,38 +559,21 @@ private function registerSubscription(): void
             });
         }
 
-        if (config('event-sourcing.subscription.auto_setup.enabled')) {
-            /*
-                      $container->register(AutoSetupListener::class)
-                ->setArguments([
-                    new Reference(SubscriptionEngine::class),
-                    $config['subscription']['auto_setup']['ids'] ?: null,
-                    $config['subscription']['auto_setup']['groups'] ?: null,
-                ])
-                ->addTag('kernel.event_listener', [
-                    'event' => 'kernel.request',
-                    'priority' => 200,
-                    'method' => 'onKernelRequest',
-                ]);
-             */
-        }
+        $this->app->singleton(AutoSetupMiddleware::class, static function () {
+            return new AutoSetupMiddleware(
+                app(SubscriptionEngine::class),
+                config('event-sourcing.subscription.auto_setup.ids'),
+                config('event-sourcing.subscription.auto_setup.groups'),
+            );
+        });
 
-        if (config('event-sourcing.subscription.rebuild_after_file_change')) {
-            /*
-                     $container->register(SubscriptionRebuildAfterFileChangeListener::class)
-            ->setArguments([
-                new Reference(SubscriptionEngine::class),
-                new TaggedIteratorArgument('event_sourcing.subscriber'),
-                new Reference('cache.app'),
-                new Reference(SubscriberMetadataFactory::class),
-            ])
-            ->addTag('kernel.event_listener', [
-                'event' => 'kernel.request',
-                'priority' => 100,
-                'method' => 'onKernelRequest',
-            ]);
-             */
-        }
+        $this->app->singleton(SubscriptionRebuildAfterFileChangeMiddleware::class, function () {
+            return new SubscriptionRebuildAfterFileChangeMiddleware(
+                app(SubscriptionEngine::class),
+                $this->app->tagged('event_sourcing.subscriber'),
+                app(SubscriberMetadataFactory::class),
+            );
+        });
 
         $this->app->singleton(SubscriptionSetupCommand::class, static function () {
             return new SubscriptionSetupCommand(
@@ -626,4 +624,33 @@ private function registerSubscription(): void
             );
         });
     }
+
+    private function registerCryptography(): void
+    {
+        if (!config('event-sourcing.cryptography.enabled')) {
+            return;
+        }
+
+        $this->app->singleton(CipherKeyFactory::class, static function () {
+            return new OpensslCipherKeyFactory(config('event-sourcing.cryptography.algorithm'));
+        });
+
+        $this->app->singleton(CipherKeyStore::class, static function () {
+            return new DoctrineCipherKeyStore(
+                app('event_sourcing.dbal_connection'),
+            );
+        });
+
+        $this->app->singleton(Cipher::class, static function () {
+            return new OpensslCipher();
+        });
+
+        $this->app->singleton(PayloadCryptographer::class, static function () {
+            return new PersonalDataPayloadCryptographer(
+                app(CipherKeyStore::class),
+                app(CipherKeyFactory::class),
+                app(Cipher::class),
+            );
+        });
+    }
 }

src/Middleware/AutoSetupMiddleware.php

@@ -0,0 +1,53 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Patchlevel\LaravelEventSourcing\Middleware;
+
+use Closure;
+use Illuminate\Http\Request;
+use Illuminate\Http\Response;
+use Patchlevel\EventSourcing\Subscription\Engine\SubscriptionEngine;
+use Patchlevel\EventSourcing\Subscription\Engine\SubscriptionEngineCriteria;
+use Patchlevel\EventSourcing\Subscription\Status;
+
+final class AutoSetupMiddleware
+{
+    /**
+     * @param list<string>|null $ids
+     * @param list<string>|null $groups
+     */
+    public function __construct(
+        private readonly SubscriptionEngine $subscriptionEngine,
+        private readonly array|null $ids,
+        private readonly array|null $groups,
+    ) {
+    }
+
+    public function handle(Request $request, Closure $next): Response
+    {
+        $subscriptions = $this->subscriptionEngine->subscriptions(
+            new SubscriptionEngineCriteria(
+                $this->ids,
+                $this->groups,
+            ),
+        );
+
+        $ids = [];
+
+        foreach ($subscriptions as $subscription) {
+            if ($subscription->status() !== Status::New) {
+                continue;
+            }
+
+            $ids[] = $subscription->id();
+        }
+
+        $this->subscriptionEngine->setup(
+            new SubscriptionEngineCriteria($ids),
+            true,
+        );
+
+        return $next($request);
+    }
+}