Gbowo\Adapter\Amplifypay\Plugin\UnsubscribeCustomer

Complexity

Total Complexity

6

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	getPluginAccessor()	0	4	1
A	handle()	0	33	4

<?php

namespace Gbowo\Adapter\Amplifypay\Plugin;

use Gbowo\Plugin\AbstractPlugin;
use function GuzzleHttp\json_decode;
use function GuzzleHttp\json_encode;
use Gbowo\Adapter\Amplifypay\Traits\KeyVerifier;
use Gbowo\Exception\InvalidHttpResponseException;
use Gbowo\Exception\TransactionVerficationFailedException;

class UnsubscribeCustomer extends AbstractPlugin
{
    use KeyVerifier;

    const UN_SUBSCRIBE_LINK = "/subscription/cancel";

    /**
     * It's with a double `ll`
     * @see https://amplifypay.com/developers Unsubscribe a customer from plan
     * @var string
     */
    const STATUS_DESCRIPTION_SUCCESS = "Successfull Request";

    const STATUS_DESCRIPTION_FAILURE = "Unsuccessfull Request";

    protected $baseUrl;

    protected $apiKeys;

    public function __construct(string $baseUrl, array $apiKeys)
    {
        $this->baseUrl = $baseUrl;
        $this->apiKeys = $apiKeys;
    }

    public function getPluginAccessor() :string
    {
        return "unsubcribeCustomerFromPlan";
    }

    /**
     * @param array $args
     * @return mixed
     * @throws \Gbowo\Exception\TransactionVerficationFailedException
     * @throws \Gbowo\Exception\InvalidHttpResponseException if we don't get a 200 Status code
     */
    public function handle(array $args)
    {
        $link = $this->baseUrl . self::UN_SUBSCRIBE_LINK;

        $response = $this->adapter->getHttpClient()
            ->post(
                $link, [
                'body' => json_encode(array_merge($this->apiKeys, $args))
                ]
            );

        if ($response->getStatusCode() !== 200) {
            throw InvalidHttpResponseException::createFromResponse($response);
        }

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

        $validated = false;

        if (strcmp($res['StatusDesc'], self::STATUS_DESCRIPTION_SUCCESS) === 0) {
            $validated = true;
        }

        if (false === $validated) {
            throw TransactionVerficationFailedException::createFromResponse($response);
        }

        //not consistent, some transaction with the Amplifypay API returns `ApiKey`, some `apiKey`.

        $this->verifyKeys($res['apiKey'], $this->apiKeys['apiKey']);

        return $res;
    }
}