oxserversmanager.php

Go to the documentation of this file.

<?php

class oxServersManager
{

    const NODE_AVAILABILITY_CHECK_PERIOD = 86400;

    const INACTIVE_NODE_STORAGE_PERIOD = 259200;

    private $_aServersData = array();

    public function __construct()
    {
        $this->_aServersData = (array) oxRegistry::getConfig()->getConfigParam('aServersData');
    }

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

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

    public function saveServer($oServer)
    {
        $aServersData = $this->_getServersData();
        $aServersData[$oServer->getId()] = array(
            'id'                => $oServer->getId(),
            'timestamp'         => $oServer->getTimestamp(),
            'ip'                => $oServer->getIp(),
            'lastFrontendUsage' => $oServer->getLastFrontendUsage(),
            'lastAdminUsage'    => $oServer->getLastAdminUsage(),
            'isValid'           => $oServer->isValid()
        );

        $this->_save($aServersData);
    }

    protected function _getServersData()
    {
        return $this->_aServersData;
    }

    protected function _getServerData($sServerId)
    {
        $aServers = $this->_getServersData();

        return array_key_exists($sServerId, $aServers) ? $aServers[$sServerId] : array();
    }

    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()
    {
        $this->markInActiveServers();
        $this->deleteInActiveServers();

        $aServers = $this->_getServersData();
        $aValidServers = array();

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

        return $aValidServers;
    }

    public function deleteServer($sServerId)
    {
        $aServersData = $this->_getServersData();
        unset($aServersData[$sServerId]);
        $this->_save($aServersData);
    }

    public function markInActiveServers()
    {
        $aServersData = $this->_getServersData();

        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);
            }
        }
    }

    public function deleteInActiveServers()
    {
        $aServersData = $this->_getServersData();

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

    protected function _save($aServersData)
    {
        oxRegistry::getConfig()->saveSystemConfigParameter('arr', 'aServersData', $aServersData);
        $this->_aServersData = $aServersData;
    }
}