| Server IP : 37.220.80.31 / Your IP : 3.22.240.164 Web Server : Apache/2.4.52 (Ubuntu) System : Linux 3051455-guretool.twc1.net 5.15.0-107-generic #117-Ubuntu SMP Fri Apr 26 12:26:49 UTC 2024 x86_64 User : www-root ( 1010) PHP Version : 7.4.33 Disable Function : pcntl_alarm,pcntl_fork,pcntl_waitpid,pcntl_wait,pcntl_wifexited,pcntl_wifstopped,pcntl_wifsignaled,pcntl_wexitstatus,pcntl_wtermsig,pcntl_wstopsig,pcntl_signal,pcntl_signal_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority, MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /var/www/www-root/data/www/dev.artlot24.ru/bitrix/components/bitrix/rest.apconnect/ |
Upload File : |
<?php
if(!defined("B_PROLOG_INCLUDED") || B_PROLOG_INCLUDED !== true)
{
die();
}
/**
* Bitrix vars
*
* @var array $arParams
* @var array $arResult
* @var CBitrixComponent $this
* @global CMain $APPLICATION
*/
use Bitrix\Main\Config\Option;
use Bitrix\Main\Context;
use Bitrix\Main\Error;
use Bitrix\Main\ErrorCollection;
use Bitrix\Main\Loader;
use Bitrix\Main\Localization\Loc;
use Bitrix\Main\SystemException;
use Bitrix\Rest\APAuth\PasswordTable;
use Bitrix\Rest\Engine\Access;
use Bitrix\Rest\Url\DevOps;
class CAPConnectComponent extends CBitrixComponent
{
const SESSION_KEY = 'APCONNECT_CLIENT_INFO';
const PATH_AP_MANAGE = '/marketplace/hook/ap/';
protected static $presetPermission = array(
'ap' => array('crm', 'telephony', 'imopenlines'),
);
protected $errors;
protected $clientInfo = null;
protected $clientAccess = array();
protected $isRestAvailable = false;
protected $landingCode = '';
public function __construct($component = null)
{
$this->errors = new ErrorCollection();
parent::__construct($component);
}
/**
* Load language file.
*/
public function onIncludeComponentLang()
{
$this->includeComponentLang(basename(__FILE__));
Loc::loadMessages(__FILE__);
}
/**
* Prepare Component Params.
*
* @param array $params Component parameters.
* @return array
*/
public function onPrepareComponentParams($params)
{
global $USER;
$params["USER_ID"] = intval($params["USER_ID"]);
$params["CLIENT_ID"] = trim($params["CLIENT_ID"]);
$params["CLIENT_STATE"] = trim($params["CLIENT_STATE"]);
if($params["USER_ID"] <= 0)
{
$params["USER_ID"] = $USER->GetID();
}
return $params;
}
protected function getConnectionData($password)
{
return array(
'ENDPOINT' => \CRestUtil::getWebhookEndpoint($password, $this->arParams['USER_ID']),
);
}
/**
* Process incoming request
* @return void
*/
protected function processRequest()
{
if ($this->arParams['USER_ID'] <= 0)
{
throw new SystemException(Loc::getMessage('APC_NOT_AUTHORIZED'));
}
if ($this->arParams['CLIENT_ID'] == '')
{
throw new SystemException(Loc::getMessage('APC_NO_CLIENT'));
}
$this->isRestAvailable = Access::isAvailable() && Access::isAvailableCount(Access::ENTITY_TYPE_AP_CONNECT);
if (!$this->isRestAvailable)
{
$this->landingCode = Access::getHelperCode(Access::ACTION_INSTALL, Access::ENTITY_TYPE_AP_CONNECT);
}
$request = Context::getCurrent()->getRequest();
if(isset($request['preset']) && array_key_exists($request['preset'], static::$presetPermission))
{
$this->clientAccess = static::$presetPermission[$request['preset']];
}
if ($request->isPost() && check_bitrix_sessid() && !empty($_SESSION[static::SESSION_KEY][$this->arParams['CLIENT_ID']]))
{
if ($this->isRestAvailable)
{
$clientInfo = $_SESSION[static::SESSION_KEY][$this->arParams['CLIENT_ID']];
$password = PasswordTable::createPassword($this->arParams['USER_ID'], $this->clientAccess, $clientInfo['TITLE']);
if ($password != false)
{
$connection = $this->getConnectionData($password);
$client = \CBitrix24NetPortalTransport::init();
$result = $client->call(
'client.authorize',
array(
'CLIENT_ID' => $clientInfo['CLIENT_ID'],
'CONNECTION' => $connection,
)
);
if (!$result['result'])
{
if ($result['error'])
{
throw new SystemException($result['error'].': '.$result['error_description']);
}
else
{
throw new SystemException(Loc::getMessage('APC_PASSWORD_NOT_REGISTERD'));
}
}
$url = $clientInfo['REDIRECT_URI'];
$url .= (mb_strpos($url, '?') !== false ? '&' : '?')
. http_build_query(
[
'apcode' => $result['result']['apcode'],
'state' => $this->arParams['CLIENT_STATE'],
]
);
unset($_SESSION[static::SESSION_KEY]);
LocalRedirect($url, true);
}
else
{
$this->errors[] = new Error(Loc::getMessage('APC_PASSWORD_NOT_CREATED'));
}
}
else
{
$this->errors[] = new Error(Loc::getMessage('APC_ERROR_REST_AVAILABLE'));
}
}
}
/**
* Check Required Modules
*
* @throws Exception
*/
protected function checkModules()
{
if(!Loader::includeModule('rest'))
{
throw new SystemException(Loc::getMessage('APC_REST_MODULE_NOT_INSTALLED'));
}
if(!Loader::includeModule('socialservices'))
{
throw new SystemException(Loc::getMessage('APC_SOCIALSERVICES_MODULE_NOT_INSTALLED'));
}
}
/**
* Get main data - client info
*
* @throws SystemException
*
* @return void
*/
protected function prepareData()
{
$query = \CBitrix24NetPortalTransport::init();
if(!$query)
{
throw new SystemException(Loc::getMessage('APC_TRANSPORT_INITIALIZE_FAILED'));
}
$clientId = $this->arParams['CLIENT_ID'];
$queryResult = $query->call('client.verify', array(
'CLIENT_ID' => $clientId,
));
if(!$queryResult)
{
throw new SystemException(Loc::getMessage('APC_VERIFY_REQUEST_FAILED'));
}
if($queryResult['error'])
{
switch($queryResult['error'])
{
case 'WRONG_CLIENT':
$errorText = Loc::getMessage('APC_ERROR_WRONG_CLIENT');
break;
case 'CLIENT_TYPE_NOT_ALLOWED':
$errorText = Loc::getMessage('APC_ERROR_CLIENT_TYPE_NOT_ALLOWED');
break;
default:
$errorText = $queryResult['error'].(!empty($queryResult['error_description']) ? ': '.$queryResult['error_description'] : '');
}
throw new SystemException($errorText);
}
$this->clientInfo = $queryResult['result'];
$_SESSION[static::SESSION_KEY] = array($clientId => $this->clientInfo);
}
/**
* Prepare data to render
*
* @return void
*/
protected function formatResult()
{
$this->arResult['CLIENT_INFO'] = $this->clientInfo;
$this->arResult['ERRORS'] = $this->errors;
$urlDevOps = DevOps::getInstance();
$this->arResult['AP_MANAGE_URL'] = $urlDevOps->getListUrl();
$this->arResult['CLIENT_ACCESS'] = $this->clientAccess;
$this->arResult['IS_REST_AVAILABLE'] = $this->isRestAvailable;
$this->arResult['LANDING_CODE'] = $this->landingCode;
}
/**
* Extract data from cache
* @return bool
*/
protected function extractDataFromCache()
{
return false;
}
protected function putDataToCache()
{
}
protected function abortDataCache()
{
}
public function executeComponent()
{
global $APPLICATION;
$APPLICATION->SetTitle(Loc::getMessage('APC_TITLE'));
try
{
$this->checkModules();
$this->processRequest();
if(!$this->extractDataFromCache())
{
$this->prepareData();
$this->formatResult();
$this->setResultCacheKeys(array());
$this->includeComponentTemplate();
$this->putDataToCache();
}
}
catch(SystemException $e)
{
$this->abortDataCache();
ShowError($e->getMessage());
}
}
}