oauthtransport.php

См. документацию.

<?php
class CSocServOAuthTransport
{
    const SERVICE_ID = "generic";
 
    protected $appID;
    protected $appSecret;
    protected $code = false;
    protected $access_token = false;
    protected $accessTokenExpires = 0;
    protected $refresh_token = '';
 
    protected $scope = array();
 
    protected $userId;
 
    public function __construct($appID, $appSecret, $code = false)
    {
        global $USER;
 
        $this->httpTimeout = SOCSERV_DEFAULT_HTTP_TIMEOUT;
        $this->appID = $appID;
        $this->appSecret = $appSecret;
        $this->code = $code;
 
        if(is_object($USER) && $USER->IsAuthorized())
        {
            $this->userId = $USER->GetID();
        }
    }
 
    public function getAppID()
    {
        return $this->appID;
    }
 
    public function getAppSecret()
    {
        return $this->appSecret;
    }
 
    public function getAccessTokenExpires()
    {
        return $this->accessTokenExpires;
    }
 
    public function setAccessTokenExpires($accessTokenExpires)
    {
        $this->accessTokenExpires = $accessTokenExpires;
    }
 
    public function getToken()
    {
        return $this->access_token;
    }
 
    public function setToken($access_token)
    {
        $this->access_token = $access_token;
    }
 
    public function setRefreshToken($refresh_token)
    {
        $this->refresh_token = $refresh_token;
    }
 
    public function getRefreshToken()
    {
        return $this->refresh_token;
    }
 
    public function removeScope(string $scope): void
    {
        if (!$this->scope)
        {
            return;
        }
 
        $this->scope = array_diff($this->scope, [$scope]);
    }
 
    public function addScope($scope)
    {
        if(is_array($scope))
            $this->scope = array_merge($this->scope, $scope);
        else
            $this->scope[] = $scope;
        return $this;
    }
 
    public function setScope($scope)
    {
        $this->scope = $scope;
    }
 
    public function getScope()
    {
        return $this->scope;
    }
 
    public function getScopeEncode()
    {
        return implode(',', array_map('urlencode', array_unique($this->getScope())));
    }
 
    public function setCode($code)
    {
        $this->code = $code;
    }
 
    public function setUser($userId)
    {
        $this->userId = $userId;
    }
 
    protected function getStorageTokens()
    {
        $accessToken = '';
        if($this->userId > 0)
        {
            $dbSocservUser = \Bitrix\Socialservices\UserTable::getList([
                'filter' => [
                    '=USER_ID' => $this->userId,
                    "=EXTERNAL_AUTH_ID" => static::SERVICE_ID
                ],
                'select' => ["USER_ID", "XML_ID", "OATOKEN", "OATOKEN_EXPIRES", "REFRESH_TOKEN", "PERMISSIONS"]
            ]);
 
            $accessToken = $dbSocservUser->fetch();
        }
        return $accessToken;
    }
 
    public function deleteStorageTokens()
    {
        if($this->userId > 0)
        {
            $dbSocservUser = \Bitrix\Socialservices\UserTable::getList(array(
                'filter' => array(
                    '=USER_ID' => $this->userId,
                    "=EXTERNAL_AUTH_ID" => static::SERVICE_ID
                ),
                'select' => array("ID")
            ));
 
            while($accessToken = $dbSocservUser->fetch())
            {
                \Bitrix\Socialservices\UserTable::delete($accessToken['ID']);
            }
        }
    }
 
    public function checkAccessToken()
    {
        return (($this->accessTokenExpires - 30) < time()) ? false : true;
    }
 
    public function getResult()
    {
        return array();
    }
 
    protected function getDecodedJson($url, $postData = null)
    {
        $http = new \Bitrix\Main\Web\HttpClient([
            'socketTimeout' => $this->httpTimeout,
            'streamTimeout' => $this->httpTimeout,
        ]);
 
        if (isset($postData))
        {
            $postResult = $http->post($url, $postData);
        }
        else
        {
            $postResult = $http->get($url);
        }
 
        try
        {
            $decodedResult = \Bitrix\Main\Web\Json::decode($postResult);
        }
        catch (\Bitrix\Main\ArgumentException $e)
        {
            if (defined("BX_SOCIALSERVICES_ERROR_DEBUG"))
            {
                AddMessage2Log([
                    'post_url' => $http->getEffectiveUrl(),
                    'result_status' => $http->getStatus(),
                    'result_error' => $http->getError(),
                    'result_text' => $http->getResult(),
                ], 'socialservices', 40);
            }
            $decodedResult = [];
        }
 
        return $decodedResult;
    }
}