Nimbles\CMTelecom\Client\IDINClient

Complexity

Total Complexity

9

Size/Duplication

Total Lines	151
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	getUserInfo()	0	24	2
A	getIssuers()	0	24	3
A	getIDINTransaction()	0	50	3

<?php
/*
* (c) Nimbles b.v. <wessel@nimbles.com>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/

namespace Nimbles\CMTelecom\Client;

use GuzzleHttp\Psr7\Request;
use Http\Client\HttpClient;
use Nimbles\CMTelecom\Exception\IDINTransactionException;
use Nimbles\CMTelecom\Exception\IssuerConnectionException;
use Nimbles\CMTelecom\Exception\UserInfoException;
use Nimbles\CMTelecom\Model\IDINTransaction;
use Nimbles\CMTelecom\Model\Issuer;

/**
 * Class IDINClient
 */
class IDINClient
{
    /** @var HttpClient */
    private $httpClient;

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

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

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

    /**
     * @param HttpClient $httpClient
     * @param string          $apiKey
     * @param string          $url
     * @param string          $applicationName
     */
    public function __construct(HttpClient $httpClient, string $apiKey, string $url, string $applicationName)
    {
        $this->httpClient             = $httpClient;
        $this->apiKey                 = $apiKey;
        $this->url                    = $url;
        $this->applicationName        = $applicationName;
    }

    /**
     * @return Issuer[]
     *
     * @throws IssuerConnectionException
     */
    public function getIssuers() : array
    {
        $uri = sprintf('%s/directory', rtrim($this->url, '/'));

        $request = new Request('POST', $uri, [
            'User-Agent' => $this->applicationName,
            'Content-Type' => 'application/json'
        ], json_encode(['merchant_token' => $this->apiKey]));

        $response = $this->httpClient->sendRequest($request);

        $responseData = json_decode($response->getBody()->getContents(), true);

        if ($response->getStatusCode() !== 200) {
            throw new IssuerConnectionException($responseData);
        }

        if (! isset($responseData[0]['issuers'])) {
            throw new IssuerConnectionException('Unable to parse issuers');
        }

        return array_map(function ($issuerData) {
            return new Issuer($issuerData['issuer_id'], $issuerData['issuer_name']);
        }, $responseData[0]['issuers']);
    }

    /**
     * @param Issuer $issuer
     * @param string $redirectUrl
     *
     * @return IDINTransaction
     *
     * @throws IDINTransactionException
     */
    public function getIDINTransaction(Issuer $issuer, string $redirectUrl, array $scopes = []) : IDINTransaction
    {
        $uri = sprintf('%s/transaction', rtrim($this->url, '/'));

        $token = md5(time() . rand(1, 1000) . $issuer->getId() . $issuer->getName());

        $options = [
            'identity'         => true,
            'name'             => true,
            'gender'           => true,
            'address'          => true,
            'date_of_birth'    => true,
            '18y_or_older'     => true,
            'email_address'    => false,
            'telephone_number' => false,
        ];

        if (!empty($scopes)) {
            $options = array_merge(
                array_fill_keys(array_keys($options), false),
                array_fill_keys($scopes, true)
            );
        }

        $requestData = array_merge($options, [
            'merchant_token'      => $this->apiKey,
            'issuer_id'           => $issuer->getId(),
            'entrance_code'       => $token,
            'merchant_return_url' => $redirectUrl,
            'language'            => 'nl',
        ]);

        $request = new Request('POST', $uri, [
            'User-Agent' => $this->applicationName,
            'Content-Type' => 'application/json'
        ], json_encode($requestData));

        $response = $this->httpClient->sendRequest($request);

        $responseData = json_decode($response->getBody()->getContents(), true);

        if ($response->getStatusCode() !== 200) {
            throw new IDINTransactionException($responseData);
        }

        return new IDINTransaction(
            $responseData['transaction_id'],
            $responseData['merchant_reference'],
            $token,
            $responseData['issuer_authentication_url']
        );
    }

    /**
     * @param IDINTransaction $IDINTransaction
     *
     * @return array
     *
     * @throws UserInfoException
     */
    public function getUserInfo(IDINTransaction $IDINTransaction) : array
    {
        $uri = sprintf('%s/status', rtrim($this->url, '/'));

        $requestData = [
            'merchant_token'     => $this->apiKey,
            'transaction_id'     => $IDINTransaction->getTransactionId(),
            'merchant_reference' => $IDINTransaction->getMerchantReference(),
        ];

        $request = new Request('POST', $uri, [
            'User-Agent' => $this->applicationName,
            'Content-Type' => 'application/json'
        ], json_encode($requestData));

        $response = $this->httpClient->sendRequest($request);

        $responseData = json_decode($response->getBody()->getContents(), true);

        if ($response->getStatusCode() !== 200) {
            throw new UserInfoException($responseData);
        }

        return $responseData;
    }
}