eXpansion\Framework\Core\Helpers\JobRunner\Factory

Complexity

Total Complexity

4

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	getJobRunner()	0	4	1
A	createCurlJob()	0	10	1
A	startJob()	0	4	1
A	onExpansionPostLoop()	0	4	1

<?php

namespace eXpansion\Framework\Core\Helpers\JobRunner;

use oliverde8\AsynchronousJobs\Job;
use oliverde8\AsynchronousJobs\Job\CallbackCurl;
use oliverde8\AsynchronousJobs\JobRunner;


/**
 * Class Factory
 *
 * @author    de Cramer Oliver<oldec@smile.fr>
 * @copyright 2017 Smile
 * @package Tests\eXpansion\Framework\Core\Helpers\JobRunner
 */
class Factory
{
    /**
     * @return JobRunner
     */
    public function getJobRunner()
    {
        return JobRunner::getInstance('expansion', 'php', 'var/tmp/asnychronous');
    }

    /**
     * @param $url
     * @param $callback
     * @param null $additionalData
     * @param array $options
     *
     * @return CallbackCurl
     */
    public function createCurlJob($url, $callback, $additionalData = null, $options = [])
    {
        $curlJob = new CallbackCurl();
        $curlJob->setCallback($callback);
        $curlJob->setUrl($url);
        $curlJob->setOptions($options);
        $curlJob->__additionalData = $additionalData;

The property __additionalData does not seem to exist in oliverde8\AsynchronousJobs\Job\CallbackCurl.

        return $curlJob;
    }

    /**
     * @param Job $job
     */
    public function startJob(Job $job)
    {
        $job->start();
    }


    /**
     * On each loop check for finished jobs.
     */
    public function onExpansionPostLoop()
    {
        $this->getJobRunner()->proccess();
    }
}