Chapi\Service\Chronos\JobStatsService

Complexity

Total Complexity

4

Size/Duplication

Total Lines	49
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getJobStats()	0	16	3

<?php
/**
 * @package: chapi
 *
 * @author:  msiebeneicher
 * @since:   2015-09-09
 *
 * @link:    https://github.com/msiebeneicher/chapi/issues/24
 */

namespace Chapi\Service\Chronos;

use Chapi\Component\Cache\CacheInterface;
use Chapi\Component\RemoteClients\ApiClientInterface;
use Chapi\Entity\Chronos\JobStatsEntity;

class JobStatsService implements JobStatsServiceInterface
{
    const CACHE_TIME_JOB_STATS = 900;

    const CACHE_KEY_JOB_STATS = 'jobs.stats.%s';

    /**
     * @var \Chapi\Component\RemoteClients\ApiClientInterface
     */
    private $apiClient;

    /**
     * @var CacheInterface
     */
    private $cache;

    /**
     * @param \Chapi\Component\RemoteClients\ApiClientInterface $apiClient
     * @param CacheInterface $cache
     */
    public function __construct(
        \Chapi\Component\RemoteClients\ApiClientInterface $apiClient,
        CacheInterface $cache
    ) {
        $this->apiClient = $apiClient;
        $this->cache = $cache;
    }

    /**
     * @param $jobName
     * @return JobStatsEntity
     */
    public function getJobStats($jobName)
    {
        $cacheKey = sprintf(self::CACHE_KEY_JOB_STATS, $jobName);
        $stats = $this->cache->get($cacheKey);

        if (empty($stats)) {
            $stats = $this->apiClient->getJobStats($jobName);

            // set result to cache
            if (!empty($stats)) {
                $this->cache->set($cacheKey, $stats, self::CACHE_TIME_JOB_STATS);
            }
        }

        return new JobStatsEntity($stats);
    }
}