BenTools\Currency\Provider\DoctrineORMProvider

Complexity

Total Complexity

6

Size/Duplication

Total Lines	80
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	12	2
B	getExchangeRate()	0	33	4

<?php

namespace BenTools\Currency\Provider;

use BenTools\Currency\Model\CurrencyInterface;
use BenTools\Currency\Model\ExchangeRateInterface;
use BenTools\Currency\Model\ExchangeRateNotFoundException;
use DateTimeInterface;
use Doctrine\Common\Persistence\ManagerRegistry;

class DoctrineORMProvider implements ExchangeRateProviderInterface
{
    private const DEFAULT_PROPERTY_MAP = [
        'sourceCurrency' => 'sourceCurrencyCode',
        'targetCurrency' => 'targetCurrencyCode',
        'date'           => 'date',
    ];

    /**
     * @var ManagerRegistry
     */
    private $managerRegistry;

    /**
     * @var string
     */
    private $entityClass;

    /**
     * @var array
     */
    private $propertyMap;

    /**
     * DoctrineORMProvider constructor.
     * @param ManagerRegistry $managerRegistry
     * @param string          $entityClass
     * @param array           $propertyMap
     * @throws \InvalidArgumentException
     */
    public function __construct(
        ManagerRegistry $managerRegistry,
        string $entityClass,
        array $propertyMap = self::DEFAULT_PROPERTY_MAP
    ) {
        if (!is_a($entityClass, ExchangeRateInterface::class, true)) {
            throw new \InvalidArgumentException(sprintf('%s must implement %s', $entityClass, ExchangeRateInterface::class));
        }
        $this->managerRegistry = $managerRegistry;
        $this->entityClass = $entityClass;
        $this->propertyMap = $propertyMap;
    }

    /**
     * @inheritDoc
     */
    public function getExchangeRate(CurrencyInterface $sourceCurrency, CurrencyInterface $targetCurrency, DateTimeInterface $date = null): ExchangeRateInterface
    {
        $em = $this->managerRegistry->getManagerForClass($this->entityClass);
        $repository = $em->getRepository($this->entityClass);
        if (null !== $date) {
            $exchangeRate = $repository->findOneBy([
                $this->propertyMap['sourceCurrency'] => $sourceCurrency->getCode(),
                $this->propertyMap['targetCurrency'] => $targetCurrency->getCode(),
                $this->propertyMap['date']           => $date,
            ]);

            if (null === $exchangeRate) {
                throw new ExchangeRateNotFoundException($sourceCurrency, $targetCurrency);
            }
            return $exchangeRate;
        }

        $criteria = [
            $this->propertyMap['sourceCurrency'] => $sourceCurrency->getCode(),
            $this->propertyMap['targetCurrency'] => $targetCurrency->getCode(),
            $this->propertyMap['date']           => $date,
        ];
        $orderBy = [
            $this->propertyMap['date'] => 'desc'
        ];

        $results = $repository->findBy($criteria, $orderBy, 1);

        foreach ($results as $exchangeRate) {
            return $exchangeRate;
        }
        throw new ExchangeRateNotFoundException($sourceCurrency, $targetCurrency);
    }
}