event-engine / prooph-v7-event-store
Event Engine Prooph V7 Event Store Integration
Installs: 76 962
Dependents: 5
Suggesters: 0
Security: 0
Stars: 7
Watchers: 3
Forks: 2
Open Issues: 0
Requires
- php: ^7.2 || ^8.0
- event-engine/php-engine-utils: ^0.2.1 || ^1.0
- event-engine/php-messaging: ^0.2.1
- event-engine/php-persistence: ^0.9.1
- prooph/event-store: ^7.0
Requires (Dev)
- malukenho/docheader: ^0.1.4
- php-coveralls/php-coveralls: ^2.0
- phpunit/phpunit: ^8.0 || ^9.0
- prooph/php-cs-fixer-config: ^0.4
- roave/security-advisories: dev-latest
This package is auto-updated.
Last update: 2024-10-30 01:59:19 UTC
README
Event Engine Prooph V7 Event Store Bindings
Installation
composer require event-engine/prooph-v7-event-store
Prooph Binding
tbd
InMemoryEventStore
tbd
FilesystemEventStore
A prooph v7 compatible FilesystemEventStore
is included, too. It is meant to be used for demonstration purpose only (for example in a workshop).
//Basic set up that's able to handle Prooph\Common\Messaging\DomainEvent $filesystemEventStore = new \EventEngine\Prooph\V7\EventStore\FilesystemEventStore( 'data/prooph.event_store.json', \JSON_PRETTY_PRINT // optional MessageFactory -> defaults to FQCNMessageFactory // optional MessageConverter -> defaults to NoOpMessageConverter ); //Create an empty stream $filesystemEventStore->create( new \Prooph\EventStore\Stream( new \Prooph\EventStore\StreamName('event_stream'), new ArrayIterator() ) ); //Can also be used together with an InMemoryProjectionManager $projectionManager = new \EventEngine\Prooph\V7\EventStore\Projecting\InMemory\InMemoryProjectionManager( $filesystemEventStore, new \EventEngine\Persistence\InMemoryConnection() ); $query = $projectionManager->createQuery(); $query->fromStream('event_stream') ->whenAny(function (array $state, \Prooph\Common\Messaging\DomainEvent $event) { echo "{$event->messageName()} stored in event_stream\n"; }); $query->run();
Please Note: The combination of FilesystemEventStore and InMemoryProjectionManager has the drawback that projections only see events that are in the event store at the time of running the projection. If other PHP processes add events to the store, those are first visible for the projection after restarting the PHP process and running the projection again. We might add a FilesystemProjectionManager in the future, if needed.