Workana\AsyncJobs\Configuration

Complexity

Total Complexity

10

Size/Duplication

Total Lines	101
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	17	2
A	getRouterClass()	0	4	1
A	getDriverClass()	0	4	1
A	getRetryStrategyClass()	0	4	1
A	getNormalizerClasses()	0	4	1
A	getDefaultQueueName()	0	4	1
A	isSync()	0	4	1
A	isUsingDoctrine()	0	4	1
A	getDispatchingRules()	0	4	1

<?php
namespace Workana\AsyncJobs;

use InvalidArgumentException;
use Workana\AsyncJobs\Retry\BinaryExponentialBackoff;
use Workana\AsyncJobs\Router\DefaultRouter;

/**
 * @author Carlos Frutos <charly@workana.com>
 */
class Configuration
{
    /**
     * @var array
     */
    protected $attributes;

    public function __construct(array $options)
    {
        $this->attributes = $options + [
            'routerClass' => DefaultRouter::class,
            'driverClass' => null,
            'retryStrategyClass' => BinaryExponentialBackoff::class,
            'normalizerClasses' => [],
            'defaultQueueName' => 'default',
            'useDoctrine' => false,
            'sync' => false,
            'dispatchingRules' => [],
        ];

        if (empty($this->attributes['driverClass'])) {
            throw new InvalidArgumentException('Driver class must be specified');
        }
    }

    /**
     * Get router class
     *
     * @return string
     */
    public function getRouterClass()
    {
        return $this->attributes['routerClass'];
    }

    /**
     * Get driver class
     *
     * @return string
     */
    public function getDriverClass()
    {
        return $this->attributes['driverClass'];
    }

    /**
     * Get retry strategy class
     *
     * @return string
     */
    public function getRetryStrategyClass()
    {
        return $this->attributes['retryStrategyClass'];
    }

    /**
     * Get normalizer classes
     *
     * @return string[]
     */
    public function getNormalizerClasses()
    {
        return $this->attributes['normalizerClasses'];
    }

    /**
     * @return string
     */
    public function getDefaultQueueName()
    {
        return $this->attributes['defaultQueueName'];
    }

    /**
     * Is on sync mode for job dispatching
     *
     * @return bool
     */
    public function isSync()
    {
        return $this->attributes['sync'];
    }

    /**
     * @return bool
     */
    public function isUsingDoctrine()
    {
        return $this->attributes['useDoctrine'];
    }

    /**
     * Get dispatching rules
     *
     * @return array
     */
    public function getDispatchingRules()
    {
        return $this->attributes['dispatchingRules'];
    }
}