vendor/florianv/exchanger/src/Service/EuropeanCentralBank.php line 44

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /*
  6.  * This file is part of Exchanger.
  7.  *
  8.  * (c) Florian Voutzinos <florian@voutzinos.com>
  9.  *
  10.  * For the full copyright and license information, please view the LICENSE
  11.  * file that was distributed with this source code.
  12.  */
  14. namespace Exchanger\Service;
  16. use Exchanger\Contract\ExchangeRateQuery;
  17. use Exchanger\Contract\HistoricalExchangeRateQuery;
  18. use Exchanger\Exception\UnsupportedCurrencyPairException;
  19. use Exchanger\Exception\UnsupportedDateException;
  20. use Exchanger\StringUtil;
  21. use Exchanger\Contract\ExchangeRate as ExchangeRateContract;
  23. /**
  24.  * European Central Bank Service.
  25.  *
  26.  * @author Florian Voutzinos <florian@voutzinos.com>
  27.  */
  28. final class EuropeanCentralBank extends HttpService
  29. {
  30.     use SupportsHistoricalQueries;
  32.     const DAILY_URL = 'https://www.ecb.europa.eu/stats/eurofxref/eurofxref-daily.xml';
  34.     const HISTORICAL_URL_LIMITED_TO_90_DAYS_BACK = 'https://www.ecb.europa.eu/stats/eurofxref/eurofxref-hist-90d.xml';
  36.     const HISTORICAL_URL_OLDER_THAN_90_DAYS = 'https://www.ecb.europa.eu/stats/eurofxref/eurofxref-hist.xml';
  38.     /**
  39.      * {@inheritdoc}
  40.      */
  41.     protected function getLatestExchangeRate(ExchangeRateQuery $exchangeQuery): ExchangeRateContract
  42.     {
  43.         $currencyPair = $exchangeQuery->getCurrencyPair();
  44.         $content = $this->request(self::DAILY_URL);
  46.         $element = StringUtil::xmlToElement($content);
  47.         $element->registerXPathNamespace('xmlns', 'http://www.ecb.int/vocabulary/2002-08-01/eurofxref');
  49.         $quoteCurrency = $currencyPair->getQuoteCurrency();
  50.         $elements = $element->xpath('//xmlns:Cube[@currency="'.$quoteCurrency.'"]/@rate');
  51.         $date = new \DateTime((string) $element->xpath('//xmlns:Cube[@time]/@time')[0]);
  53.         if (empty($elements) || !$date) {
  54.             throw new UnsupportedCurrencyPairException($currencyPair, $this);
  55.         }
  57.         return $this->createRate($currencyPair, (float) ($elements[0]['rate']), $date);
  58.     }
  60.     /**
  61.      * {@inheritdoc}
  62.      */
  63.     protected function getHistoricalExchangeRate(HistoricalExchangeRateQuery $exchangeQuery): ExchangeRateContract
  64.     {
  65.         $currencyPair = $exchangeQuery->getCurrencyPair();
  66.         $historicalUrl = $this->getHistoricalUrl($exchangeQuery->getDate());
  67.         $content = $this->request($historicalUrl);
  69.         $element = StringUtil::xmlToElement($content);
  70.         $element->registerXPathNamespace('xmlns', 'http://www.ecb.int/vocabulary/2002-08-01/eurofxref');
  72.         $formattedDate = $exchangeQuery->getDate()->format('Y-m-d');
  73.         $quoteCurrency = $currencyPair->getQuoteCurrency();
  75.         $elements = $element->xpath('//xmlns:Cube[@time="'.$formattedDate.'"]/xmlns:Cube[@currency="'.$quoteCurrency.'"]/@rate');
  77.         if (empty($elements)) {
  78.             if (empty($element->xpath('//xmlns:Cube[@time="'.$formattedDate.'"]'))) {
  79.                 throw new UnsupportedDateException($exchangeQuery->getDate(), $this);
  80.             }
  82.             throw new UnsupportedCurrencyPairException($currencyPair, $this);
  83.         }
  85.         return $this->createRate($currencyPair, (float) ($elements[0]['rate']), $exchangeQuery->getDate());
  86.     }
  88.     /**
  89.      * {@inheritdoc}
  90.      */
  91.     public function supportQuery(ExchangeRateQuery $exchangeQuery): bool
  92.     {
  93.         return 'EUR' === $exchangeQuery->getCurrencyPair()->getBaseCurrency();
  94.     }
  96.     /**
  97.      * {@inheritdoc}
  98.      */
  99.     public function getName(): string
  100.     {
  101.         return 'european_central_bank';
  102.     }
  104.     /**
  105.      * @param \DateTimeInterface $date
  106.      *
  107.      * @return string
  108.      *
  109.      * @throws \Exception
  110.      */
  111.     private function getHistoricalUrl(\DateTimeInterface $date): string
  112.     {
  113.         $dateDiffInDays = $date->diff(new \DateTime('now'))->days;
  114.         if ($dateDiffInDays > 90) {
  115.             return self::HISTORICAL_URL_OLDER_THAN_90_DAYS;
  116.         }
  118.         return self::HISTORICAL_URL_LIMITED_TO_90_DAYS_BACK;
  119.     }
  120. }