Reverse

src/Collection/AllRatesRecord.php

@@ -0,0 +1,46 @@
+<?php
+declare(strict_types=1);
+
+namespace PayCrypto\Collection;
+
+use ScriptFUSION\Porter\Collection\CountableProviderRecords;
+use ScriptFUSION\Porter\Provider\Resource\ProviderResource;
+
+class AllRatesRecord extends CountableProviderRecords
+{
+    private $base;
+
+    private $time;
+
+    private $quote;
+
+    private $rate;
+
+    public function __construct(array $time, string $base, array $quote, array $rate)
+    {
+        $this->base = $base;
+        $this->time = $time;
+        $this->quote = $quote;
+        $this->rate = $rate;
+    }
+
+    public function getBase(): string
+    {
+        return $this->base;
+    }
+
+    public function getTime(): array
+    {
+        return $this->time;
+    }
+
+    public function getQuote(): array
+    {
+        return $this->quote;
+    }
+
+    public function getRate(): array
+    {
+        return $this->rate;
+    }
+}

src/Collection/SpecificRateRecord.php

@@ -0,0 +1,46 @@
+<?php
+declare(strict_types=1);
+
+namespace PayCrypto\Collection;
+
+use ScriptFUSION\Porter\Collection\CountableProviderRecords;
+use ScriptFUSION\Porter\Provider\Resource\ProviderResource;
+
+class SpecificRateRecord extends CountableProviderRecords
+{
+    private $base;
+
+    private $time;
+
+    private $quote;
+
+    private $rate;
+
+    public function __construct(string $time, string $base, string $quote, float $rate)
+    {
+        $this->base = $base;
+        $this->time = $time;
+        $this->quote = $quote;
+        $this->rate = $rate;
+    }
+
+    public function getBase(): string
+    {
+        return $this->base;
+    }
+
+    public function getTime(): string
+    {
+        return $this->time;
+    }
+
+    public function getQuote(): string
+    {
+        return $this->quote;
+    }
+
+    public function getRate(): float
+    {
+        return $this->rate;
+    }
+}

src/Connector/CryptoConnector.php

@@ -0,0 +1,19 @@
+<?php
+declare(strict_types=1);
+
+namespace PayCrypto\Connector;
+
+use ScriptFUSION\Porter\Net\Http\HttpConnector;
+use ScriptFUSION\Porter\Net\Http\HttpOptions;
+
+class CryptoConnector extends HttpConnector
+{
+    private $options;
+
+    public function __construct(string $apiKey)
+    {
+        $buildHeader = sprintf("X-CoinAPI-Key: %s", $apiKey);
+
+        parent::__construct($this->options = (new HttpOptions)->addHeader($buildHeader));
+    }
+}

src/CryptoMonitor.php

@@ -0,0 +1,29 @@
+<?php
+declare(strict_types=1);
+
+namespace PayCrypto;
+
+use ScriptFUSION\Porter\Connector\Connector;
+use ScriptFUSION\Porter\Provider\Provider;
+
+class CryptoMonitor implements Provider
+{
+    public const EXCHANGE_API_ENDPOINT = 'https://rest.coinapi.io/';
+
+    private $connector;
+
+    public function __construct(Connector $connector)
+    {
+        $this->connector = $connector;
+    }
+
+    public static function buildExchangeApiUrl(string $url): string
+    {
+        return self::EXCHANGE_API_ENDPOINT . $url;
+    }
+
+    public function getConnector(): Connector
+    {
+        return $this->connector;
+    }
+}

src/Resource/GetAllRate.php

@@ -0,0 +1,54 @@
+<?php
+declare(strict_types=1);
+
+namespace PayCrypto\Resource;
+
+use PayCrypto\CryptoMonitor;
+use PayCrypto\Collection\AllRatesRecord;
+use ScriptFUSION\Porter\Connector\ImportConnector;
+use ScriptFUSION\Porter\Provider\Patreon\Collection\PledgeRecords;
+use ScriptFUSION\Porter\Provider\Patreon\PatreonProvider;
+use ScriptFUSION\Porter\Provider\Resource\ProviderResource;
+
+class GetAllRate implements ProviderResource
+{
+    private $apiKey;
+
+    public $base = 'BTC';
+
+    public function __construct(string $apiKey)
+    {
+        $this->apiKey = $apiKey;
+    }
+
+    public function getProviderClassName(): string
+    {
+        return CryptoMonitor::class;
+    }
+
+    public function fetch(ImportConnector $connector): \Iterator
+    {
+        $response = \json_decode(
+            (string) $connector->fetch(
+                CryptoMonitor::buildExchangeApiUrl(
+                    sprintf("v1/exchangerate/%s", $this->base)
+                )
+            ),
+            true
+        );
+
+        $rates = $response['rates'];
+        $base = $response['asset_id_base'];
+        $quote = [];
+        $rate = [];
+        $time = [];
+
+        foreach($rates as $key => $value) {
+            $quote[] = $rates[$key]['asset_id_quote'];
+            $rate[] = $rates[$key]['rate'];
+            $time[] = $rates[$key]['time'];
+        }
+
+        return new AllRatesRecord($time, $base, $quote, $rate);
+    }
+}

src/Resource/GetSpecificRate.php

@@ -0,0 +1,50 @@
+<?php
+declare(strict_types=1);
+
+namespace PayCrypto\Resource;
+
+use PayCrypto\CryptoMonitor;
+use PayCrypto\Collection\SpecificRateRecord;
+use ScriptFUSION\Porter\Connector\ImportConnector;
+use ScriptFUSION\Porter\Provider\Patreon\Collection\PledgeRecords;
+use ScriptFUSION\Porter\Provider\Patreon\PatreonProvider;
+use ScriptFUSION\Porter\Provider\Resource\ProviderResource;
+
+class GetSpecificRate implements ProviderResource
+{
+    private $apiKey;
+
+    public $base = 'BTC';
+
+    public $quote = 'USD';
+
+    public function __construct(string $apiKey)
+    {
+        $this->apiKey = $apiKey;
+    }
+
+    public function getProviderClassName(): string
+    {
+        return CryptoMonitor::class;
+    }
+
+    public function fetch(ImportConnector $connector): \Iterator
+    {
+        $response = \json_decode(
+            (string) $connector->fetch(
+                CryptoMonitor::buildExchangeApiUrl(
+                    sprintf("v1/exchangerate/%s/%s", $this->base, $this->quote)
+                )
+            ),
+            true
+        );
+
+        $base = $response['asset_id_base'];
+
+        $quote = $response['asset_id_quote'];
+        $rate = $response['rate'];
+        $time = $response['time'];
+
+        return new SpecificRateRecord($time, $base, $quote, $rate);
+    }
+}

tests/FixtureFactory.php

@@ -0,0 +1,28 @@
+<?php
+
+namespace PayCrypto\Tests;
+
+use Psr\Container\ContainerInterface;
+use ScriptFUSION\Porter\Porter;
+use PayCrypto\Connector\CryptoConnector;
+use PayCrypto\CryptoMonitor;
+use ScriptFUSION\StaticClass;
+
+final class FixtureFactory
+{
+    use StaticClass;
+
+    public static function createPorter(): Porter
+    {
+        return new Porter(
+            \Mockery::mock(ContainerInterface::class)
+                ->shouldReceive('has')
+                    ->with(CryptoMonitor::class)
+                    ->andReturn(true)
+                ->shouldReceive('get')
+                    ->with(CryptoMonitor::class)
+                    ->andReturn(new CryptoMonitor(new CryptoConnector('4E861687-19D6-4894-87B9-E785B1EE3900')))
+                ->getMock()
+        );
+    }
+}

tests/Functional/GetRateTest.php

@@ -0,0 +1,48 @@
+<?php
+declare(strict_types=1);
+
+namespace PayCrypto\Tests;
+
+use PHPUnit\Framework\TestCase;
+use PayCrypto\Resource\GetSpecificRate;
+use PayCrypto\Resource\GetAllRate;
+use PayCrypto\Collection\SpecificRateRecord;
+use PayCrypto\Collection\AllRatesRecord;
+use ScriptFUSION\Porter\Specification\ImportSpecification;
+
+final class GetRateTest extends TestCase
+{
+    /** @var $apiKey This is the Coin API Key for test environment*/
+    private $apiKey = '4E861687-19D6-4894-87B9-E785B1EE3900';
+
+    public function testGetSpecificRateRecords()
+    {
+        /** @var SpecificRateRecord $rates */
+        $rates = FixtureFactory::createPorter()->import(new ImportSpecification(new GetSpecificRate($this->apiKey)))
+            ->findFirstCollection();
+
+        $this->assertSame('BTC', $rates->getBase());
+        $this->assertSame('USD', $rates->getQuote());
+        $this->assertLessThanOrEqual(time(), strtotime($rates->getTime()));
+        $this->assertInternalType('float', $rates->getRate());
+    }
+
+    public function testGetAllRateRecords()
+    {
+        /** @var AllRatesRecord $rates */
+        $rates = FixtureFactory::createPorter()->import(new ImportSpecification(new GetAllRate($this->apiKey)))
+            ->findFirstCollection();
+
+        $base = $rates->getBase();
+        $quote = $rates->getQuote();
+        $time = $rates->getTime();
+        $rate = $rates->getRate();
+
+        $this->assertSame('BTC', $base);
+        $this->assertContains('USD', $quote);
+        $this->assertContains('GBP', $quote);
+        $this->assertContains('EUR', $quote);
+        $this->assertLessThanOrEqual(time(), strtotime($time[0]));
+        $this->assertInternalType('float', $rate[0]);
+    }
+}