File Metadata

Created: Mon, Oct 6, 5:40 PM

session_log_eh.php
View Options

	<?php
	/**
	* @version $Id: session_log_eh.php 16519 2017-01-20 20:21:46Z alex $
	* @package In-Portal
	* @copyright Copyright (C) 1997 - 2009 Intechnic. All rights reserved.
	* @license GNU/GPL
	* In-Portal is Open Source software.
	* This means that this software may have been modified pursuant
	* the GNU General Public License, and as distributed it includes
	* or is derivative of works licensed under the GNU General Public License
	* or other free or open source software licenses.
	* See http://www.in-portal.org/license for copyright notices and details.
	*/

	defined('FULL_PATH') or die('restricted access!');

	class SessionLogEventHandler extends kDBEventHandler {

	/**
	* Opens log for new session
	*
	* @param kEvent $event
	*/
	function OnStartSession($event)
	{
	if (!$this->Application->ConfigValue('UseChangeLog')) {
	// don't use session log when change log is disabled
	return ;
	}

	/** @var kDBItem $object */
	$object = $this->Application->recallObject($event->Prefix, null, Array ('skip_autoload' => 1));

	$fields_hash = Array (
	'SessionStart' => time(),
	'IP' => $this->Application->getClientIp(),
	'PortalUserId' => $this->Application->RecallVar('user_id'),
	'SessionId' => $this->Application->GetSID(),
	'Status' => SESSION_LOG_ACTIVE,
	);

	$object->SetDBFieldsFromHash($fields_hash);

	$object->UpdateFormattersSubFields();

	if ($object->Create()) {
	$this->Application->StoreVar('_SessionLogId_', $object->GetID());
	}
	}

	/**
	* Closes log for current session
	*
	* @param kEvent $event
	*/
	function OnEndSession($event)
	{
	/** @var kDBItem $object */
	$object = $this->Application->recallObject($event->Prefix, null, Array ('skip_autoload' => 1));

	$object->Load($this->Application->RecallVar('_SessionLogId_'));
	if (!$object->isLoaded()) {
	return ;
	}

	$fields_hash = Array (
	'SessionEnd' => time(),
	'Status' => SESSION_LOG_LOGGED_OUT,
	);

	$object->SetDBFieldsFromHash($fields_hash);

	$object->UpdateFormattersSubFields();
	$object->Update();
	}

	/**
	* Apply custom processing to item
	*
	* @param kEvent $event
	* @param string $type
	* @return void
	* @access protected
	*/
	protected function customProcessing(kEvent $event, $type)
	{
	if ( $event->Name == 'OnMassDelete' && $type == 'before' ) {
	$ids = $event->getEventParam('ids');
	if ( $ids ) {
	$config = $event->getUnitConfig();
	$id_field = $config->getIDField();

	$sql = 'SELECT ' . $id_field . '
	FROM ' . $config->getTableName() . '
	WHERE ' . $id_field . ' IN (' . implode(',', $ids) . ') AND Status <> ' . SESSION_LOG_ACTIVE;
	$allowed_ids = $this->Conn->GetCol($sql);

	$event->setEventParam('ids', $allowed_ids);
	}
	}
	}

	/**
	* Delete changes, related to deleted session
	*
	* @param kEvent $event
	* @return void
	* @access protected
	*/
	protected function OnAfterItemDelete(kEvent $event)
	{
	parent::OnAfterItemDelete($event);

	/** @var kDBItem $object */
	$object = $event->getObject();

	$change_logs_config = $this->Application->getUnitConfig('change-log');

	$sql = 'SELECT ' . $change_logs_config->getIDField() . '
	FROM ' . $change_logs_config->getTableName() . '
	WHERE SessionLogId = ' . $object->GetID();
	$related_ids = $this->Conn->GetCol($sql);

	if ( $related_ids ) {
	/** @var kTempTablesHandler $temp_handler */
	$temp_handler = $this->Application->recallObject('change-log_TempHandler', 'kTempTablesHandler', Array ('parent_event' => $event->MasterEvent));

	$temp_handler->DeleteItems('change-log', '', $related_ids);
	}
	}

	/**
	* [SCHEDULED TASK] Will remove old session logs
	*
	* @param kEvent $event Event.
	*
	* @return void
	*/
	protected function OnRotate(kEvent $event)
	{
	$rotation_interval = (int)$this->Application->ConfigValue('SessionLogRotationInterval');

	if ( $rotation_interval === -1 ) {
	// Forever.
	return;
	}

	$session_log_temp_handler = $this->getTempTablesHandler($event->getPrefixSpecial(), $event);
	$change_log_temp_handler = $this->getTempTablesHandler('change-log', $event);

	$limit = 100;
	$session_log_config = $event->getUnitConfig();
	$session_log_select_sql = ' SELECT ' . $session_log_config->getIDField() . '
	FROM ' . $session_log_config->getTableName() . '
	WHERE ' . TIMENOW . ' - SessionEnd > ' . $rotation_interval . '
	LIMIT 0,' . $limit;
	$change_log_config = $this->Application->getUnitConfig('change-log');

	do {
	$session_log_ids = $this->Conn->GetCol($session_log_select_sql);

	if ( !$session_log_ids ) {
	break;
	}

	$change_log_select_sql = ' SELECT ' . $change_log_config->getIDField() . '
	FROM ' . $change_log_config->getTableName() . '
	WHERE SessionLogId IN (' . implode(',', $session_log_ids) . ')
	LIMIT 0,' . $limit;

	do {
	$change_log_ids = $this->Conn->GetCol($change_log_select_sql);

	if ( $change_log_ids ) {
	$change_log_temp_handler->DeleteItems('change-log', '', $change_log_ids);
	}
	} while ( count($change_log_ids) == $limit );

	$session_log_temp_handler->DeleteItems($event->Prefix, $event->Special, $session_log_ids);
	} while ( count($session_log_ids) == $limit );
	}

	/**
	* Get temp tables handler instance.
	*
	* @param string $prefix_special Prefix, special.
	* @param kEvent $event Event.
	*
	* @return kTempTablesHandler
	*/
	public function getTempTablesHandler($prefix_special, kEvent $event)
	{
	return $this->Application->recallObject(
	$prefix_special . '_TempHandler',
	'kTempTablesHandler',
	array('parent_event' => $event)
	);
	}

	}

session_log_eh.php
No OneTemporary
Actions

File Metadata

session_log_eh.php
View Options

Event Timeline

session_log_eh.phpNo OneTemporaryActions

File Metadata

session_log_eh.phpView Options

Event Timeline

session_log_eh.php
No OneTemporary
Actions

session_log_eh.php
View Options