TonicHealthCheck\Incident\IncidentEventSubscriber

Complexity

Total Complexity

17

Size/Duplication

Total Lines	119
Duplicated Lines	15.13 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	4
Bugs	2	Features	1

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getSubscribedEvents()	0	7	1
A	preUpdate()	10	10	3
A	prePersist()	8	8	3
A	getIncidentSirenCollection()	0	4	1
A	setIncidentSirenCollection()	0	4	1
A	preUpdateIncidentStatus()	0	11	4
A	checkIsNotificationAllow()	0	13	3

<?php

namespace TonicHealthCheck\Incident;

use Doctrine\Common\EventSubscriber;
use Doctrine\Common\Persistence\Event\LifecycleEventArgs;
use Doctrine\ORM\Event\PreFlushEventArgs;
use Doctrine\ORM\Event\PreUpdateEventArgs;
use Doctrine\ORM\Events;

use TonicHealthCheck\Incident\Siren\IncidentSiren;
use TonicHealthCheck\Incident\Siren\IncidentSirenCollection;
use TonicHealthCheck\Incident\Siren\NotificationType\EmailNotificationType;
use TonicHealthCheck\Incident\Siren\NotificationType\FileNotificationType;
use TonicHealthCheck\Incident\Siren\NotificationType\RequestNotificationType;

/**
 * Class IncidentEventSubscriber
 * @package TonicHealthCheck\Incident
 */
class IncidentEventSubscriber implements EventSubscriber
{
    protected static $typeEventPolitic =[
        IncidentInterface::TYPE_URGENT => [
            EmailNotificationType::class,
            FileNotificationType::class,
            RequestNotificationType::class,
        ],
        IncidentInterface::TYPE_WARNING => [
            EmailNotificationType::class,
            RequestNotificationType::class,
        ],
        IncidentInterface::TYPE_MINOR => [
            EmailNotificationType::class,
            RequestNotificationType::class,
        ],
    ];

    /**
     * @var IncidentSirenCollection
     */
    private $incidentSirenCollection;

    /**
     * IncidentHandler constructor.
     * @param IncidentSirenCollection $incidentSirenC
     */
    public function __construct($incidentSirenC)
    {
        $this->setIncidentSirenCollection($incidentSirenC);
    }

    /**
     * @return array
     */
    public function getSubscribedEvents()
    {
        return array(
            Events::preUpdate,
            Events::prePersist,
        );
    }

    /**
     * @param PreUpdateEventArgs $args
     */
    public function preUpdate(PreUpdateEventArgs $args)

This method seems to be duplicated in your project.

    {

        $entity = $args->getObject();

        if ($entity instanceof IncidentInterface && $args->hasChangedField('status')) {
            $this->preUpdateIncidentStatus($entity);
            $entity->notify();
        }
    }

    /**
     * @param LifecycleEventArgs $args
     */
    public function prePersist(LifecycleEventArgs $args)

This method seems to be duplicated in your project.

    {
        $entity = $args->getObject();
        if ($entity instanceof IncidentInterface && $entity->getId() === null) {
            $this->preUpdateIncidentStatus($entity);
            $entity->notify();
        }
    }

    /**
     * @return IncidentSirenCollection
     */
    public function getIncidentSirenCollection()
    {
        return $this->incidentSirenCollection;
    }

    /**
     * @param IncidentSirenCollection $incidentSiren
     */
    protected function setIncidentSirenCollection(IncidentSirenCollection $incidentSiren)
    {
        $this->incidentSirenCollection = $incidentSiren;
    }

    /**
     * @param IncidentInterface $entity
     */
    protected function preUpdateIncidentStatus(IncidentInterface $entity)
    {
        /** @var IncidentSiren $incidentI */
        foreach ($this->getIncidentSirenCollection() as $incidentI) {
            if (isset(static::$typeEventPolitic[$entity->getType()])
                && $this->checkIsNotificationAllow($entity->getType(), $incidentI->getNotificationTypeI())
            ) {
                $entity->attach($incidentI);
            }
        }
    }

    /**
     * @param $type
     * @param $notificationTypeI
     * @return bool
     */
    protected function checkIsNotificationAllow($type, $notificationTypeI)
    {
        $isNotificationAllow = false;

        foreach (static::$typeEventPolitic[$type] as $notificationType) {
            if (is_a($notificationTypeI, $notificationType)) {
                $isNotificationAllow = true;
                break;
            }
        }

        return $isNotificationAllow;
    }
}