TonicHealthCheck\Incident\Siren\IncidentSiren

Complexity

Total Complexity

15

Size/Duplication

Total Lines	111
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	3
Bugs	2	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	2
A	update()	0	8	2
A	notify()	0	12	4
A	getNotificationTypeI()	0	4	1
A	getSubjects()	0	4	1
A	setSubjects()	0	4	1
A	setNotificationTypeI()	0	4	1
A	notifySubject()	0	6	3

<?php

namespace TonicHealthCheck\Incident\Siren;

use SplSubject;
use TonicHealthCheck\Incident\IncidentInterface;
use TonicHealthCheck\Incident\Siren\NotificationType\NotificationTypeInterface;
use TonicHealthCheck\Incident\Siren\Subject\SubjectCollection;
use TonicHealthCheck\Incident\Siren\Subject\SubjectInterface;

/**
 * Class IncidentSiren
 * @package TonicHealthCheck\Incident\Siren
 */
class IncidentSiren implements \SplObserver
{
    const FILE_NAME_ALARM_TRIGGER = 'alarm_triger.data';

    /**
     * @var NotificationTypeInterface
     */
    protected $notificationTypeI;

    /**
     * email or tel numbers
     *
     * @var SubjectCollection
     */
    protected $subjects;


    /**
     * IncidentSiren constructor.
     * @param NotificationTypeInterface $notificationTypeI
     * @param null|SubjectCollection    $subjects
     * @throws IncidentSirenException
     */
    public function __construct(NotificationTypeInterface $notificationTypeI, SubjectCollection $subjects = null)
    {
        $this->setNotificationTypeI($notificationTypeI);
        if (null === $subjects) {
            $subjects = new SubjectCollection();
        }
        $this->setSubjects($subjects);
    }

    /**
     * Receive update from subject
     * @link http://php.net/manual/en/splobserver.update.php
     * @param SplSubject $subject <p>
     * The <b>SplSubject</b> notifying the observer of an update.
     * </p>
     * @return void
     * @since 5.1.0
     */
    public function update(SplSubject $subject)
    {

        if ($subject instanceof IncidentInterface) {
            /** @var IncidentInterface $subject */
                $this->notify($subject);
        }
    }

    /**
     * @param IncidentInterface $incident
     * @param null|array        $subjects
     */
    public function notify(IncidentInterface $incident, $subjects = null)
    {
        $subjects = null === $subjects? $this->getSubjects(): $subjects;
        /** @var SubjectInterface $subject */
        foreach ($subjects as $subject) {
            try {
                $this->notifySubject($incident, $subject);
            } catch (\Exception $e) {
                user_error($e->getMessage(), E_USER_WARNING);
            }
        }
    }

    /**
     * @return NotificationTypeInterface
     */
    public function getNotificationTypeI()
    {
        return $this->notificationTypeI;
    }

    /**
     * @return SubjectCollection
     */
    public function getSubjects()
    {
        return $this->subjects;
    }

    /**
     * @param SubjectCollection $subjects
     */
    protected function setSubjects(SubjectCollection $subjects)
    {
        $this->subjects = $subjects;
    }

    /**
     * @param NotificationTypeInterface $notificationTypeI
     */
    protected function setNotificationTypeI(NotificationTypeInterface $notificationTypeI)
    {
        $this->notificationTypeI = $notificationTypeI;
    }

    /**
     * @param IncidentInterface $incident
     * @param $subject
     */
    protected function notifySubject(IncidentInterface $incident, $subject)
    {
        if (null === $subject->getSchedule() || $subject->getSchedule()->isDue()) {
            $this->getNotificationTypeI()->notify($subject, $incident);
        }
    }

}