ifhub.club/engine/classes/Engine.class.php

<?php
/*-------------------------------------------------------
*
*   LiveStreet Engine Social Networking
*   Copyright © 2008 Mzhelskiy Maxim
*
*--------------------------------------------------------
*
*   Official site: www.livestreet.ru
*   Contact e-mail: rus.engine@gmail.com
*
*   GNU General Public License, version 2:
*   http://www.gnu.org/licenses/old-licenses/gpl-2.0.html
*
---------------------------------------------------------
*/

set_include_path(get_include_path().PATH_SEPARATOR.dirname(__FILE__));
require_once(Config::Get('path.root.engine').'/lib/internal/ProfilerSimple/Profiler.class.php');

require_once("Object.class.php");
require_once("Block.class.php");
require_once("Hook.class.php");
require_once("Module.class.php");
require_once("Router.class.php");

require_once("Entity.class.php");
require_once("Mapper.class.php");

/**
 * Основной класс движка, который позволяет напрямую обращаться к любому модулю
 *
 */
class Engine extends Object {
	
	static protected $oInstance=null;
	
	protected $aModules=array();
	protected $aConfigModule;
	public $iTimeLoadModule=0;
	
	/**
	 * Массив содержит меппер кастомизации сущностей
	 *
	 * @var arrat
	 */
	static protected $aEntityCustoms=array();
	
	/**
	 * При создании объекта делаем инициализацию
	 *
	 */
	protected function __construct() {
		if (get_magic_quotes_gpc()) {
			func_stripslashes($_REQUEST);
		}
	}
	
	
	/**
	 * Ограничиваем объект только одним экземпляром
	 *
	 * @return Engine
	 */
	static public function getInstance() {
		if (isset(self::$oInstance) and (self::$oInstance instanceof self)) {
			return self::$oInstance;
		} else {
			self::$oInstance= new self();
			return self::$oInstance;
		}
	}
	
	/**
	 * Инициализация
	 *
	 */
	public function Init() {
		/**
		 * Инициализируем хуки
		 */
		$this->InitHooks();		
		/**
		 * Загружаем модули автозагрузки
		 */
		$this->LoadModules();
		/**
		 * Инициализируем загруженные модули
		 */
		$this->InitModules();
		/**
		 * Запускаем хуки для события завершения инициализации Engine
		 */
		$this->Hook_Run('engine_init_complete');
	}
	/**
	 * Завершение работы модуля
	 *
	 */
	public function Shutdown() {
		$this->ShutdownModules();
	}
	/**
	 * Производит инициализацию всех модулей
	 *
	 */
	protected function InitModules() {
		foreach ($this->aModules as $oModule) {
			$oModule->Init();
		}
	}
	
	/**
	 * Завершаем работу всех модулей
	 *
	 */
	protected function ShutdownModules() {
		foreach ($this->aModules as $sKey => $oModule) {
			$oModule->Shutdown();
		}
	}
	/**
	 * Выполняет загрузку модуля по его названию
	 *
	 * @param string $sModuleName
	 * @param bool $bInit - инициализировать модуль или нет
	 * @return unknown
	 */
	protected function LoadModule($sModuleName,$bInit=false) {
		$tm1=microtime(true);
		if ($this->isFileExists(Config::Get('path.root.engine')."/modules/".strtolower($sModuleName)."/".$sModuleName.".class.php")) {
			require_once(Config::Get('path.root.engine')."/modules/".strtolower($sModuleName)."/".$sModuleName.".class.php");			
		} elseif ($this->isFileExists(Config::Get('path.root.server')."/classes/modules/".strtolower($sModuleName)."/".$sModuleName.".class.php")) {
			require_once(Config::Get('path.root.server')."/classes/modules/".strtolower($sModuleName)."/".$sModuleName.".class.php");
		} else {
			throw new Exception("Can not find module class - ".$sModuleName);
		}		
		/**
		 * Проверяем наличие кастомного класса. Также можно переопределить системный модуль
		 */
		$sPrefixCustom='';
		if ($this->isFileExists(Config::Get('path.root.server')."/classes/modules/".strtolower($sModuleName)."/".$sModuleName.".class.custom.php")) {
			require_once(Config::Get('path.root.server')."/classes/modules/".strtolower($sModuleName)."/".$sModuleName.".class.custom.php");
			$sPrefixCustom='_custom';
		}
		/**
		 * Создаем объект модуля
		 */
		$sModuleNameClass='Ls'.$sModuleName.$sPrefixCustom;
		$oModule=new $sModuleNameClass($this);
		if ($bInit or $sModuleName=='Cache') {
			$oModule->Init();
		}
		$this->aModules[$sModuleName]=$oModule;
		$tm2=microtime(true);
		$this->iTimeLoadModule+=$tm2-$tm1;
		dump("load $sModuleName - \t\t".($tm2-$tm1)."");
		return $oModule;
	}
	
	/**
	 * Загружает все используемые модули и передает им в конструктор ядро
	 *
	 */
	protected function LoadModules() {
		$this->LoadConfig();
		foreach ($this->aConfigModule['autoLoad'] as $sModuleName) {
			$this->LoadModule($sModuleName);
		}
	}
	/**
	 * Выполняет загрузку конфигов
	 *
	 */
	protected function LoadConfig() {
		$this->aConfigModule = Config::Get('module');
	}
	/**
	 * Регистрирует хуки из /classes/hooks/
	 *
	 */
	protected function InitHooks() {
		$sDirHooks=Config::Get('path.root.server').'/classes/hooks/';
		if ($hDir = opendir($sDirHooks)) {
			while (false !== ($sFile = readdir($hDir))) {
				if ($sFile !='.' and $sFile !='..' and is_file($sDirHooks.$sFile)) {
					if (preg_match("/^Hook([\w]+)\.class\.php$/i",$sFile,$aMatch)) {
						require_once($sDirHooks.$sFile);
						$sClassName='Hook'.$aMatch[1];
						$oHook=new $sClassName;
						$oHook->RegisterHook();
					}
				}
			}
			closedir($hDir);
		}
	}
	/**
	 * Проверяет файл на существование, если используется кеширование memcache то кеширует результат работы
	 *
	 * @param unknown_type $sFile
	 * @return unknown
	 */
	public function isFileExists($sFile,$iTime=3600) {	return file_exists($sFile);	
		if (strpos($sFile,'/Cache.class.')!==false) {
			return file_exists($sFile);
		}
		if (SYS_CACHE_USE and SYS_CACHE_TYPE==SYS_CACHE_TYPE_MEMORY) {
			if (false === ($data = $this->Cache_Get("file_exists_{$sFile}"))) {
				$data=file_exists($sFile);
				$this->Cache_Set((int)$data, "file_exists_{$sFile}", array(), $iTime);
			}
			return $data;
		} else {
			return file_exists($sFile);
		}
	}
	/**
	 * Вызывает метод нужного модуля
	 *
	 * @param string $sName
	 * @param array $aArgs
	 * @return unknown
	 */
	public function _CallModule($sName,$aArgs) {				
		$sArgs='';
		$aStrArgs=array();
		foreach ($aArgs as $sKey => $arg) {
			$aStrArgs[]='$aArgs['.$sKey.']';
		}
		$sArgs=join(',',$aStrArgs);
		
		$aName=explode("_",$sName);
		
		$sModuleName=$aName[0];
		if (isset($this->aModules[$sModuleName])) {
			$oModule=$this->aModules[$sModuleName];
		} else {
			$oModule=$this->LoadModule($sModuleName,true);			
		}		
		if (!method_exists($oModule,$aName[1])) {
			throw new Exception("The module has no required method: ".$sModuleName.'->'.$aName[1].'()');
		}		
		$sCmd='$result=$oModule->'.$aName[1].'('.$sArgs.');';
		$oProfiler=ProfilerSimple::getInstance();
		$iTimeId=$oProfiler->Start('callModule',$sModuleName.'->'.$aName[1].'()');
		eval($sCmd);
		$oProfiler->Stop($iTimeId);
		return $result;		
	}

	public function getStats() {
		return array('sql'=>$this->Database_GetStats(),'cache'=>$this->Cache_GetStats(),'engine'=>array('time_load_module'=>round($this->iTimeLoadModule,3)));
	}

	/**
	 * Ставим хук на вызов неизвестного метода и считаем что хотели вызвать метод какого либо модуля
	 *
	 * @param string $sName
	 * @param array $aArgs
	 * @return unknown
	 */
	public function __call($sName,$aArgs) {
		return $this->_CallModule($sName,$aArgs);
	}
	
	/**
	 * Блокируем копирование/клонирование объекта роутинга
	 *
	 */
	protected function __clone() {
		
	}
	
	/**
	 * Создает объект сущности, контролируя варианты кастомизации
	 *
	 * @param  string $sName
	 * @param  mixed  $aParams
	 * @return mixed
	 */
	public static function GetEntity($sName,$aParams=array()) {
		/**
		 * Сущности, имеющие такое же название как модуль, 
		 * можно вызывать сокращенно. Например, вместо User_User -> User
		 */
		if(substr_count($sName,'_')==0) {
			$sEntity = $sModule = $sName;
		} else {
			list($sModule,$sEntity) = explode('_',$sName,2);
		}
		/**
		 * Проверяем наличие сущности в меппере кастомизации
		 */
		if(array_key_exists($sName,self::$aEntityCustoms)) {
			$sEntity = (self::$aEntityCustoms[$sName]=='custom')
				? $sEntity.'_custom'
				: $sEntity;
			//$sFileClass=Config::get('path.root.server').'/classes/modules/'.strtolower($sModule).'/entity/'.$sEntity.'.entity.class.'.((self::$aEntityCustoms[$sName]=='custom')?'custom.':'').'php';
		} else {
			$sFileDefaultClass=Config::get('path.root.server').'/classes/modules/'.strtolower($sModule).'/entity/'.$sEntity.'.entity.class.php';		
			$sFileCustomClass = Config::get('path.root.server').'/classes/modules/'.strtolower($sModule).'/entity/'.$sEntity.'.entity.class.custom.php';
			/**
			 * Пытаемся найти кастомизированную сущность
			 */
			if(file_exists($sFileCustomClass)) {
				$sFileClass=$sFileCustomClass;
				$sEntity.='_custom';
				self::$aEntityCustoms[$sName]='custom';	
			} elseif(file_exists($sFileDefaultClass)) {
				$sFileClass=$sFileDefaultClass;
				self::$aEntityCustoms[$sName]='default';
			} else {
				throw new Exception('Entity class not found');
				return null;
			}
			/**
			 * Подгружаем нужный файл
			 */
			require_once($sFileClass);		
		}
		
		$sClass=$sModule.'Entity_'.$sEntity;
		$oEntity=new $sClass($aParams);
		return $oEntity;
	}
}

/**
 * Автозагрузка кслассов
 *
 * @param unknown_type $sClassName
 */
function __autoload($sClassName) {
	/**
	 * Если класс подходит под шблон класса сущности то загружаем его
	 */
	if (preg_match("/^(\w+)Entity\_(\w+)$/i",$sClassName,$aMatch)) {			
		$tm1=microtime(true);	
		
		$sFileClass= (substr($aMatch[2],-7)=='_custom') 
			? Config::get('path.root.server').'/classes/modules/'.strtolower($aMatch[1]).'/entity/'.substr($aMatch[2],0,strlen($aMatch[2])-7).'.entity.class.custom.php'
			: Config::get('path.root.server').'/classes/modules/'.strtolower($aMatch[1]).'/entity/'.$aMatch[2].'.entity.class.php';
			
		if (file_exists($sFileClass)) {
			require_once($sFileClass);
			$tm2=microtime(true);			
			dump($sClassName." - \t\t".($tm2-$tm1));
		}
	}
}
?>