eXpansion\Framework\Core\Helpers\JobRunner\Factory

Complexity

Total Complexity

6

Size/Duplication

Total Lines	55
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	3

Test Coverage

Coverage

80%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getJobRunner()	0	4	1
A	createCurlJob()	0	11	1
A	startJob()	0	4	1
A	onPreLoop()	0	4	1
A	onPostLoop()	0	4	1
A	onEverySecond()	0	4	1

<?php

namespace eXpansion\Framework\Core\Helpers\JobRunner;

use eXpansion\Framework\Core\DataProviders\Listener\ListenerInterfaceExpApplication;
use eXpansion\Framework\Core\DataProviders\Listener\ListenerInterfaceExpTimer;
use eXpansion\Framework\Core\Helpers\Structures\HttpRequest;
use eXpansion\Framework\Core\Helpers\Structures\HttpResult;
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 implements ListenerInterfaceExpTimer
{
    /**
     * @return JobRunner
     */
    public function getJobRunner()
    {
        return JobRunner::getInstance('expansion', PHP_BINARY, 'var/tmp/asynchronous');
    }

    /**
     * @param $url
     * @param $callback
     * @param null|mixed $additionalData
     * @param array $options
     *
     * @param array|\stdClass $parameters one dimensional array or \stdClass with post key-value pairs
     * @return CallbackCurl
     */
    public function createCurlJob($url, $callback, $additionalData = null, $options = [], $parameters = [])
    {
        $curlJob = new HttpRequest();
        $curlJob->setCallback($callback);
        $curlJob->setUrl($url);
        $curlJob->setOptions($options);
        $curlJob->setParameters($parameters);

It seems like $parameters defined by parameter $parameters on line 40 can also be of type object<stdClass>; however, oliverde8\AsynchronousJobs\Job\Curl::setParameters() does only seem to accept array, maybe add an additional type check?

        $curlJob->setAdditionalData($additionalData);

        return $curlJob;
    }

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


    public function onPreLoop()
    {

    }

    public function onPostLoop()
    {
        $this->getJobRunner()->proccess();
    }

    public function onEverySecond()
    {

    }
}