OpenConext / Stepup-Middleware

use Symfony\Component\DependencyInjection\ContainerBuilder;

use Symfony\Component\DependencyInjection\Reference;

class AddCommandBusCommandHandlersCompilerPass implements CompilerPassInterface

{

    public function process(ContainerBuilder $container)

    {

        $definition = $container->getDefinition('surfnet_stepup_middleware_command_handling.command_bus');

        $commandHandlerDefinitions = $container->findTaggedServiceIds('command_bus.command_handler');

        foreach (array_keys($commandHandlerDefinitions) as $id) {

            $definition->addMethodCall('subscribe', [new Reference($id)]);

        }

    }

}

use Symfony\Component\DependencyInjection\ContainerBuilder;

use Symfony\Component\DependencyInjection\Reference;

class CollectProjectorsForEventReplayCompilerPass implements CompilerPassInterface

{

    public function process(ContainerBuilder $container)

    {

        $projectorCollectionDefinition = $container->getDefinition('middleware.event_replay.projector_collection');

        $projectorDefinitions = $container->findTaggedServiceIds('projector.register_for_replay');

        foreach (array_keys($projectorDefinitions) as $serviceId) {

            $projectorCollectionDefinition->addMethodCall('add', [new Reference($serviceId)]);

        }

    }

}