Kaliop\Queueing\Plugins\KinesisBundle\Service\DoctrineCacheSequenceNumberStore

Complexity

Total Complexity

4

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

30%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	save()	0	4	1
A	fetch()	0	4	1
A	getCacheId()	0	4	1

<?php

namespace Kaliop\Queueing\Plugins\KinesisBundle\Service;

use Doctrine\Common\Cache\Cache;

/**
 * Uses the Doctrine Cache to store the Sequence Number of stream shards
 */
class DoctrineCacheSequenceNumberStore implements SequenceNumberStoreInterface
{
    /** @var  \Doctrine\Common\Cache\Cache */
    protected $cache;

    public function __construct(Cache $cacheService)
    {
        $this->cache =  $cacheService;
    }

    /**
     * @param $stream
     * @param $shard
     * @param $sequenceNumber
     */
    public function save($stream, $shard, $sequenceNumber)
    {
        $this->cache->save($this->getCacheId($stream, $shard), $sequenceNumber);
    }

    /**
     * @param $stream
     * @param $shard
     * @return string|null
     */
    public function fetch($stream, $shard)
    {
        return $this->cache->fetch($this->getCacheId($stream, $shard));
    }

    protected function getCacheId($stream, $shard)
    {
        return md5(md5($stream).md5($shard));
    }
}