baseapiobject.php

<?
 
namespace Bitrix\Sender\Integration\Yandex\Toloka;
 
use Bitrix\Main\Web\HttpClient;
use Bitrix\Sender\Integration\Yandex\Toloka\Exception\AccessDeniedException;
use Bitrix\Seo\Analytics\Service;
use Bitrix\Seo\Engine\YandexJson;
use COption;
 
if(!defined("BITRIX_CLOUD_ADV_URL"))
{
    define("BITRIX_CLOUD_ADV_URL", 'https://cloud-adv.bitrix.info');
}
 
if(!defined("SEO_BITRIX_API_URL"))
{
    define("SEO_BITRIX_API_URL", BITRIX_CLOUD_ADV_URL."/rest/");
}
 
abstract class BaseApiObject
{
    private const API_URL = SEO_BITRIX_API_URL;
    protected $result;
    protected $accessToken;
    protected $clientId;
    protected $clientSecret;
 
    private function checkResult(): void
    {
        $errorCode = $this->result['error'] ?? $this->result['code']?? false;
 
        if(!$errorCode)
        {
            return;
        }
 
        switch ($errorCode)
        {
            case 'verification_needed':
            case 'ACCESS_DENIED':
                COption::RemoveOption('sender', ApiRequest::ACCESS_CODE);
                throw new AccessDeniedException();
                break;
        }
    }
 
    public function getAccessToken()
    {
        return $this->accessToken;
    }
 
    public function setAccessToken($accessToken)
    {
        $this->accessToken = $accessToken;
 
        return $this;
    }
 
    public function getClientId()
    {
        return $this->clientId;
    }
 
    public function setClientId($clientId)
    {
        $this->clientId = $clientId;
 
        return $this;
    }
 
    public function getClientSecret()
    {
        return $this->clientSecret;
    }
 
    public function setClientSecret($clientSecret)
    {
        $this->clientSecret = $clientSecret;
 
        return $this;
    }
 
    protected function sendRequest($data = [])
    {
        $scope = static::getScope().$data['methodName']??'';
 
        $httpResult =  $this
            ->query($scope, $data['parameters']??[])
            ->getResult();
 
        $httpResult = $httpResult ?
            YandexJson::decode($httpResult) : [];
 
        $this->result = isset($httpResult['result']) ?
            YandexJson::decode($httpResult['result']) :
            $httpResult
        ;
 
        $this->checkResult();
    }
    protected function registerOnCloudAdv()
    {
        $authAdapter = Service::getInstance()->getAuthAdapter(Service::TYPE_YANDEX);
 
        $http = new HttpClient();
        $http->setRedirect(false);
        $http->get($authAdapter->getAuthUrl());
    }
 
    protected function query($scope, $param = NULL)
    {
        if ($param === NULL)
        {
            $param = array();
        }
 
        $http = new HttpClient();
        $http->setRedirect(false);
 
        $postData = array(
            "access_code" => $this->accessToken,
            "client_id" => $this->clientId,
            "client_secret" => $this->clientSecret,
            "data" => json_encode($param, JSON_UNESCAPED_UNICODE)
        );
 
        if (!empty($param))
        {
            $postData = array_merge($postData, $param);
        }
 
        $http->post(self::API_URL.$scope, $postData, false);
 
        return $http;
    }
 
    abstract function getScope():string;
}