PSB\Core\Routing\AutoSubscription\AutoSubscribeFeature

Complexity

Total Complexity

2

Size/Duplication

Total Lines	30
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	5

Test Coverage

Coverage

46.15%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	describe()	0	10	1
A	setup()	0	10	1

<?php
namespace PSB\Core\Routing\AutoSubscription;


use PSB\Core\Feature\Feature;
use PSB\Core\KnownSettingsEnum;
use PSB\Core\MessageHandlerRegistry;
use PSB\Core\ObjectBuilder\BuilderInterface;
use PSB\Core\Pipeline\PipelineModifications;
use PSB\Core\Util\Settings;

class AutoSubscribeFeature extends Feature
{

    public function describe()
    {
        $this->enableByDefault();
        $this->registerPrerequisite(
            function (Settings $settings) {
                return !$settings->tryGet(KnownSettingsEnum::SEND_ONLY);
            },
            "Send only endpoints can't autosubscribe."
        );
    }

    /**
     * @param Settings              $settings
     * @param BuilderInterface      $builder
     * @param PipelineModifications $pipelineModifications
     */
    public function setup(Settings $settings, BuilderInterface $builder, PipelineModifications $pipelineModifications)
    {
        $this->registerStartupTask(
            function (BuilderInterface $builder) {
                /** @var MessageHandlerRegistry $handlerRegistry */
                $handlerRegistry = $builder->build(MessageHandlerRegistry::class);
                return new SubscriptionApplierStartupTask($handlerRegistry->getEventFqcns());
            }
        );
    }
}