Index: trunk/core/kernel/event_manager.php
===================================================================
diff -u -N
--- trunk/core/kernel/event_manager.php (revision 8002)
+++ trunk/core/kernel/event_manager.php (revision 0)
@@ -1,556 +0,0 @@
-Conn =& $this->Application->GetADODBConnection();
- }
-
- /**
- * Set's new enviroment parameter mappings
- * between their names as application vars
- *
- * @param Array $new_query_maps
- * @access public
- */
- /*function setQueryMaps($new_query_maps)
- {
- $this->queryMaps = $new_query_maps;
- }*/
-
- /**
- * Adds new query map to already parsed query maps
- *
- * @param string $prefix
- */
- function setQueryMap($prefix_special)
- {
- list($prefix) = explode('.', $prefix_special);
- $query_map = $this->Application->getUnitOption($prefix, 'QueryString');
- if ($query_map) {
- $this->queryMaps[$prefix_special] = $query_map;
- }
- else {
- unset($this->queryMaps[$prefix]);
- }
-
-// 'passed' is set later in ProcessRequest - do we really need it here? (it breakes HTTPQuery initialization...)
-// $this->Application->SetVar('passed', implode(',', array_keys($this->queryMaps)) );
- return $query_map;
- }
-
- /**
- * Registers new regular event
- *
- * @param string $short_name name to be used to store last maintenace run info
- * @param string $event_name
- * @param int $run_interval run interval in seconds
- * @param int $type before or after regular event
- */
- function registerRegularEvent($short_name, $event_name, $run_interval, $type = reBEFORE)
- {
- if($type == reBEFORE)
- {
- $this->beforeRegularEvents[$short_name] = Array('EventName' => $event_name, 'RunInterval' => $run_interval);
- }
- else
- {
- $this->afterRegularEvents[$short_name] = Array('EventName' => $event_name, 'RunInterval' => $run_interval);
- }
- }
-
- function registerBuildEvent($pseudo_class,$build_event_name)
- {
- $this->buildEvents[$pseudo_class]=$build_event_name;
- }
-
- /**
- * Returns build event by pseudo class
- * name if any defined in config
- *
- * @param string $pseudo_class
- * @return kEvent
- * @access public
- */
- function &getBuildEvent($pseudo_class)
- {
- $false = false;
- if( !isset($this->buildEvents[$pseudo_class]) ) return $false;
-
- $event = new kEvent();
- $event->Name=$this->buildEvents[$pseudo_class];
- $event->MasterEvent=null;
- return $event;
- }
-
- /**
- * Check if event is called twice, that causes recursion
- *
- * @param kEvent $event
- */
- function isRecursion(&$event)
- {
- $event_key = $event->getPrefixSpecial().':'.$event->Name;
- return in_array($event_key, $this->recursionStack) ? true : false;
- }
-
- function pushEvent(&$event)
- {
- $event_key = $event->getPrefixSpecial().':'.$event->Name;
- array_push($this->recursionStack, $event_key);
- }
-
- function popEvent()
- {
- array_pop($this->recursionStack);
- }
-
- /**
- * Allows to process any type of event
- *
- * @param kEvent $event
- * @access public
- */
- function HandleEvent(&$event)
- {
- if ($this->isRecursion($event)) {
- return true;
- }
-
- $this->pushEvent($event);
-
- if( !$this->Application->prefixRegistred($event->Prefix) )
- {
- $unit_config_reader =& $this->Application->recallObject('kUnitConfigReader');
- $unit_config_reader->loadConfig($event->Prefix);
- if( !$this->Application->prefixRegistred($event->Prefix) )
- {
- trigger_error('Prefix '.$event->Prefix.' not registred (requested event '.$event->Name.')', E_USER_NOTICE);
- return false;
- }
- }
-
- if (!$event->SkipBeforeHooks) {
- $this->processHooks($event, hBEFORE);
- if ($event->status == erFATAL) return true;
- }
-
- $event_handler =& $this->Application->recallObject($event->Prefix.'_EventHandler');
- /* @var $event_handler kEventHandler */
- $event_handler->processEvent($event);
-
- if ($event->status == erFATAL) return true;
- if (!$event->SkipAfterHooks) {
- $this->processHooks($event, hAFTER);
- }
-
- $this->popEvent();
- return true;
- }
-
- function ProcessRequest()
- {
- $this->processOpener();
-
- // 1. get events from $_POST
- $events = $this->Application->GetVar('events');
- if ($events === false) $events = Array();
- // 2. if nothing there, then try to find them in $_GET
- if ($this->queryMaps && !$events) {
- // if we got $_GET type submit (links, not javascript)
- foreach ($this->queryMaps as $prefix_special => $query_map) {
- $query_map = array_flip($query_map);
- if (isset($query_map['event'])) {
- $event_name = $this->Application->GetVar($prefix_special.'_event');
- if ($event_name) {
- $events[$prefix_special] = $event_name;
- }
- }
- }
- $actions = $this->Application->GetVar('do');
- if ($actions) {
- list($prefix, $event_name) = explode('_', $actions);
- $events[$prefix] = $event_name;
- }
- }
-
- // 3. store all prefixes passed before event processing, because they are used by GetTopmostPrefix
- $all_passed = explode(',', $this->Application->GetVar('passed'));
- foreach ($events as $prefix_special => $event_name) {
- if (!$event_name) continue;
- $prefix_special = explode('.',$prefix_special);
- array_push($all_passed, $prefix_special[0]);
- }
- $this->Application->SetVar('all_passed', implode(',', $all_passed));
-
- foreach ($events as $prefix_special => $event_name) {
- if (!$event_name) continue;
- if (is_array($event_name)) {
- $event_name = key($event_name);
- $events[$prefix_special] = $event_name;
- $this->Application->SetVar($prefix_special.'_event', $event_name);
- }
-
- $event = new kEvent();
- $event->Name = $event_name;
- $event->Prefix_Special = $prefix_special;
-
- $prefix_special = explode('.',$prefix_special);
- $event->Prefix = $prefix_special[0];
-// array_push($passed, $prefix_special[0]);
- $event->Special = isset($prefix_special[1]) ? $prefix_special[1] : '';
-
- $event->redirect_params = Array('opener' => 's', 'pass' => 'all');
- $event->redirect = true;
-
- $event_handler =& $this->Application->recallObject($event->Prefix.'_EventHandler');
- /* @var $event_handler kEventHandler */
- $event->setEventParam('top_prefix', $this->Application->GetTopmostPrefix($event->Prefix, true));
- if (($this->Application->RecallVar('user_id') == -1) || $event_handler->CheckPermission($event)) {
- $this->HandleEvent($event);
- }
-
- if ($event->status == erSTOP) {
- // event requested to stop processing at this point
- safeDefine('DBG_SKIP_REPORTING', 1);
- $this->Application->Session->SaveData();
- exit;
- }
-
- if ($event->status == erPERM_FAIL) {
- // should do redirect but to no_permissions template
- $event->redirect = $this->Application->IsAdmin() ? 'no_permission' : $this->Application->ConfigValue('NoPermissionTemplate');
- $event->redirect_params['pass'] = 'm';
- $event->redirect_params['m_cat_id'] = 0;
-
- // restore stuff, that processOpener() changed
- $wid = $this->Application->GetVar('m_wid');
- $this->Application->RestoreVar(rtrim('opener_stack_'.$wid, '_'));
- // don't save last_template, because no_permission template does js history.back and could cause invalid opener_stack content
- $this->Application->SetVar('skip_last_template', 1);
- }
-
- if ( ($event->status == erSUCCESS || $event->status == erPERM_FAIL) && ($event->redirect === true || strlen($event->redirect) > 0)) {
- // we need to pass category if the action was submitted to self-template, with the category passed
- // and it has not explicly set redirect template or pass_cateogry param
- if ($event->redirect === true && !isset($event->redirect_params['pass_category']) && $this->Application->GetVar('m_cat_id')) {
- $event->redirect_params['pass_category'] = 1;
- }
-
- $wid = $this->Application->GetVar('m_wid');
- if ($wid && $event->redirect_params['opener'] == 'u') {
- $event->redirect_params['opener'] = 's'; // because Application->HREF will react differently when 'opener' = 'u'
- $event->redirect = defined('CLOSE_POPUP_TPL') ? CLOSE_POPUP_TPL : 'incs/close_popup';
- }
-
- $this->Application->Redirect($event->redirect, $event->redirect_params, null, $event->redirect_script);
- }
- }
-
- $this->Application->SetVar('events', $events);
- $this->Application->SetVar('passed', implode(',', $all_passed));
- }
-
- function processOpener()
- {
- $wid = $this->Application->GetVar('m_wid');
-
- $opener_stack = $this->Application->RecallVar(rtrim('opener_stack_'.$wid, '_'));
- $opener_stack = $opener_stack ? unserialize($opener_stack) : Array();
-
- $opener_action = $this->Application->GetVar('m_opener');
- switch ($opener_action) {
- case 'r': // "reset" opener stack
- $opener_stack = Array();
- break;
-
- case 'd': // "down/push" new template to opener stack, deeplevel++
- if ($this->Application->GetVar('front')) {
- $front_session =& $this->Application->recallObject('Session.front');
- array_push($opener_stack, '../'.$front_session->RecallVar('last_template') );
- }
- else {
- array_push($opener_stack, $this->Application->RecallVar('last_template') );
- }
- break;
-
- case 'u': // "up/pop" last template from opener stack, deeplevel--
- array_pop($opener_stack);
- break;
-
- case 'p': // pop-up - generate new wid
- $parent_wid = $this->Application->GetVar('m_wid'); // window_id of popup's parent window
- $popup_wid = (int)$this->Application->RecallVar('last_wid') + 1;
- $this->Application->StoreVar('last_wid', $popup_wid);
- $this->Application->SetVar('m_wid', $popup_wid);
-
- if ($this->Application->GetVar('front')) {
- $front_session =& $this->Application->recallObject('Session.front');
-
- $last_template = $front_session->RecallVar(rtrim('last_template_popup_'.$parent_wid, '_'));
- $last_template = '../'.$last_template;
- }
- else {
- $last_template = $this->Application->RecallVar(rtrim('last_template_popup_'.$parent_wid, '_'));
- }
-
- $opener_stack = Array ( $last_template );
- $this->Application->SetVar('m_opener', 's');
- $wid = $popup_wid;
- break;
-
- default: // "s/0," stay on same deep level
- break;
- }
-
-
- $this->Application->SetVar('m_opener', 's');
- $this->Application->StoreVar(rtrim('opener_stack_'.$wid, '_'), serialize($opener_stack));
- }
-
- /**
- * Used from relationship event handler
- *
- * @param string $t
- * @param Array $params
- * @param string $pass
- */
- function openerStackPush($t, $params, $pass = 'all', $wid=null)
- {
- if (!isset($wid)) $wid = $this->Application->GetVar('m_wid');
- $stack_name = rtrim('opener_stack_'.$wid, '_');
-
- $opener_stack = $this->Application->RecallVar($stack_name);
- $opener_stack = $opener_stack ? unserialize($opener_stack) : Array();
-
- $redirect_params = array_merge_recursive2(Array('m_opener' => 'u', '__URLENCODE__' => 1), $params);
- $new_level = $this->Application->BuildEnv($t, $redirect_params, $pass, true);
- array_push($opener_stack, 'index.php|'.ltrim($new_level, ENV_VAR_NAME.'=') );
- $this->Application->StoreVar($stack_name, serialize($opener_stack));
- }
-
- function registerHook($hookto_prefix, $hookto_special, $hookto_event, $mode, $do_prefix, $do_special, $do_event, $conditional)
- {
- if( !$this->Application->prefixRegistred($hookto_prefix) )
- {
- if ($this->Application->isDebugMode()) {
- trigger_error('Prefix '.$hookto_prefix.' doesn\'t exist when trying to hook from '.$do_prefix.':'.$do_event.'', E_USER_WARNING);
- }
- return;
- }
- $hookto_prefix_special = rtrim($hookto_prefix.'.'.$hookto_special, '.');
- if ($mode == hBEFORE) {
- $this->beforeHooks[strtolower($hookto_prefix_special.'.'.$hookto_event)][] = Array(
- 'DoPrefix' => $do_prefix,
- 'DoSpecial' => $do_special,
- 'DoEvent' => $do_event,
- 'Conditional' => $conditional,
- );
- }
- elseif ($mode == hAFTER) {
- $this->afterHooks[strtolower($hookto_prefix_special.'.'.$hookto_event)][] = Array(
- 'DoPrefix' => $do_prefix,
- 'DoSpecial' => $do_special,
- 'DoEvent' => $do_event,
- 'Conditional' => $conditional,
- );
- }
- }
-
- /**
- * Enter description here...
- *
- * @param kEvent $event
- * @param int $mode hBEFORE or hAFTER
- * @return Array
- */
- function &getHooks(&$event, $mode, $special = null)
- {
- $event_key = !isset($special) ? $event->Prefix_Special : $event->Prefix.'.'.$special;
-
- if ($mode == hBEFORE) {
- $mode_hooks =& $this->beforeHooks;
- }
- else {
- $mode_hooks =& $this->afterHooks;
- }
-
- if (!isset($mode_hooks[strtolower($event_key.'.'.$event->Name)])) {
- $hooks = array();
- return $hooks;
- }
- return $mode_hooks[strtolower($event_key.'.'.$event->Name)];
- }
-
- /**
- * Enter description here...
- *
- * @param kEvent $event
- * @param int $mode hBEFORE or hAFTER
- */
- function processHooks(&$event, $mode)
- {
- // * - get hooks that are valid with any special of given prefix
- $hooks = array_merge($this->getHooks($event, $mode, '*'), $this->getHooks($event, $mode));
-
- if ($hooks) {
- foreach ($hooks as $hook) {
- if ($hook['DoSpecial'] == '*') {
- // use same special as master event
- $hook['DoSpecial'] = $event->Special;
- }
-
- $prefix_special = rtrim($hook['DoPrefix'].'_'.$hook['DoSpecial'], '_');
- if ( $hook['Conditional'] && !$this->Application->GetVar($prefix_special) ) {
- continue;
- }
-
- $hook_event = new kEvent( Array('name'=>$hook['DoEvent'],'prefix'=>$hook['DoPrefix'],'special'=>$hook['DoSpecial']) );
- $hook_event->MasterEvent =& $event;
- $this->HandleEvent($hook_event);
- }
- }
- }
-
- /**
- * Set's new event for $prefix_special
- * passed
- *
- * @param string $prefix_special
- * @param string $event_name
- * @access public
- */
- function setEvent($prefix_special,$event_name)
- {
- $actions =& $this->Application->recallObject('kActions');
- $actions->Set('events['.$prefix_special.']',$event_name);
- }
-
- /**
- * Run registred regular events with specified event type
- *
- * @param int $event_type
- */
- function RunRegularEvents($event_type = reBEFORE, $from_cron=false)
- {
- if (defined('IS_INSTALL')) return ;
- // if RegularEvents are set to run from cron
- if (!$from_cron && $this->Application->ConfigValue('UseCronForRegularEvent')) return ;
- $events_source = ($event_type == reBEFORE) ? $this->beforeRegularEvents : $this->afterRegularEvents;
-
- /*if(rand(0, 100) < 90)
- {
- return;
- }*/
-
- $sql = 'SELECT Data FROM '.TABLE_PREFIX.'Cache WHERE VarName = %s';
- $event_last_runs = $this->Conn->GetOne( sprintf($sql, $this->Conn->qstr('RegularEventRuns') ) );
- $event_last_runs = $event_last_runs ? unserialize($event_last_runs) : Array();
-
- foreach($events_source as $short_name => $event_data)
- {
- $event_last_run = getArrayValue($event_last_runs, $short_name);
- if($event_last_run && $event_last_run > adodb_mktime() - $event_data['RunInterval'])
- {
- continue;
- }
- else
- {
- $event = new kEvent($event_data['EventName']);
- $event->redirect = false;
- $this->Application->HandleEvent($event);
- $event_last_runs[$short_name] = adodb_mktime();
- }
- }
-
- $sql = 'REPLACE INTO '.TABLE_PREFIX.'Cache (VarName,Data,Cached) VALUES (%s,%s,%s)';
- $this->Conn->Query( sprintf($sql, $this->Conn->qstr('RegularEventRuns'), $this->Conn->qstr(serialize($event_last_runs)), adodb_mktime() ) );
- }
-
- /**
- * Allows to determine, that required event is beeing processed right now
- *
- * @param string $event_key Event name in format prefix[.special]:event_name
- * @return bool
- */
- function eventRunning($event_key)
- {
- return array_search($event_key, $this->recursionStack) !== false;
- }
- }
-
-
-?>
\ No newline at end of file