una/studio/classes/BxDolStudioStore.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('BxTemplStudioPage');
bx_import('BxDolStudioStoreQuery');

define('BX_DOL_STUDIO_STR_TYPE_DEFAULT', 'downloaded');

class BxDolStudioStore extends BxTemplStudioPage {
    protected $sPage;
    protected $aContent;

    protected $iClient;

    protected $aAlias;

    function __construct($sPage = "") {
        parent::__construct('store');

        $this->oDb = new BxDolStudioStoreQuery();

        $this->aAlias = array(
        	'tag' => array(
        		'modules' => 'extensions',
        		'languages' => 'translations'
        	),
        	'category' => array()
        );

        $this->sPage = BX_DOL_STUDIO_STR_TYPE_DEFAULT;
        if(is_string($sPage) && !empty($sPage))
            $this->sPage = $sPage;

		bx_import('BxDolStudioOAuth');
        $this->iClient = BxDolStudioOAuth::getAuthorizedClient();

        //--- Check actions ---//
        if(($sAction = bx_get('str_action')) !== false) {
	        $sAction = bx_process_input($sAction);

            $aResult = array('code' => 1, 'message' => _t('_adm_mod_err_cannot_process_action'));
	        switch($sAction) {
	        	/*
	        	 * NOTE. Is needed for download popup selector. Isn't used for now.
	        	 */
	        	case 'get-files':
			    	$iId = (int)bx_get('str_id');
			    	$sType = bx_process_input(bx_get('str_type'));
			        $aResult = $this->getFiles($iId, $sType);
			    	break;

	        	case 'get-file':
	        		$iId = (int)bx_get('str_id');
	        		$aResult = $this->getFile($iId);
	        		break;

				case 'get-product':
	        		$iId = (int)bx_get('str_id');
	        		$aResult = $this->getProduct($iId);
	        		break;

	            case 'get-products-by-type':
	                $this->sPage = bx_process_input(bx_get('str_value'));

	                $sContent = $this->getPageCode();
	                if(!empty($sContent))
						$aResult = array('code' => 0, 'content' => $sContent);
					else
						$aResult = array('code' => 1, 'message' => _t('_adm_act_err_failed_page_loading'));
	                break;

	            case 'get-products-by-page':
	            	$this->sPage = bx_process_input(bx_get('str_type'));

	            	$sContent = $this->getPageContent();
	            	if(!empty($sContent))
	            		$aResult = array('code' => 0, 'content' => $sContent);
	            	else 
	            		$aResult = array('code' => 1, 'message' => _t('_adm_act_err_failed_page_loading'));
	            	break;

	            case 'add-to-cart':
	            	$sVendor = bx_process_input(bx_get('str_vendor'));
	            	$iItem = (int)bx_get('str_item');
	            	$iItemCount = 1;

	            	if(empty($sVendor) || empty($iItem)) {
	            		$aResult = array('code' => 1, 'message' => _t('_adm_err_modules_cannot_add_to_cart'));
	            		break;
	            	}

	            	bx_import('BxDolStudioCart');
	            	BxDolStudioCart::getInstance()->add($sVendor, $iItem, $iItemCount);
	            	$aResult = array('code' => 0, 'message' => _t('_adm_msg_modules_success_added_to_cart'));
	            	break;

	            case 'delete-from-cart':
	            	$sVendor = bx_process_input(bx_get('str_vendor'));
	            	$iItem = (int)bx_get('str_item');

		        	if(empty($sVendor)) {
	            		$aResult = array('code' => 1, 'message' => _t('_adm_err_modules_cannot_delete_from_cart'));
	            		break;
	            	}

	            	bx_import('BxDolStudioCart');
	            	BxDolStudioCart::getInstance()->delete($sVendor, $iItem);
	            	$aResult = array('code' => 0, 'message' => '');
	            	break;

	            case 'checkout-cart':
	            	$sVendor = bx_process_input(bx_get('str_vendor'));
	        		if(empty($sVendor)) {
	            		$aResult = array('code' => 1, 'message' => _t('_adm_err_modules_cannot_checkout_empty_vendor'));
	            		break;
	            	}

	            	$sLocation = $this->checkoutCart($sVendor);
					$aResult = array('code' => 0, 'message' => '', 'redirect' => $sLocation);
	            	break;

	        	case 'install':
	        	    $sValue = bx_process_input(bx_get('str_value'));
	        	    if(empty($sValue))
	                    break;

                    bx_import('BxDolStudioInstallerUtils');
	        		$aResult = BxDolStudioInstallerUtils::getInstance()->perform($sValue, 'install');
	        		break;

				case 'update':
	        	    $sValue = bx_process_input(bx_get('str_value'));
	        	    if(empty($sValue))
	                    break;

                    bx_import('BxDolStudioInstallerUtils');
	        		$aResult = BxDolStudioInstallerUtils::getInstance()->perform($sValue, 'update');
	        		break;

				case 'delete':
	        	    $sValue = bx_process_input(bx_get('str_value'));
	        	    if(empty($sValue))
	                    break;

                    bx_import('BxDolStudioInstallerUtils');
	        		$aResult = BxDolStudioInstallerUtils::getInstance()->perform($sValue, 'delete');
	        		break;
	        }

	        if(!empty($aResult['message'])) {
                bx_import('BxDolStudioTemplate');
                $aResult['message'] = BxDolStudioTemplate::getInstance()->parseHtmlByName('mod_action_result.html', array('content' => $aResult['message']));

                bx_import('BxTemplStudioFunctions');
                $aResult['message'] = BxTemplStudioFunctions::getInstance()->transBox('', $aResult['message']);
            }

	        $oJson = new Services_JSON();		        
            echo $oJson->encode($aResult);
            exit;
        }
    }

    protected function loadGoodies() {
    	$iPerPage = 5;
        $aProducts = array();
        $sJsObject = $this->getPageJsObject();

        bx_import('BxDolStudioJson');
        $oJson = BxDolStudioJson::getInstance();

        // Load featured
        $aProducts[] = array(
            'caption' => '_adm_block_cpt_last_featured',
            'actions' => array(
                array('name' => 'featured', 'caption' => '_adm_action_cpt_see_all_featured', 'url' => 'javascript:void(0)', 'onclick' => $sJsObject . ".changePage('featured', this)")
            ), 
            'items' => $oJson->load(BX_DOL_UNITY_URL_MARKET . 'json_browse_featured', array('start' => 0, 'per_page' => $iPerPage, 'client' => $this->iClient))
        );

        
        // Load modules
        $aProducts[] = array(
            'caption' => '_adm_block_cpt_last_modules',
            'actions' => array(
                array('name' => 'modules', 'caption' => '_adm_action_cpt_see_all_modules', 'url' => 'javascript:void(0)', 'onclick' => $sJsObject . ".changePage('modules', this)")
            ), 
            'items' => $oJson->load(BX_DOL_UNITY_URL_MARKET . 'json_browse_by_tag', array('value' => 'extensions', 'start' => 0, 'per_page' => $iPerPage, 'client' => $this->iClient))
        );

        // Load templates
        $aProducts[] = array(
            'caption' => '_adm_block_cpt_last_templates',
            'actions' => array(
                array('name' => 'templates', 'caption' => '_adm_action_cpt_see_all_templates', 'url' => 'javascript:void(0)', 'onclick' => $sJsObject . ".changePage('templates', this)")
            ), 
            'items' => $oJson->load(BX_DOL_UNITY_URL_MARKET . 'json_browse_by_tag', array('value' => 'templates', 'start' => 0, 'per_page' => $iPerPage, 'client' => $this->iClient))
        );

        // Load languages
        $aProducts[] = array(
            'caption' => '_adm_block_cpt_last_languages',
            'actions' => array(
                array('name' => 'languages', 'caption' => '_adm_action_cpt_see_all_languages', 'url' => 'javascript:void(0)', 'onclick' => $sJsObject . ".changePage('languages', this)")
            ), 
            'items' => $oJson->load(BX_DOL_UNITY_URL_MARKET . 'json_browse_by_tag', array('value' => 'translations', 'start' => 0, 'per_page' => $iPerPage, 'client' => $this->iClient))
        );

        return $aProducts;
    }

    protected function loadFeatured($iStart, $iPerPage) {
    	bx_import('BxDolStudioJson');
        return BxDolStudioJson::getInstance()->load(BX_DOL_UNITY_URL_MARKET . 'json_browse_featured', array('start' => $iStart, 'per_page' => $iPerPage, 'client' => $this->iClient));
    }

	protected function loadTag($sTag, $iStart, $iPerPage) {
    	bx_import('BxDolStudioJson');
        return BxDolStudioJson::getInstance()->load(BX_DOL_UNITY_URL_MARKET . 'json_browse_by_tag', array('value' => $this->aliasToNameTag($sTag), 'start' => $iStart, 'per_page' => $iPerPage, 'client' => $this->iClient));
    }

	protected function loadPurchases() {
    	bx_import('BxDolStudioOAuth');
        return BxDolStudioOAuth::getInstance()->loadItems(array('dol_type' => 'purchased_products'));
    }

	protected function loadUpdates() {
        bx_import('BxDolModuleQuery');
        $oModules = BxDolModuleQuery::getInstance();
        $aModules = $oModules->getModules();

        $aParams = array();
        foreach($aModules as $aModule) {
        	if(!isset($aModule['name']) || empty($aModule['name']))
        		continue;

			$aParams[] = array(
				'name' => $aModule['name'],
				'version' => $aModule['version'],
			);
        }

        bx_import('BxDolStudioOAuth');
        return BxDolStudioOAuth::getInstance()->loadItems(array('dol_type' => 'available_updates', 'dol_products' => base64_encode(serialize($aParams))));
    }

    protected function loadCheckout() {
    	bx_import('BxDolStudioJson');
    	$oJson = BxDolStudioJson::getInstance();

    	bx_import('BxDolStudioCart');
		$aVendors = BxDolStudioCart::getInstance()->parseByVendor();

		$aResult = array();
		foreach($aVendors as $sVendor => $aItems) {
			$aIds = $aCounts = array();
			foreach($aItems as $aItem) {
				$aIds[] = $aItem['item_id'];
				$aCounts[$aItem['item_id']] = $aItem['item_count'];
			}

			$aProducts = $oJson->load(BX_DOL_UNITY_URL_MARKET . 'json_browse_selected', array('products' => base64_encode(serialize($aIds))));
			if(!empty($aProducts))
				$aResult[$sVendor] = array(
					'ids' => $aIds,
					'counts' => $aCounts,
					'products' => $aProducts
				);
		}

        return $aResult;
    }

    protected function loadDownloaded() {
    	bx_import('BxDolStudioInstallerUtils');
    	$oInstallerUtils = BxDolStudioInstallerUtils::getInstance();

        return array(
        	'modules' => $oInstallerUtils->loadModules(),
        	'updates' => $oInstallerUtils->loadUpdates()
        );
    }

    protected function loadProduct($iId) {
    	bx_import('BxDolStudioJson');
        $oJson = BxDolStudioJson::getInstance();

        return $oJson->load(BX_DOL_UNITY_URL_MARKET . 'json_get_product_by_id', array('value' => $iId, 'client' => $this->iClient));
    }

    /*
     * NOTE. Is needed for download popup selector. Isn't used for now.
     */
    protected function loadFiles($iId, $sType) {
    	bx_import('BxDolStudioOAuth');
        return BxDolStudioOAuth::getInstance()->loadItems(array('dol_type' => 'product_files', 'dol_product_id' => $iId, 'dol_file_type' => $sType));
    }

	protected function loadFile($iId) {
    	bx_import('BxDolStudioOAuth');
        $aItem = BxDolStudioOAuth::getInstance()->loadItems(array('dol_type' => 'product_file', 'dol_file_id' => $iId));
		if(empty($aItem) || !is_array($aItem))
			return $aItem;

		//--- write ZIP archive.
		$sFilePath = BX_DIRECTORY_PATH_TMP . $aItem['name'];
		if (!$rHandler = fopen($sFilePath, 'w'))
			return _t('_adm_str_err_cannot_write');

		if (!fwrite($rHandler, urldecode($aItem['content'])))
			return _t('_adm_str_err_cannot_write');

    	fclose($rHandler);

    	//--- Unarchive package.
    	if(!class_exists('ZipArchive'))
            return _t('_adm_str_err_zip_not_available');

		$oZip = new ZipArchive();
		if($oZip->open($sFilePath) !== true)
        	return _t('_adm_str_err_cannot_unzip_package');

        $sPackageRootFolder = $oZip->numFiles > 0 ? $oZip->getNameIndex(0) : false;
		if($sPackageRootFolder && file_exists(BX_DIRECTORY_PATH_TMP . $sPackageRootFolder)) // remove existing tmp folder with the same name
        	bx_rrmdir(BX_DIRECTORY_PATH_TMP . $sPackageRootFolder);

		if($sPackageRootFolder && !$oZip->extractTo(BX_DIRECTORY_PATH_TMP))
        	return _t('_adm_str_err_cannot_unzip_package');

		$oZip->close();

		//--- Move unarchived package.
		$sLogin = getParam('sys_ftp_login');
		$sPassword = getParam('sys_ftp_password');
		$sPath = getParam('sys_ftp_dir');
		if(empty($sLogin) || empty($sPassword) || empty($sPath))
			return _t('_adm_str_err_no_ftp_info');

		bx_import('BxDolFtp');
		$oFtp = new BxDolFtp($_SERVER['HTTP_HOST'], $sLogin, $sPassword, $sPath);

		if(!$oFtp->connect())
        	return _t('_adm_str_err_cannot_connect_to_ftp');

		if(!$oFtp->isDolphin())
			return _t('_adm_str_err_destination_not_valid');

		$sConfigPath = BX_DIRECTORY_PATH_TMP . $sPackageRootFolder . '/install/config.php';
		if(!file_exists($sConfigPath))
			return _t('_adm_str_err_wrong_package_format');

		include($sConfigPath);
		if(empty($aConfig) || empty($aConfig['home_dir']) || !$oFtp->copy(BX_DIRECTORY_PATH_TMP . $sPackageRootFolder . '/', 'modules/' . $aConfig['home_dir']))
			return _t('_adm_str_err_ftp_copy_failed');

        return true;
    }

    private function checkoutCart($sVendor) {
    	bx_import('BxDolStudioCart');
		$oCart = BxDolStudioCart::getInstance();

		$aItems = $oCart->getByVendor($sVendor);
		if(empty($aItems) || !is_array($aItems))
			return false;

		$aIds = array();
		foreach($aItems as $aItem)
			$aIds[] = $aItem['item_id'];

		$sSid = bx_site_hash();
		return BX_DOL_UNITY_URL_MARKET . 'purchase/' . $sVendor . '?sid=' . $sSid . '&products=' . base64_encode(implode(',', $aIds));
    }

    private function aliasToNameTag($sAlias) {
    	return $this->aliasToName('tag', $sAlias);
    }

	private function aliasToNameCategory($sAlias) {
    	return $this->aliasToName('category', $sAlias);
    }

    private function aliasToName($sType, $sAlias) {
    	return isset($this->aAlias[$sType][$sAlias]) ? $this->aAlias[$sType][$sAlias] : $sAlias;
    }
}

/** @} */