flipbox\queue\jobs\traits\CollectionTrait

Complexity

Total Complexity

14

Size/Duplication

Total Lines	111
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	jobConfig()	0	6	1
A	setJobs()	0	6	1
A	addJobs()	0	11	1
A	addJob()	0	14	1
A	getJobs()	0	4	1
A	findJob()	0	4	1
A	getJob()	0	8	2
A	createJob()	0	6	1

<?php

namespace flipbox\queue\jobs\traits;

use craft\helpers\ArrayHelper;
use flipbox\queue\helpers\JobHelper;
use flipbox\queue\jobs\JobInterface;
use yii\base\Exception;

trait CollectionTrait
{

    use JobTrait;

    /**
     * @var JobInterface[]
     */
    protected $jobs;

    /**
     * @param string $class
     * @return array
     */
    protected function jobConfig(string $class): array
    {
        return [
            'class' => $class
        ];
    }

    /**
     * @param array $jobs
     * @return static
     */
    public function setJobs(array $jobs = [])
    {
        $this->jobs = null;

It seems like null of type null is incompatible with the declared type array<integer,object<flipbox\queue\jobs\JobInterface>> of property $jobs.

        return $this->addJobs($jobs);
    }

    /**
     * @param array $jobs
     * @return static
     */
    protected function addJobs(array $jobs = [])
    {
        foreach ($jobs as $key => $job) {
            if (is_numeric($key) || empty($key)) {
                $key = null;
            }
            $this->addJob($key, $job);
        }

        return $this;
    }

    /**
     * @param $key
     * @param $job
     * @return static
     */
    public function addJob($key, $job)
    {
        if (is_string($job)) {
            $job = $this->jobConfig($job);
        }

        if (!$job instanceof JobInterface) {
            $job = JobHelper::create($job);
        }

        $this->jobs[$key] = $job;

        return $this;
    }

    /**
     * @return JobInterface[]
     */
    public function getJobs()
    {
        return $this->jobs;
    }

    /**
     * @param $identifier
     * @return JobInterface
     */
    public function findJob($identifier)
    {
        return ArrayHelper::getValue($this->jobs, $identifier);
    }

    /**
     * @param $identifier
     * @return JobInterface
     * @throws Exception
     */
    public function getJob($identifier)
    {
        if (!$job = $this->findJob($identifier)) {
            throw new Exception("Job not found.");
        }

        return $job;
    }

    /**
     * @param $identifier
     * @param array $config
     * @return JobInterface
     */
    public function createJob($identifier, array $config = [])
    {
        $config['class'] = $this->getJob($identifier);

        return JobHelper::create($config);
    }
}