Glooby\TaskBundle\Annotation\Schedule

Complexity

Total Complexity

16

Size/Duplication

Total Lines	142
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	1
A	validateTimeout()	0	6	3
A	validateParams()	0	6	2
A	validateExpression()	0	4	1
A	populate()	0	10	3
A	mapExpression()	0	8	2
A	setDefault()	0	9	2
A	ensureExpressionExist()	0	7	2

<?php

namespace Glooby\TaskBundle\Annotation;

use Cron\CronExpression;

/**
 * @author Emil Kilhage
 * @Annotation
 */
class Schedule
{
    /**
     * @var array
     */
    private static $map = [
        '@yearly' => '0 0 1 1 *',
        '@annually' => '0 0 1 1 *',
        '@monthly' => '0 0 1 * *',
        '@weekly' => '0 0 * * 0',
        '@daily' => '0 0 * * *',
        '@hourly' => '0 * * * *',
        '@semi_hourly' => '*/30 * * * *',
        '@quarter_hourly' => '*/15 * * * *',
        '*' => '* * * * *',
    ];

    /**
     * @var string
     */
    public $runEvery;

    /**
     * @var bool
     */
    public $active = true;

    /**
     * @var null|int
     */
    public $timeout = 0;

    /**
     * @var int
     */
    public $version = 10;

    /**
     * @var array
     */
    public $params = [];

    /**
     * @param array $options
     * @throws \InvalidArgumentException
     */
    public function __construct(array $options)
    {
        $options = $this->setDefault($options);
        $options = $this->ensureExpressionExist($options);
        $options = $this->mapExpression($options);

        $this->populate($options);

        $this->validateExpression();
        $this->validateTimeout();
        $this->validateParams();
    }

    /**
     * @throws \InvalidArgumentException
     */
    public function validateTimeout()
    {
        if (isset($this->timeout) && !is_numeric($this->timeout)) {
            throw new \InvalidArgumentException('Property "timeout" must be an int');
        }
    }

    /**
     * @throws \InvalidArgumentException
     */
    public function validateParams():void
    {
        if (!is_array($this->params)) {
            throw new \InvalidArgumentException('Property "params" must be an array');
        }
    }

    /**
     * @throws \InvalidArgumentException
     */
    public function validateExpression()
    {
        CronExpression::factory($this->runEvery);
    }

    /**
     * @param array $options
     * @throws \InvalidArgumentException
     */
    public function populate(array $options)
    {
        foreach ($options as $key => $value) {
            if (!property_exists($this, $key)) {
                throw new \InvalidArgumentException(sprintf('Property "%s" does not exist', $key));
            }

            $this->$key = $value;
        }
    }

    /**
     * @param array $options
     * @return array
     */
    public function mapExpression(array $options)
    {
        if (isset(self::$map[$options['runEvery']])) {
            $options['runEvery'] = self::$map[$options['runEvery']];
        }

        return $options;
    }

    /**
     * @param array $options
     * @return array
     */
    public function setDefault(array $options)
    {
        if (isset($options['value'])) {
            $options['runEvery'] = $options['value'];
            unset($options['value']);
        }

        return $options;
    }

    /**
     * @param array $options
     * @throws \InvalidArgumentException
     * @return array
     */
    public function ensureExpressionExist(array $options)
    {
        if (empty($options['runEvery'])) {
            throw new \InvalidArgumentException('Missing property runEvery');
        }
        return $options;
    }
}