README

事件源 PSR-11 容器

patchlevel/event-sourcing 为 PSR-11 容器提供的工厂。

安装

composer require patchlevel/event-sourcing-psr-container

文档

配置构建器

要创建配置数组，您可以使用 ConfigBuilder。这提供了一些调整配置的方法。

$eventSourcingConfig = (new ConfigBuilder())
    ->singleTable()
    ->databaseUrl('mysql://user:secret@localhost/app')
    ->addAggregatePath(__DIR__ . '/Aggregate')
    ->addEventPath(__DIR__ . '/Events')
    ->addProcessor(SendEmailProcessor::class)
    ->addProjector(ProfileProjection::class)
    ->build();

默认内置容器

自己的 PSR 容器实现已经集成了所有必要的工厂。因此，我们只需要传递配置。

use Patchlevel\EventSourcing\Container\ConfigBuilder;
use Patchlevel\EventSourcing\Container\DefaultContainer;

$container = new DefaultContainer(
    $eventSourcingConfig,
    [
        HotelProjection::class => fn(DefaultContainer $container) 
            => new HotelProjection($container->connection()),
        SendEmailProcessor::class => fn(DefaultContainer $container) 
            => new SendEmailProcessor($container->get('mailer')),
    ]
);

$container->get(SchemaDirector::class)->create();

$hotelRepository = $container->repository(Hotel::class);

Laminas 服务管理器

工厂也可以与其他 PSR-11 兼容的库一起使用。以下是一个使用 Laminas 的示例。

composer require laminas/laminas-servicemanager

我们只需要指定工厂并传递配置。

use Laminas\ServiceManager\ServiceManager;
use Patchlevel\EventSourcing\Repository\RepositoryManager;
use Patchlevel\EventSourcing\Schema\SchemaDirector;
use Patchlevel\EventSourcingPsrContainer\ConfigBuilder;
use Patchlevel\EventSourcingPsrContainer\Factory\ConnectionFactory;
use Patchlevel\EventSourcingPsrContainer\Factory\RepositoryManagerFactory;
use Patchlevel\EventSourcingPsrContainer\Factory\SchemaDirectorFactory;

$serviceManager = new ServiceManager([
    'services' => [
        'config' => [
            'event_sourcing' => $eventSourcingConfig
        ],
        SendEmailProcessor::class => new SendEmailProcessor()
    ],
    'factories' => [
        'event_sourcing.connection' => new ConnectionFactory(),
        RepositoryManager::class => new RepositoryManagerFactory(),
        SchemaDirector::class => new SchemaDirectorFactory(),
        HotelProjection::class => static fn (ServiceManager $container) => new HotelProjection($container->get('event_sourcing.connection')),
    ],
]);

$serviceManager->get(SchemaDirector::class)->create();

$repositoryManager = $serviceManager->get(RepositoryManager::class);
$hotelRepository = $repositoryManager->get(Hotel::class);