SlayerBirden\DataFlowServer\Db\Doctrine\Subscriber\Validation

Complexity

Total Complexity

13

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Test Coverage

Coverage

83.33%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getSubscribedEvents()	0	7	1
A	preUpdate()	0	7	2
A	prePersist()	0	7	2
B	validate()	0	27	8

<?php
declare(strict_types=1);

namespace SlayerBirden\DataFlowServer\Db\Doctrine\Subscriber;

use Doctrine\Common\EventSubscriber;
use Doctrine\ORM\Event\LifecycleEventArgs;
use Doctrine\ORM\Event\PreUpdateEventArgs;
use Doctrine\ORM\Events;
use SlayerBirden\DataFlowServer\Db\Entities\DbConfiguration;
use SlayerBirden\DataFlowServer\Validation\Exception\ValidationException;

final class Validation implements EventSubscriber
{
    /**
     * @inheritDoc
     */
    public function getSubscribedEvents(): array
    {
        return [
            Events::preUpdate,
            Events::prePersist,
        ];
    }

    /**
     * @param PreUpdateEventArgs $args
     * @throws ValidationException
     */
    public function preUpdate(PreUpdateEventArgs $args): void
    {
        $entity = $args->getObject();
        if ($entity instanceof DbConfiguration) {
            $this->validate($entity);
        }
    }

    /**
     * @param LifecycleEventArgs $args
     * @throws ValidationException
     */
    public function prePersist(LifecycleEventArgs $args): void
    {
        $entity = $args->getObject();
        if ($entity instanceof DbConfiguration) {
            $this->validate($entity);
        }
    }

    /**
     * @param DbConfiguration $configuration
     * @throws ValidationException
     */
    private function validate(DbConfiguration $configuration): void
    {
        $msg = '%s is required field if "url" is not set.';
        if (!empty($configuration->getUrl())) {
            return;
        }

        if (empty($configuration->getDbname())) {
            throw new ValidationException(sprintf($msg, 'dbname'));
        }
        if (empty($configuration->getDriver())) {
            throw new ValidationException(sprintf($msg, 'driver'));
        }
        if (empty($configuration->getHost())) {
            throw new ValidationException(sprintf($msg, 'host'));
        }
        if (empty($configuration->getUser())) {
            throw new ValidationException(sprintf($msg, 'user'));
        }
        if (empty($configuration->getPort())) {
            throw new ValidationException(sprintf($msg, 'port'));
        }

        if (empty($configuration->getTitle())) {
            throw new ValidationException('Title is empty.');
        }
    }
}