Lamoda\Metric\Storage\MaterializeHelper

Complexity

Total Complexity

4

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	materializeSource()	0	8	2
A	materialize()	0	6	1

<?php

namespace Lamoda\Metric\Storage;

use Lamoda\Metric\Collector\CollectorRegistry;
use Lamoda\Metric\Common\Metric;
use Lamoda\Metric\Common\MetricSourceInterface;
use Lamoda\Metric\Common\Source\IterableMetricSource;
use Lamoda\Metric\Storage\Exception\ReceiverException;

final class MaterializeHelper
{
    /** @var CollectorRegistry */
    private $collectorRegistry;
    /** @var StorageRegistry */
    private $storageRegistry;

    /**
     * @param CollectorRegistry $collectorRegistry
     * @param StorageRegistry   $storageRegistry
     */
    public function __construct(CollectorRegistry $collectorRegistry, StorageRegistry $storageRegistry)
    {
        $this->collectorRegistry = $collectorRegistry;
        $this->storageRegistry = $storageRegistry;
    }

    /**
     * Receives metrics from named collector to named storage.
     *
     * @param string $collectorName
     * @param string $storageName
     *
     * @throws ReceiverException
     * @throws \OutOfBoundsException
     */
    public function materialize(string $collectorName, string $storageName): void
    {
        $collector = $this->collectorRegistry->getCollector($collectorName);
        $storage = $this->storageRegistry->getStorage($storageName);

        $storage->receive($this->materializeSource($collector->collect()));
    }

    private function materializeSource(MetricSourceInterface $source): MetricSourceInterface
    {
        $metrics = [];
        foreach ($source->getMetrics() as $metric) {
            $metrics[] = new Metric($metric->getName(), $metric->resolve(), $metric->getTags());
        }

        return new IterableMetricSource($metrics);
    }
}