Payever\ExternalIntegration\ThirdParty\ThirdPartyApiClient

Complexity

Total Complexity

10

Size/Duplication

Total Lines	132
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	getBusinessInfoUrl()	0	3	1
A	fillSubscriptionEntityFromConfiguration()	0	7	3
A	getSubscriptionStatus()	0	14	1
A	subscribe()	0	16	1
A	getConnectionUrl()	0	9	1
A	unsubscribe()	0	14	1
A	getBusinessRequest()	0	12	1
A	getIntegrationUrl()	0	9	1

<?php

/**
 * PHP version 5.4 and 8
 *
 * @category  ThirdParty
 * @package   Payever\ThirdParty
 * @author    payever GmbH <service@payever.de>
 * @author    Hennadii.Shymanskyi <gendosua@gmail.com>
 * @copyright 2017-2021 payever GmbH
 * @license   MIT <https://opensource.org/licenses/MIT>
 * @link      https://docs.payever.org/shopsystems/api/getting-started
 */

namespace Payever\ExternalIntegration\ThirdParty;

use Payever\ExternalIntegration\Core\CommonProductsThirdPartyApiClient;
use Payever\ExternalIntegration\Core\Http\RequestBuilder;
use Payever\ExternalIntegration\Core\Http\ResponseEntity\DynamicResponse;
use Payever\ExternalIntegration\ThirdParty\Base\ThirdPartyApiClientInterface;
use Payever\ExternalIntegration\ThirdParty\Http\RequestEntity\SubscriptionRequestEntity;
use Payever\ExternalIntegration\ThirdParty\Http\ResponseEntity\BusinessResponseEntity;
use Payever\ExternalIntegration\ThirdParty\Http\ResponseEntity\SubscriptionResponseEntity;

class ThirdPartyApiClient extends CommonProductsThirdPartyApiClient implements ThirdPartyApiClientInterface
{
    const SUB_URL_BUSINESS_INFO = 'api/business/%s/plugins';
    const SUB_URL_CONNECTION = 'api/business/%s/connection/authorization/%s';
    const SUB_URL_INTEGRATION = 'api/business/%s/integration/%s';

    /**
     * @inheritdoc
     */
    public function getBusinessRequest()
    {
        $this->configuration->assertLoaded();

        $request = RequestBuilder::get($this->getBusinessInfoUrl($this->configuration->getBusinessUuid()))
            ->addRawHeader(
                $this->getToken()->getAuthorizationString()
            )
            ->setResponseEntity(new BusinessResponseEntity())
            ->build();

        return $this->executeRequest($request);
    }

    /**
     * @inheritdoc
     */
    public function getSubscriptionStatus(SubscriptionRequestEntity $requestEntity)
    {
        $this->configuration->assertLoaded();

        $this->fillSubscriptionEntityFromConfiguration($requestEntity);

        $request = RequestBuilder::get($this->getConnectionUrl($requestEntity))
            ->addRawHeader(
                $this->getToken()->getAuthorizationString()
            )
            ->setResponseEntity(new SubscriptionResponseEntity())
            ->build();

        return $this->executeRequest($request);
    }

    /**
     * @inheritdoc
     */
    public function subscribe(SubscriptionRequestEntity $requestEntity)
    {
        $this->configuration->assertLoaded();

        $this->fillSubscriptionEntityFromConfiguration($requestEntity);

        $request = RequestBuilder::post($this->getIntegrationUrl($requestEntity))
            ->contentTypeIsJson()
            ->addRawHeader(
                $this->getToken()->getAuthorizationString()
            )
            ->setRequestEntity($requestEntity)
            ->setResponseEntity(new SubscriptionResponseEntity())
            ->build();

        return $this->executeRequest($request);
    }

    /**
     * @inheritdoc
     */
    public function unsubscribe(SubscriptionRequestEntity $requestEntity)
    {
        $this->configuration->assertLoaded();

        $this->fillSubscriptionEntityFromConfiguration($requestEntity);

        $request = RequestBuilder::delete($this->getConnectionUrl($requestEntity))
            ->addRawHeader(
                $this->getToken()->getAuthorizationString()
            )
            ->setResponseEntity(new DynamicResponse())
            ->build();

        return $this->executeRequest($request);
    }

    /**
     * @param string $businessUuid
     *
     * @return string
     */
    protected function getBusinessInfoUrl($businessUuid)
    {
        return $this->getBaseUrl() . sprintf(static::SUB_URL_BUSINESS_INFO, $businessUuid);
    }

    /**
     * @param SubscriptionRequestEntity $requestEntity
     * @return string
     */
    protected function getConnectionUrl(SubscriptionRequestEntity $requestEntity)
    {
        $path = sprintf(
            static::SUB_URL_CONNECTION,
            $requestEntity->getBusinessUuid(),
            $requestEntity->getExternalId()
        );

        return $this->getBaseUrl() . $path;
    }

    /**
     * @param SubscriptionRequestEntity $requestEntity
     * @return string
     */
    protected function getIntegrationUrl(SubscriptionRequestEntity $requestEntity)
    {
        $path = sprintf(
            static::SUB_URL_INTEGRATION,
            $requestEntity->getBusinessUuid(),
            $requestEntity->getThirdPartyName()
        );

        return $this->getBaseUrl() . $path;
    }

    /**
     * @param SubscriptionRequestEntity $requestEntity
     */
    private function fillSubscriptionEntityFromConfiguration(SubscriptionRequestEntity $requestEntity)
    {
        if (!$requestEntity->getBusinessUuid()) {
            $requestEntity->setBusinessUuid($this->configuration->getBusinessUuid());
        }
        if (!$requestEntity->getThirdPartyName()) {
            $requestEntity->setThirdPartyName($this->configuration->getChannelSet());
        }
    }
}