PSB\Persistence\Doctrine2\Outbox\Doctrine2OutboxPersistenceFeature

Complexity

Total Complexity

2

Size/Duplication

Total Lines	86
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	13

Test Coverage

Coverage

56%

Importance

Changes

0

2 Methods

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

<?php
namespace PSB\Persistence\Doctrine2\Outbox;


use Doctrine\DBAL\Connection;
use Doctrine\DBAL\Schema\Synchronizer\SingleDatabaseSynchronizer;
use PSB\Core\Feature\Feature;
use PSB\Core\KnownSettingsEnum;
use PSB\Core\ObjectBuilder\BuilderInterface;
use PSB\Core\Outbox\OutboxFeature;
use PSB\Core\Outbox\OutboxStorageInterface;
use PSB\Core\Pipeline\PipelineModifications;
use PSB\Core\Util\Settings;
use PSB\Persistence\Doctrine2\DbalConnectionFactory;
use PSB\Persistence\Doctrine2\Doctrine2KnownSettingsEnum;
use PSB\Persistence\Doctrine2\Outbox\SchemaProvider\OutboxEndpointSchemaProvider;
use PSB\Persistence\Doctrine2\Outbox\SchemaProvider\OutboxMessageSchemaProvider;

class Doctrine2OutboxPersistenceFeature extends Feature
{

    /**
     * Method will always be executed and should be used to determine whether to enable or disable the feature,
     * configure default settings, configure dependencies, configure prerequisites and register startup tasks.
     */
    public function describe()
    {
        $this->dependsOn(OutboxFeature::class);
        $this->registerDefault(
            function (Settings $settings) {
                $settings->setDefault(Doctrine2KnownSettingsEnum::OUTBOX_MESSAGES_TABLE_NAME, 'psb_outbox_messages');
                $settings->setDefault(Doctrine2KnownSettingsEnum::OUTBOX_ENDPOINTS_TABLE_NAME, 'psb_outbox_endpoints');
            }
        );
    }

    /**
     * Method is called if all defined conditions are met and the feature is marked as enabled.
     * Use this method to configure and initialize all required components for the feature like
     * the steps in the pipeline or the instances/factories in the container.
     *
     * @param Settings              $settings
     * @param BuilderInterface      $builder
     * @param PipelineModifications $pipelineModifications
     */
    public function setup(Settings $settings, BuilderInterface $builder, PipelineModifications $pipelineModifications)
    {
        $builder->defineSingleton(Connection::class, new DbalConnectionFactory($settings));

        $builder->defineSingleton(
            OutboxPersister::class,
            function () use ($builder, $settings) {
                return new OutboxPersister(
                    $builder->build(Connection::class),
                    $settings->get(Doctrine2KnownSettingsEnum::OUTBOX_MESSAGES_TABLE_NAME),
                    $settings->get(Doctrine2KnownSettingsEnum::OUTBOX_ENDPOINTS_TABLE_NAME)
                );
            }
        );

        $builder->defineSingleton(
            OutboxStorageInterface::class,
            function () use ($builder, $settings) {
                return new Doctrine2OutboxStorage(
                    $builder->build(OutboxPersister::class),
                    new OutboxMessageConverter(),
                    $settings->get(Doctrine2KnownSettingsEnum::OUTBOX_ENDPOINT_ID)
                );
            }
        );

        $this->registerStartupTask(
            function () use ($builder, $settings) {
                return new EndpointIdLoaderFeatureStartupTask(
                    $builder->build(OutboxPersister::class),
                    $settings,
                    $settings->get(KnownSettingsEnum::ENDPOINT_NAME)
                );
            }
        );

        $this->registerStartupTask(
            function () use ($builder, $settings) {
                return new OutboxCleanerFeatureStartupTask(
                    $builder->build(OutboxPersister::class),
                    new \DateTime('now', new \DateTimeZone('UTC')),
                    $settings->tryGet(KnownSettingsEnum::DAYS_TO_KEEP_DEDUPLICATION_DATA)
                );
            }
        );

        $this->registerInstallTask(
            function () use ($builder, $settings) {
                return new OutboxTablesCreatorFeatureInstallTask(
                    new SingleDatabaseSynchronizer($builder->build(Connection::class)),
                    new OutboxEndpointSchemaProvider(),
                    new OutboxMessageSchemaProvider(),
                    $settings->get(Doctrine2KnownSettingsEnum::OUTBOX_ENDPOINTS_TABLE_NAME),
                    $settings->get(Doctrine2KnownSettingsEnum::OUTBOX_MESSAGES_TABLE_NAME)
                );
            }
        );
    }
}