request.php

<?
 
namespace Bitrix\Seo\Retargeting;
 
use Bitrix\Main\Error;
use Bitrix\Main\SystemException;
use Bitrix\Seo\Retargeting\Internals\ServiceLogTable;
 
abstract class Request
{
    const TYPE_CODE = '';
 
    protected $adapter;
 
    protected $client;
 
    protected $response;
 
    protected $type;
 
    protected $endpoint;
 
    protected $useDirectQuery = false;
 
    public function __construct()
    {
        $this->type = static::TYPE_CODE;
 
        $options = array(
            'socketTimeout' => 5
        );
        $this->client = new AdsHttpClient($options);
    }
 
    public function setUseDirectQuery($mode)
    {
        $this->useDirectQuery = $mode;
    }
 
    public function getAuthAdapter()
    {
        return $this->adapter;
    }
 
    public function setAuthAdapter(AuthAdapter $adapter)
    {
        $this->adapter = $adapter;
        return $this;
    }
 
    public function getResponse()
    {
        return $this->response;
    }
 
    public function getClient()
    {
        return $this->client;
    }
 
    public function setClient(AdsHttpClient $client)
    {
        $this->client = $client;
        return $this;
    }
 
    public function getEndpoint()
    {
        return $this->endpoint;
    }
 
    public static function create($type)
    {
        return Factory::create(get_called_class(), $type);
    }
 
    public function send(array $params = array())
    {
        if (!$this->adapter)
        {
            throw new SystemException('AuthAdapter not applied.');
        }
        $this->client = $this->client ?? new AdsHttpClient(['socketTimeout' => 5]);
        $this->client->clearHeaders();
 
        $response = Response::create($this->type);
        $response->setRequest($this);
        try
        {
            $data = $this->query($params);
            $response->setResponseText($data);
            $response->parse($data);
        }
        catch (\Exception $exception)
        {
            $response->addError(new Error($exception->getMessage(), $exception->getCode()));
        }
 
        if ($response->getErrorCollection()->count() > 0)
        {
            $errors = $response->getErrors();
            foreach ($errors as $error)
            {
                if (!$error->getMessage())
                {
                    continue;
                }
 
                ServiceLogTable::add(array(
                    'GROUP_ID' => 'retargeting',
                    'TYPE' => static::TYPE_CODE,
                    'CODE' => $error->getCode(),
                    'MESSAGE' => $error->getMessage()
                ));
            }
        }
 
 
        return $response;
    }
 
    abstract public function query(array $params = array());
 
    protected function directQuery(array $params = array())
    {
        return [];
    }
}