flipbox\queue\jobs\AbstractCollection

Complexity

Total Complexity

10

Size/Duplication

Total Lines	72
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	runInternal()	0	12	3
A	runJob()	0	16	4
A	toConfig()	0	9	1
A	getJobsConfig()	0	8	2

<?php

namespace flipbox\queue\jobs;

use flipbox\queue\helpers\JobHelper;
use flipbox\queue\jobs\traits\CollectionTrait;

abstract class AbstractCollection extends AbstractJob
{

    use CollectionTrait;

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

    /**
     * @return bool
     */
    protected function runInternal()
    {
        $success = true;

        foreach ($this->getJobs() as $job) {
            if (!$this->runJob($job)) {
                $success = false;
            }
        }

        return $success;
    }

    /**
     * @param string $job
     * @return mixed
     */
    protected function runJob($job)
    {
        if (is_string($job)) {
            $job = $this->jobConfig($job);
        }

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

        if ($this->toQueue) {
            return $job->toQueue();
        }

        return $job->run();
    }

    /**
     * @return array
     */
    public function toConfig(): array
    {
        return array_merge(
            parent::toConfig(),
            [
                'jobs' => $this->getJobsConfig()
            ]
        );
    }

    /**
     * @return array
     */
    protected function getJobsConfig()
    {
        $jobsConfig = [];
        foreach ($this->getJobs() as $job) {
            $jobsConfig[] = $job->toConfig();
        }
        return $jobsConfig;
    }
}