Chapi\Component\RemoteClients\ChronosApiClient

Complexity

Total Complexity

16

Size/Duplication

Total Lines	116
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

84.62%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	listingJobs()	0	4	1
C	addingJob()	0	25	7
A	updatingJob()	0	4	1
A	removeJob()	0	5	1
A	getJobStats()	0	4	1
A	sendGetJsonRequest()	0	10	2
A	ping()	0	11	2

<?php
/**
 * @package: chapi
 *
 * @author:  msiebeneicher
 * @since:   2015-07-28
 *
 */


namespace Chapi\Component\RemoteClients;


use Chapi\Component\RemoteClients\ApiClientInterface;
use Chapi\Component\Http\HttpClientInterface;
use Chapi\Entity\Chronos\ChronosJobEntity;
use Chapi\Entity\JobEntityInterface;
use Chapi\Exception\ApiClientException;
use Symfony\Component\Config\Definition\Exception\Exception;

class ChronosApiClient implements ApiClientInterface
{
    /**
     * @var HttpClientInterface
     */
    private $oHttpClient;

    /**
     * @param HttpClientInterface $oHttpClient
     */
    public function __construct(
        HttpClientInterface $oHttpClient
    )
    {
        $this->oHttpClient = $oHttpClient;
    }

    /**
     * @inheritdoc
     * @link: https://mesos.github.io/chronos/docs/api.html#listing-jobs
     */
    public function listingJobs()
    {
        return $this->sendGetJsonRequest('/scheduler/jobs');
    }

    /**
     * @param JobEntityInterface $oJobEntity
     * @return bool
     * @throws ApiClientException
     */
    public function addingJob(JobEntityInterface $oJobEntity)
    {
        $_sTargetUrl = '';

        if (!$oJobEntity instanceof ChronosJobEntity)
        {
            throw new \RuntimeException('Expected ChronosJobEntity.');
        }

        if (!empty($oJobEntity->schedule) && empty($oJobEntity->parents))
        {
            $_sTargetUrl = '/scheduler/iso8601';
        } elseif (empty($oJobEntity->schedule) && !empty($oJobEntity->parents))
        {
            $_sTargetUrl = '/scheduler/dependency';
        }

        if (empty($_sTargetUrl))
        {
            throw new ApiClientException('No scheduler or dependency found. Can\'t get right target url.');
        }

        $_oResponse = $this->oHttpClient->postJsonData($_sTargetUrl, $oJobEntity);
        return ($_oResponse->getStatusCode() == 204);
    }

    /**
     * @param JobEntityInterface|ChronosJobEntity $oJobEntity
     * @return bool
     * @throws ApiClientException
     */
    public function updatingJob(JobEntityInterface $oJobEntity)
    {
        return $this->addingJob($oJobEntity);
    }

    /**
     * @param string $sJobName
     * @return bool
     */
    public function removeJob($sJobName)
    {
        $_oResponse = $this->oHttpClient->delete('/scheduler/job/' . $sJobName);
        return ($_oResponse->getStatusCode() == 204);
    }

    /**
     * @inheritdoc
     */
    public function getJobStats($sJobName)
    {
        return $this->sendGetJsonRequest('/scheduler/job/stat/' . $sJobName);
    }

    /**
     * @param string $sUrl
     * @return array
     */
    private function sendGetJsonRequest($sUrl)
    {
        $_oResponse = $this->oHttpClient->get($sUrl);
        if (200 == $_oResponse->getStatusCode())
        {
            return $_oResponse->json();
        }

        return [];
    }

    /**
     * Returns true if the client can be connected to.
     * @return bool
     */
    public function ping()
    {
        try {
            $this->oHttpClient->get('scheduler/jobs');
        } catch (\Exception $e)
        {
            return false;
        }

        return true;
    }
}