Lamoda\Metric\Adapters\Doctrine\AtomicMutableWrapper

Complexity

Total Complexity

7

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	resolve()	0	3	1
A	getTags()	0	3	1
A	getName()	0	3	1
A	__construct()	0	4	1
A	setValue()	0	5	1
A	executeWithLock()	0	11	1
A	adjust()	0	5	1

<?php

namespace Lamoda\Metric\Adapters\Doctrine;

use Doctrine\DBAL\LockMode;
use Doctrine\ORM\EntityManagerInterface;
use Lamoda\Metric\Storage\MutableMetricInterface;

/** @internal */
final class AtomicMutableWrapper implements MutableMetricInterface
{
    /** @var EntityManagerInterface */
    private $manager;
    /** @var MutableMetricInterface */
    private $metric;

    public function __construct(EntityManagerInterface $manager, MutableMetricInterface $metric)
    {
        $this->manager = $manager;
        $this->metric = $metric;
    }

    /** {@inheritdoc} */
    public function adjust(float $delta): void
    {
        $this->executeWithLock(
            function () use ($delta) {
                $this->metric->adjust($delta);
            }
        );
    }

    /** {@inheritdoc} */
    public function setValue(float $value): void
    {
        $this->executeWithLock(
            function () use ($value) {
                $this->metric->setValue($value);
            }
        );
    }

    /** {@inheritdoc} */
    public function getName(): string
    {
        return $this->metric->getName();
    }

    /** {@inheritdoc} */
    public function resolve(): float
    {
        return $this->metric->resolve();
    }

    /** {@inheritdoc} */
    public function getTags(): array
    {
        return $this->metric->getTags();
    }

    private function executeWithLock(callable $fn): void
    {
        $this->manager->transactional(
            function () use ($fn) {
                $this->manager->lock($this->metric, LockMode::PESSIMISTIC_WRITE);

                $this->manager->refresh($this->metric);

                $fn();

                $this->manager->flush();
            }
        );
    }
}