oxserversmanager.php

Go to the documentation of this file.

<?php

class oxServersManager
{

    const NODE_AVAILABILITY_CHECK_PERIOD = 86400;

    const INACTIVE_NODE_STORAGE_PERIOD = 259200;

    const CONFIG_NAME_FOR_SERVER_INFO = 'aServersData_';

    public function getServer($sServerId)
    {
        $aServerData = $this->getServerDataFromDb($sServerId);

        return $this->createServer($sServerId, $aServerData);
    }

    public function saveServer($oServer)
    {
        $aServerData = array(
            'id'                => $oServer->getId(),
            'timestamp'         => $oServer->getTimestamp(),
            'ip'                => $oServer->getIp(),
            'lastFrontendUsage' => $oServer->getLastFrontendUsage(),
            'lastAdminUsage'    => $oServer->getLastAdminUsage(),
            'isValid'           => $oServer->isValid()
        );
        $this->saveToDb($oServer->getId(), $aServerData);
    }

    protected function createServer($sServerId, $aData = array())
    {
        $oAppServer = oxNew('oxApplicationServer');

        $oAppServer->setId($sServerId);
        $oAppServer->setTimestamp($this->getServerParameter($aData, 'timestamp'));
        $oAppServer->setIp($this->getServerParameter($aData, 'serverIp'));
        $oAppServer->setLastFrontendUsage($this->getServerParameter($aData, 'lastFrontendUsage'));
        $oAppServer->setLastAdminUsage($this->getServerParameter($aData, 'lastAdminUsage'));
        $oAppServer->setIsValid($this->getServerParameter($aData, 'isValid'));

        return $oAppServer;
    }

    protected function getServerParameter($aData, $sName)
    {
        return array_key_exists($sName, $aData) ? $aData[$sName] : null;
    }

    public function getServers()
    {
        $aServersData = $this->getServersData();
        $aServersData = $this->markInActiveServers($aServersData);
        $aServersData = $this->deleteInActiveServers($aServersData);

        $aValidServers = array();

        foreach ($aServersData as $aServer) {
            if ($aServer['isValid']) {
                unset($aServer['isValid']);
                unset($aServer['timestamp']);
                $aValidServers[] = $aServer;
            }
        }

        return $aValidServers;
    }

    public function deleteServer($sServerId)
    {
        $oConfig = oxRegistry::getConfig();
        $sShopId = $oConfig->getBaseShopId();
        $sVarName = self::CONFIG_NAME_FOR_SERVER_INFO.$sServerId;
        $oDb = oxDb::getDb();
        $sQ = "DELETE FROM oxconfig WHERE oxvarname = ? and oxshopid = ?";
        $oDb->execute($sQ, array($sVarName, $sShopId));
    }

    public function markInActiveServers($aServersData = null)
    {
        foreach ($aServersData as $sServerId => $aServerData) {
            if ($aServerData['timestamp'] < oxRegistry::get("oxUtilsDate")->getTime() - self::NODE_AVAILABILITY_CHECK_PERIOD) {
                $oServer = $this->getServer($sServerId);
                $oServer->setIsValid(false);
                $this->saveServer($oServer);
                $aServersData[$sServerId]['isValid'] = false;
            }
        }
        return $aServersData;
    }

    public function deleteInActiveServers($aServersData)
    {
        foreach ($aServersData as $sServerId => $aServerData) {
            if ($aServerData['timestamp'] < oxRegistry::get("oxUtilsDate")->getTime() - self::INACTIVE_NODE_STORAGE_PERIOD) {
                $this->deleteServer($sServerId);
                unset($aServersData[$sServerId]);
            }
        }
        return $aServersData;
    }

    public function getServersData()
    {
        $aServersData = array();
        $result = $this->getAllServersDataConfigsFromDb();
        if ($result != false && $result->recordCount() > 0) {
            while (!$result->EOF) {
                $sServerId = $this->parseServerIdFromConfig($result->fields['oxvarname']);
                $aServersData[$sServerId] = (array)unserialize($result->fields['oxvarvalue']);
                $result->moveNext();
            }
        }
        return $aServersData;
    }

    private function parseServerIdFromConfig($sVarName)
    {
        $iConstNameLength = strlen(self::CONFIG_NAME_FOR_SERVER_INFO);
        $sId = substr($sVarName, $iConstNameLength);
        return $sId;
    }

    protected function getAllServersDataConfigsFromDb()
    {
        $oDb = oxDb::getDb(oxDb::FETCH_MODE_ASSOC);
        $oConfig = oxRegistry::getConfig();

        $sConfigsQuery = "SELECT oxvarname, " . $oConfig->getDecodeValueQuery() .
            " as oxvarvalue FROM oxconfig WHERE oxvarname like ? AND oxshopid = ?";

        return $oDb->select($sConfigsQuery, array(self::CONFIG_NAME_FOR_SERVER_INFO."%", $oConfig->getBaseShopId()));
    }

    protected function getServerDataFromDb($sServerId)
    {
        $aServerData = array();
        $sData = $this->getConfigValueFromDB(self::CONFIG_NAME_FOR_SERVER_INFO.$sServerId);

        if ($sData != false ) {
            $aServerData = (array)unserialize($sData);
        }
        return $aServerData;
    }

    private function getConfigValueFromDB($sVarName)
    {
        $oConfig = oxRegistry::getConfig();
        $oDb = oxDb::getDb();

        $sConfigsQuery = "SELECT " . $oConfig->getDecodeValueQuery() .
            " as oxvarvalue FROM oxconfig WHERE oxvarname = ? AND oxshopid = ?";

        $sResult = $oDb->getOne($sConfigsQuery, array($sVarName, $oConfig->getBaseShopId()), false);

        return $sResult;
    }

    protected function saveToDb($sServerId, $aServerData)
    {
        $oConfig = oxRegistry::getConfig();
        $sVarName = self::CONFIG_NAME_FOR_SERVER_INFO.$sServerId;
        $sConfigKey = $oConfig->getConfigParam('sConfigKey');
        $sValue = serialize($aServerData);
        $sVarType = 'arr';
        $sShopId = $oConfig->getBaseShopId();
        $oDb = oxDb::getDb();
        if ($this->getConfigValueFromDB($sVarName) !== false) {
            $sQ = "UPDATE oxconfig SET oxvarvalue=ENCODE( ?, ?) WHERE oxvarname = ? and oxshopid = ?";
            $oDb->execute($sQ, array($sValue, $sConfigKey, $sVarName, $sShopId));
        } else {
            $sOxid = oxUtilsObject::getInstance()->generateUID();

            $sQ = "insert into oxconfig (oxid, oxshopid, oxmodule, oxvarname, oxvartype, oxvarvalue)
               values(?, ?, '', ?, ?, ENCODE( ?, ?) )";
            $oDb->execute($sQ, array($sOxid, $sShopId, $sVarName, $sVarType, $sValue, $sConfigKey));
        }
    }
}