Audiens\DoubleclickClient\service\UserListClientService

Complexity

Total Complexity

14

Size/Duplication

Total Lines	127
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
B	createUserClientList()	0	47	7
B	getUserClientList()	0	39	6

<?php

namespace Audiens\DoubleclickClient\service;

use Audiens\DoubleclickClient\ApiConfigurationInterface;
use Audiens\DoubleclickClient\Auth;
use Audiens\DoubleclickClient\CachableTrait;
use Audiens\DoubleclickClient\CacheableInterface;
use Audiens\DoubleclickClient\entity\ApiResponse;
use Audiens\DoubleclickClient\entity\UserListClient;
use Audiens\DoubleclickClient\exceptions\ClientException;
use Doctrine\Common\Cache\Cache;
use GuzzleHttp\Client;
use GuzzleHttp\Exception\RequestException;

class UserListClientService implements CacheableInterface, ApiConfigurationInterface
{
    use CachableTrait;

    public const URL_LIST_CLIENT          = 'https://ddp.googleapis.com/api/ddp/provider/'.self::API_VERSION.'/UserListClientService?wsdl';
    public const USER_LIST_CLIENT_TPL     = 'userListClient.xml.twig';
    public const GET_USER_CLIENT_LIST_TPL = 'getUserClientList.xml.twig';

    /** @var Client|Auth */
    protected $client;

    /** @var Cache */
    protected $cache;

    /** @var TwigCompiler */
    protected $twigCompiler;

    /** @var string */
    protected $clientCustomerId;

    public function __construct($client, Cache $cache = null, TwigCompiler $twigCompiler, $clientCustomerId)
    {
        $this->client           = $client;
        $this->cache            = $cache;
        $this->twigCompiler     = $twigCompiler;
        $this->clientCustomerId = $clientCustomerId;
    }

    public function createUserClientList(UserListClient $client, $updateIfExist = false): UserListClient
    {
        $operator = 'ADD';

        if ($updateIfExist) {
            $operator = 'SET';
        }

        $context = [
            'status' => $client->getStatus(),
            'userlistid' => $client->getUserlistid(),
            'operator' => $operator,
            'clientCustomerId' => $this->clientCustomerId,
            'clientid' => $client->getClientid(),
        ];

        if ($client->getPricingInfo()) {
            $context['pricingInfo'] = $client->getPricingInfo();
        }

        if ($client->getClientproduct()) {
            $context['clientproduct'] = $client->getClientproduct();
        }

        $requestBody = $this->twigCompiler->getTwig()->render(
            self::API_VERSION.'/'.self::USER_LIST_CLIENT_TPL,
            $context
        );

        try {
            $response = $this->client->request('POST', self::URL_LIST_CLIENT, ['body' => $requestBody]);
        } catch (RequestException $e) {
            $response = $e->getResponse();
        }

        $apiResponse = ApiResponse::fromResponse($response);

        if (!$apiResponse->isSuccessful()) {
            throw ClientException::failed($apiResponse);
        }

        if (!isset($apiResponse->getResponseArray()['body']['envelope']['body']['mutateresponse']['rval']['value'])) {
            throw ClientException::failed($apiResponse);
        }

        return UserListClient::fromArray($apiResponse->getResponseArray()['body']['envelope']['body']['mutateresponse']['rval']['value']);
    }

    /**
     * @param null|string $userListId
     * @param null|string $clientId
     *
     * @return UserListClient[]|UserListClient
     * @throws ClientException
     * @throws \GuzzleHttp\Exception\GuzzleException
     * @throws \Twig_Error_Loader
     * @throws \Twig_Error_Runtime
     * @throws \Twig_Error_Syntax
     */
    public function getUserClientList($userListId = null, $clientId = null)
    {
        $compiledUrl = self::URL_LIST_CLIENT;

        $requestBody = $this->twigCompiler->getTwig()->render(
            self::API_VERSION.'/'.self::GET_USER_CLIENT_LIST_TPL,
            [
                'clientCustomerId' => $this->clientCustomerId,
                'userlistid' => $userListId,
                'clientId' => $clientId,
            ]
        );

        try {
            $response = $this->client->request('POST', $compiledUrl, ['body' => $requestBody]);
        } catch (RequestException $e) {
            $response = $e->getResponse();
        }

        $repositoryResponse = ApiResponse::fromResponse($response);

        if (!$repositoryResponse->isSuccessful()) {
            throw ClientException::failed($repositoryResponse);
        }

        $entries = $repositoryResponse->getResponseArray()['body']['envelope']['body']['getresponse']['rval']['entries'] ?? [];

        if (\is_array($entries) && isset($entries['userlistid'])) {
            return UserListClient::fromArray($entries);
        }

        $licenses = [];

        foreach ($entries as $entry) {
            $licenses[] = UserListClient::fromArray($entry);
        }

        return $licenses;
    }
}