Innmind\ProvisionerBundle\EventListener\ProvisionAlertListener

Complexity

Total Complexity

15

Size/Duplication

Total Lines	114
Duplicated Lines	10.53 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes	4
Bugs	1	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	addAlerter()	0	4	1
A	setCpuThresholds()	0	4	1
A	setLoadAverageThresholds()	0	4	1
A	setServer()	0	4	1
A	setProcessStatusHandler()	0	4	1
C	handle()	12	48	10

<?php

namespace Innmind\ProvisionerBundle\EventListener;

use Innmind\ProvisionerBundle\Event\ProvisionAlertEvent;
use Innmind\ProvisionerBundle\Alert\AlerterInterface;
use Innmind\ProvisionerBundle\Alert\Alert;
use Innmind\ProvisionerBundle\Server\ServerInterface;
use Innmind\ProvisionerBundle\ProcessStatusHandler;

/**
 * Alerts when new servers need to be run or the current server
 * is no longer needed
 */
class ProvisionAlertListener
{
    protected $alerters = [];
    protected $cpuThreshold;
    protected $loadAverageThreshold;
    protected $server;
    protected $processStatus;

    /**
     * Add a new alerter
     *
     * @param AlerterInterface $alerter
     */
    public function addAlerter(AlerterInterface $alerter)
    {
        $this->alerters[] = $alerter;
    }

    /**
     * Set the CPU thresholds
     *
     * @param int $min
     * @param int $max
     */
    public function setCpuThresholds($min, $max)
    {
        $this->cpuThreshold = [(int) $min, (int) $max];
    }

    /**
     * Set the load average thresholds
     *
     * @param float $min
     * @param float $max
     */
    public function setLoadAverageThresholds($min, $max)
    {
        $this->loadAverageThreshold = [(float) $min, (float) $max];
    }

    /**
     * Set the server helper
     *
     * @param ServerInterface $server
     */
    public function setServer(ServerInterface $server)
    {
        $this->server = $server;
    }

    /**
     * Set the process status handler
     *
     * @param ProcessStatusHandler $handler
     */
    public function setProcessStatusHandler(ProcessStatusHandler $handler)
    {
        $this->processStatus = $handler;
    }

    /**
     * Check if an alert needs to be fired
     *
     * @param ProvisionAlertEvent $event
     */
    public function handle(ProvisionAlertEvent $event)
    {
        $leftOver = $event->getLeftOver();
        $cpuUsage = $this->server->getCpuUsage();
        $loadAverage = $this->server->getCurrentLoadAverage();

        $alert = new Alert();
        $alert
            ->setCommandName(
                $event->getCommandName()
            )
            ->setCommandInput(
                $event->getCommandInput()
            )
            ->setCpuUsage($cpuUsage)
            ->setLoadAverage($loadAverage)
            ->setRunningProcesses(
                $this->processStatus->getProcessCount(sprintf(
                    'console %s',
                    (string) $event->getCommandInput()
                ))
            )
            ->setLeftOver($leftOver);

        if ($leftOver === 0) {
            if (

This code seems to be duplicated across your project.

                $cpuUsage <= $this->cpuThreshold[0] ||
                $loadAverage <= $this->loadAverageThreshold[0]
            ) {
                $alert->setUnderUsed();
            }
        } else if ($leftOver > 0) {
            if (

This code seems to be duplicated across your project.

                $cpuUsage >= $this->cpuThreshold[1] ||
                $loadAverage >= $this->loadAverageThreshold[1]
            ) {
                $alert->setOverUsed();
            }
        }

        if (!$alert->isUnderUsed() && !$alert->isOverUsed()) {
            return;
        }

        foreach ($this->alerters as $alerter) {
            $alerter->alert($alert);
        }
    }
}