webdevilopers
commented
3 years ago Thank you to @prolic for confirming that the event-store should work as expected:
<?php
/**
* This file is part of prooph/event-store.
* (c) 2014-2021 prooph software GmbH <contact@prooph.de>
* (c) 2015-2021 Sascha-Oliver Prolic <saschaprolic@googlemail.com>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
declare(strict_types=1);
namespace Prooph\EventStore\Plugin;
use Prooph\Common\Event\ActionEvent;
use Prooph\EventStore\ActionEventEmitterEventStore;
use Prooph\EventStore\StreamIterator\StreamIterator;
use Prooph\EventStore\Upcasting\Upcaster;
use Prooph\EventStore\Upcasting\UpcastingIterator;
final class UpcastingPlugin extends AbstractPlugin
{
public const ACTION_EVENT_PRIORITY = -1000;
/**
* @var Upcaster
*/
private $upcaster;
public function __construct(Upcaster $upcaster)
{
$this->upcaster = $upcaster;
}
public function attachToEventStore(ActionEventEmitterEventStore $eventStore): void
{
$upcaster = function (ActionEvent $actionEvent): void {
$streamEvents = $actionEvent->getParam('streamEvents');
if (! $streamEvents instanceof StreamIterator) {
return;
}
$actionEvent->setParam('streamEvents', new UpcastingIterator($this->upcaster, $streamEvents));
};
$eventStore->attach(
ActionEventEmitterEventStore::EVENT_LOAD,
$upcaster,
self::ACTION_EVENT_PRIORITY
);
$eventStore->attach(
ActionEventEmitterEventStore::EVENT_LOAD_REVERSE,
$upcaster,
self::ACTION_EVENT_PRIORITY
);
}
}
I will start debugging the symfony bridge.
lunetics
codeliner
unixslayer
prolic
Came from:
Though this could be a general (PDO) Event Store issue I post it here first to get sure it is not a Symfony wiring problem.
We successfully register projections and an Upcaster as plugin:
Upcasting works as expected when saving or getting aggregates from the
AggregateRepository. The used Event Store is an instance ofProoph\EventStore\TransactionalActionEventEmitterEventStorethat holds a property namedactionEventEmitter:But when running projections the plugin is not used. The Event Store is an instance of
Prooph\EventStore\Pdo\PostgresEventStorewithout theactionEventEmitterinstead:There is a
handlersproperty but it is empty.Should the used Event Store instances not be the same?
Refs: