una/studio/classes/BxDolStudioOAuthLib.php

<?php defined('BX_DOL') or die('hack attempt');
/**
 * Copyright (c) BoonEx Pty Limited - http://www.boonex.com/
 * CC-BY License - http://creativecommons.org/licenses/by/3.0/
 *
 * @defgroup    DolphinStudio Dolphin Studio
 * @{
 */

bx_import('BxDolStudioOAuth');

class BxDolStudioOAuthLib extends BxDolStudioOAuth implements iBxDolSingleton
{
    public function __construct()
    {
        if (isset($GLOBALS['bxDolClasses'][get_class($this)]))
            trigger_error ('Multiple instances are not allowed for the class: ' . get_class($this), E_USER_ERROR);

        parent::__construct();

        $this->sKey = getParam('sys_oauth_key');
        $this->sSecret = getParam('sys_oauth_secret');
        $this->sDataRetrieveMethod = OAUTH_HTTP_METHOD_POST;
    }

    public function __clone()
    {
        if (isset($GLOBALS['bxDolClasses'][get_class($this)]))
            trigger_error('Clone is not allowed for the class: ' . get_class($this), E_USER_ERROR);
    }

    public static function getInstance()
    {
        if (!isset($GLOBALS['bxDolClasses'][__CLASS__])) {
            $sClass = __CLASS__;
            $GLOBALS['bxDolClasses'][__CLASS__] = new $sClass();
        }

        return $GLOBALS['bxDolClasses'][__CLASS__];
    }

    protected function authorize($sKey, $sSecret)
    {
        if($this->isAuthorized())
            return true;

        try {
            $oConsumer = new OAuth($sKey, $sSecret);
            $oConsumer->setAuthType(OAUTH_AUTH_TYPE_URI);
            $oConsumer->enableDebug();

            $bToken = bx_get('oauth_token') !== false;
            $mixedSecret = $this->oSession->getValue('sys_oauth_secret');
            if(!$bToken && $mixedSecret !== false) {
                $this->oSession->unsetValue('sys_oauth_secret');
                $mixedSecret = false;
            }

            //--- Get request token and redirect to authorize.
            if(!$bToken && $mixedSecret === false) {
                $aRequestToken = $oConsumer->getRequestToken(BX_DOL_OAUTH_URL_REQUEST_TOKEN);
                if(empty($aRequestToken))
                    return _t('_adm_err_oauth_cannot_get_token');

                if($this->isServerError($aRequestToken))
                    return $this->processServerError($aRequestToken);

                $this->oSession->setValue('sys_oauth_secret', $aRequestToken['oauth_token_secret']);
                return _t('_adm_msg_oauth_need_authorize', bx_append_url_params(BX_DOL_OAUTH_URL_AUTHORIZE, array('oauth_token' => $aRequestToken['oauth_token'], 'sid' => bx_site_hash())));
            }

            //--- Get access token.
            if($bToken && $mixedSecret !== false) {
                $oConsumer->setToken(bx_get('oauth_token'), $mixedSecret);
                $aAccessToken = $oConsumer->getAccessToken(bx_append_url_params(BX_DOL_OAUTH_URL_ACCESS_TOKEN, array('oauth_verifier' => bx_get('oauth_verifier'))));
                if(empty($aAccessToken))
                    return _t('_adm_err_oauth_cannot_get_token');

                if($this->isServerError($aAccessToken))
                    return $this->processServerError($aAccessToken);

                $this->oSession->setValue('sys_oauth_token', $aAccessToken['oauth_token']);
                $this->oSession->setValue('sys_oauth_secret', $aAccessToken['oauth_token_secret']);
                $this->oSession->setValue('sys_oauth_authorized', 1);
                $this->oSession->setValue('sys_oauth_authorized_user', (int)bx_get('oauth_user'));

                return true;
            }
        } catch(OAuthException $e) {
            return _t('_adm_err_oauth_cannot_get_token');
        }
    }

    protected function fetch($sKey, $sSecret, $aParams = array())
    {
        if(!$this->isAuthorized())
            return array();

        try {
            $oConsumer = new OAuth($sKey, $sSecret);
            $oConsumer->setAuthType(OAUTH_AUTH_TYPE_URI);
            $oConsumer->enableDebug();

            $oConsumer->setToken($this->oSession->getValue('sys_oauth_token'), $this->oSession->getValue('sys_oauth_secret'));
            $oConsumer->fetch(BX_DOL_OAUTH_URL_FETCH_DATA, $aParams, $this->sDataRetrieveMethod);

            
            //echo $oConsumer->getLastResponse(); exit;	//--- Uncomment to debug
            return json_decode($oConsumer->getLastResponse(), true);
        } catch(OAuthException $e) {
            return array();
        }
    }
}

/** @} */