AsyncPHP\Doorman\Rules\InMemoryRules

Complexity

Total Complexity

37

Size/Duplication

Total Lines	205
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	addRule()	0	8	1
A	removeRule()	0	10	2
B	canRunTask()	0	20	8
A	getRulesForTask()	0	6	2
A	hasTooManyProcessesRunning()	0	4	2
A	withinConstraints()	0	4	2
A	withinProcessorConstraints()	0	8	4
A	withinMemoryConstraints()	0	8	4
A	hasTooManySiblingProcessesRunning()	0	4	2
A	withinSiblingConstraints()	0	4	2
A	withinSiblingProcessorConstraints()	0	8	4
A	withinSiblingMemoryConstraints()	0	8	4

<?php

namespace AsyncPHP\Doorman\Rules;

use AsyncPHP\Doorman\Profile;
use AsyncPHP\Doorman\Rule;
use AsyncPHP\Doorman\Rules;
use AsyncPHP\Doorman\Task;

final class InMemoryRules implements Rules
{
    /**
     * @var Rule[]
     */
    private $rules = [];

    /**
     * @inheritdoc
     *
     * @param Rule $rule
     *
     * @return $this
     */
    public function addRule(Rule $rule)
    {
        $hash = spl_object_hash($rule);

        $this->rules[$hash] = $rule;

        return $this;
    }

    /**
     * @inheritdoc
     *
     * @param Rule $rule
     *
     * @return $this
     */
    public function removeRule(Rule $rule)
    {
        $hash = spl_object_hash($rule);

        if (isset($this->rules[$hash])) {
            unset($this->rules[$hash]);
        }

        return $this;
    }

    /**
     * @inheritdoc
     *
     * @param Task $task
     * @param Profile $profile
     *
     * @return bool
     */
    public function canRunTask(Task $task, Profile $profile)
    {
        $rules = $this->getRulesForTask($task);

        if (count($rules) === 0) {
            return true;
        }

        foreach ($rules as $rule) {
            if ($rule->getProcesses() === null) {
                continue;
            }

            if (($rule->getHandler() === null || $rule->getHandler() === $task->getHandler()) && ($this->hasTooManyProcessesRunning($rule, $profile) || $this->hasTooManySiblingProcessesRunning($rule, $profile))) {
                return false;
            }
        }

        return true;
    }

    /**
     * Gets all the rules that apply to a task.
     *
     * @param Task $task
     *
     * @return Rule[]
     */
    private function getRulesForTask(Task $task)
    {
        return array_filter($this->rules, function (Rule $rule) use ($task) {
            return $rule->getHandler() === null || $rule->getHandler() === $task->getHandler();
        });
    }

    /**
     * Checks whether there are too many processes running to start a new one.
     *
     * @param Rule $rule
     * @param Profile $profile
     *
     * @return bool
     */
    private function hasTooManyProcessesRunning(Rule $rule, Profile $profile)
    {
        return $this->withinConstraints($rule, $profile) && count($profile->getProcesses()) >= $rule->getProcesses();
    }

    /**
     * Checks whether the current profile is within the constraints of a rule.
     *
     * @param Rule $rule
     * @param Profile $profile
     *
     * @return bool
     */
    private function withinConstraints(Rule $rule, Profile $profile)
    {
        return $this->withinProcessorConstraints($rule, $profile) || $this->withinMemoryConstraints($rule, $profile);
    }

    /**
     * Checks whether the current profile is within the processor constraints of a rule.
     *
     * @param Rule $rule
     * @param Profile $profile
     *
     * @return bool
     */
    private function withinProcessorConstraints(Rule $rule, Profile $profile)
    {
        if ($rule->getMinimumProcessorUsage() !== null && $rule->getMaximumProcessorUsage() !== null) {
            return $profile->getProcessorLoad() >= $rule->getMinimumProcessorUsage() && $profile->getProcessorLoad() <= $rule->getMaximumProcessorUsage();
        }

        return false;
    }

    /**
     * Checks whether the current profile is within the memory constraints of a rule.
     *
     * @param Rule $rule
     * @param Profile $profile
     *
     * @return bool
     */
    private function withinMemoryConstraints(Rule $rule, Profile $profile)
    {
        if ($rule->getMinimumMemoryUsage() !== null && $rule->getMaximumMemoryUsage() !== null) {
            return $profile->getMemoryLoad() >= $rule->getMinimumMemoryUsage() && $profile->getMemoryLoad() <= $rule->getMaximumMemoryUsage();
        }

        return false;
    }

    /**
     * Checks whether there are too many sibling processes running to start a new one.
     *
     * @param Rule $rule
     * @param Profile $profile
     *
     * @return bool
     */
    private function hasTooManySiblingProcessesRunning(Rule $rule, Profile $profile)
    {
        return $this->withinSiblingConstraints($rule, $profile) && count($profile->getSiblingProcesses()) >= $rule->getProcesses();
    }

    /**
     * Checks whether the profile or sibling processes is within the constraints of a rule.
     *
     * @param Rule $rule
     * @param Profile $profile
     *
     * @return bool
     */
    private function withinSiblingConstraints(Rule $rule, Profile $profile)
    {
        return $this->withinSiblingProcessorConstraints($rule, $profile) || $this->withinSiblingMemoryConstraints($rule, $profile);
    }

    /**
     * Checks whether the profile or sibling processes is within the processor constraints of a
     * rule.
     *
     * @param Rule $rule
     * @param Profile $profile
     *
     * @return bool
     */
    private function withinSiblingProcessorConstraints(Rule $rule, Profile $profile)
    {
        if ($rule->getMinimumSiblingProcessorUsage() !== null && $rule->getMaximumSiblingProcessorUsage() !== null) {
            return $profile->getSiblingProcessorLoad() >= $rule->getMinimumSiblingProcessorUsage() && $profile->getSiblingProcessorLoad() <= $rule->getMaximumSiblingProcessorUsage();
        }

        return false;
    }

    /**
     * Checks whether the profile or sibling processes is within the memory constraints of a rule.
     *
     * @param Rule $rule
     * @param Profile $profile
     *
     * @return bool
     */
    private function withinSiblingMemoryConstraints(Rule $rule, Profile $profile)
    {
        if ($rule->getMinimumSiblingMemoryUsage() !== null && $rule->getMaximumSiblingMemoryUsage() !== null) {
            return $profile->getSiblingMemoryLoad() >= $rule->getMinimumSiblingMemoryUsage() && $profile->getSiblingMemoryLoad() <= $rule->getMaximumSiblingMemoryUsage();
        }

        return false;
    }
}