Krenor\Prometheus\Storage\Repositories\ApcRepository

Complexity

Total Complexity

13

Size/Duplication

Total Lines	88
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	flush()	0	3	1
A	decrement()	0	3	1
A	set()	0	12	4
A	push()	0	8	2
A	get()	0	3	2
A	increment()	0	11	2
A	__construct()	0	3	1

<?php

namespace Krenor\Prometheus\Storage\Repositories;

use RuntimeException;
use Tightenco\Collect\Support\Collection;
use Krenor\Prometheus\Contracts\Repository;

class ApcRepository implements Repository
{
    /**
     * @var ApcWrapper
     */
    protected $apc;

    /**
     * ApcRepository constructor.
     *
     * @param ApcWrapper $apc
     */
    public function __construct(ApcWrapper $apc)
    {
        $this->apc = $apc;
    }

    /**
     * {@inheritdoc}
     */
    public function get(string $key): Collection
    {
        return new Collection($this->apc->get($key) ?: []);
    }

    /**
     * {@inheritdoc}
     */
    public function increment(string $key, string $field, float $value): void
    {
        $collection = $this->get($key);

        $stored = $this->apc->store($key, $collection->put(
            $field,
            $collection->get($field, 0) + $value
        ));

        if (!$stored) {
            throw new RuntimeException('The store method returned false.');
        }
    }

    /**
     * {@inheritdoc}
     */
    public function decrement(string $key, string $field, float $value): void
    {
        $this->increment($key, $field, -abs($value));
    }

    /**
     * {@inheritdoc}
     */
    public function set(string $key, string $field, $value, $override = true): void
    {
        $collection = $this->get($key);

        if (!$override && $collection->get($field) !== null) {
            return;
        }

        $stored = $this->apc->store($key, $collection->put($field, $value));

        if (!$stored) {
            throw new RuntimeException('The store method returned false.');
        }
    }

    /**
     * {@inheritdoc}
     */
    public function push(string $key, float $value): void
    {
        $collection = $this->get($key);

        $stored = $this->apc->store($key, $collection->push($value));

        if (!$stored) {
            throw new RuntimeException('The store method returned false.');
        }
    }

    /**
     * {@inheritdoc}
     */
    public function flush(): bool
    {
        return $this->apc->flush();
    }
}