in-portal
No OneTemporary
Actions

Subscribers

None

File Metadata

Created: Thu, Feb 6, 3:52 PM

in-portal
View Options

	Index: branches/5.1.x/core/kernel/utility/temp_handler.php
	===================================================================
	--- branches/5.1.x/core/kernel/utility/temp_handler.php (revision 14432)
	+++ branches/5.1.x/core/kernel/utility/temp_handler.php (revision 14433)
	@@ -1,972 +1,972 @@
	<?php
	/**
	* @version $Id$
	* @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 kTempTablesHandler extends kBase {

	var $Tables = Array();

	/**
	* Master table name for temp handler
	*
	* @var string
	* @access private
	*/
	var $MasterTable = '';

	/**
	* IDs from master table
	*
	* @var Array
	* @access private
	*/
	var $MasterIDs = Array();

	var $AlreadyProcessed = Array();

	var $DroppedTables = Array();

	var $FinalRefs = Array();

	var $CopiedTables = Array();


	/**
	* IDs of newly cloned items (key - prefix.special, value - array of ids)
	*
	* @var Array
	*/
	var $savedIDs = Array();

	/**
	* Description
	*
	* @var kDBConnection
	* @access public
	*/
	var $Conn;


	/**
	* Window ID of current window
	*
	* @var mixed
	*/
	var $WindowID = '';

	function kTempTablesHandler()
	{
	parent::kBase();
	$this->Conn =& $this->Application->GetADODBConnection();
	}

	function SetTables($tables)
	{
	// set tablename as key for tables array
	$ret = Array();
	$this->Tables = $tables;
	$this->MasterTable = $tables['TableName'];
	}

	function saveID($prefix, $special = '', $id = null)
	{
	if (!isset($this->savedIDs[$prefix.($special ? '.' : '').$special])) {
	$this->savedIDs[$prefix.($special ? '.' : '').$special] = array();
	}
	if (is_array($id)) {
	foreach ($id as $tmp_id => $live_id) {
	$this->savedIDs[$prefix.($special ? '.' : '').$special][$tmp_id] = $live_id;
	}
	}
	else {
	$this->savedIDs[$prefix.($special ? '.' : '').$special][] = $id;
	}
	}

	/**
	* Get temp table name
	*
	* @param string $table
	* @return string
	*/
	function GetTempName($table)
	{
	return $this->Application->GetTempName($table, $this->WindowID);
	}

	function GetTempTablePrefix()
	{
	return $this->Application->GetTempTablePrefix($this->WindowID);
	}

	/**
	* Return live table name based on temp table name
	*
	* @param string $temp_table
	* @return string
	*/
	function GetLiveName($temp_table)
	{
	return $this->Application->GetLiveName($temp_table);
	}

	function IsTempTable($table)
	{
	return $this->Application->IsTempTable($table);
	}

	/**
	* Return temporary table name for master table
	*
	* @return string
	* @access public
	*/
	function GetMasterTempName()
	{
	return $this->GetTempName($this->MasterTable);
	}

	function CreateTempTable($table)
	{
	$query = sprintf("CREATE TABLE %s SELECT * FROM %s WHERE 0",
	$this->GetTempName($table),
	$table);

	$this->Conn->Query($query);
	}

	function BuildTables($prefix, $ids)
	{
	$this->WindowID = $this->Application->GetVar('m_wid');

	$this->TableIdCounter = 0;
	$tables = Array(
	'TableName' => $this->Application->getUnitOption($prefix, 'TableName'),
	'IdField' => $this->Application->getUnitOption($prefix, 'IDField'),
	'IDs' => $ids,
	'Prefix' => $prefix,
	'TableId' => $this->TableIdCounter++,
	);

	/*$parent_prefix = $this->Application->getUnitOption($prefix, 'ParentPrefix');
	if ($parent_prefix) {
	$tables['ForeignKey'] = $this->Application->getUnitOption($prefix, 'ForeignKey');
	$tables['ParentPrefix'] = $parent_prefix;
	$tables['ParentTableKey'] = $this->Application->getUnitOption($prefix, 'ParentTableKey');
	}*/

	$this->FinalRefs[ $tables['TableName'] ] = $tables['TableId']; // don't forget to add main table to FinalRefs too

	$SubItems = $this->Application->getUnitOption($prefix,'SubItems');
	if (is_array($SubItems)) {
	foreach ($SubItems as $prefix) {
	$this->AddTables($prefix, $tables);
	}
	}
	$this->SetTables($tables);
	}

	/**
	* Searches through TempHandler tables info for required prefix
	*
	* @param string $prefix
	* @param Array $master
	* @return mixed
	*/
	function SearchTable($prefix, $master = null)
	{
	if (is_null($master)) {
	$master = $this->Tables;
	}

	if ($master['Prefix'] == $prefix) {
	return $master;
	}

	if (isset($master['SubTables'])) {
	foreach ($master['SubTables'] as $sub_table) {
	$found = $this->SearchTable($prefix, $sub_table);
	if ($found !== false) {
	return $found;
	}
	}
	}

	return false;
	}

	function AddTables($prefix, &$tables)
	{
	if (!$this->Application->prefixRegistred($prefix)) {
	// allows to skip subitem processing if subitem module not enabled/installed
	return ;
	}

	$tmp = Array(
	'TableName' => $this->Application->getUnitOption($prefix,'TableName'),
	'IdField' => $this->Application->getUnitOption($prefix,'IDField'),
	'ForeignKey' => $this->Application->getUnitOption($prefix,'ForeignKey'),
	'ParentPrefix' => $this->Application->getUnitOption($prefix, 'ParentPrefix'),
	'ParentTableKey' => $this->Application->getUnitOption($prefix,'ParentTableKey'),
	'Prefix' => $prefix,
	'AutoClone' => $this->Application->getUnitOption($prefix,'AutoClone'),
	'AutoDelete' => $this->Application->getUnitOption($prefix,'AutoDelete'),
	'TableId' => $this->TableIdCounter++,
	);

	$this->FinalRefs[ $tmp['TableName'] ] = $tmp['TableId'];

	$constrain = $this->Application->getUnitOption($prefix,'Constrain');
	if ($constrain)
	{
	$tmp['Constrain'] = $constrain;
	$this->FinalRefs[ $tmp['TableName'].$tmp['Constrain'] ] = $tmp['TableId'];
	}

	$SubItems = $this->Application->getUnitOption($prefix,'SubItems');
	$same_sub_counter = 1;
	if( is_array($SubItems) )
	{
	foreach($SubItems as $prefix)
	{
	$this->AddTables($prefix, $tmp);
	}
	}

	if ( !is_array(getArrayValue($tables, 'SubTables')) ) {
	$tables['SubTables'] = array();
	}

	$tables['SubTables'][] = $tmp;
	}

	function CloneItems($prefix, $special, $ids, $master = null, $foreign_key = null, $parent_prefix = null, $skip_filenames = false)
	{
	if (!isset($master)) $master = $this->Tables;

	// recalling by different name, because we may get kDBList, if we recall just by prefix
	if (!preg_match('/(.*)-item$/', $special)) {
	$special .= '-item';
	}

	$object =& $this->Application->recallObject($prefix.'.'.$special, $prefix, Array('skip_autoload' => true));
	$object->PopulateMultiLangFields();

	foreach ($ids as $id) {
	$mode = 'create';
	if ( $cloned_ids = getArrayValue($this->AlreadyProcessed, $master['TableName']) ) {
	// if we have already cloned the id, replace it with cloned id and set mode to update
	// update mode is needed to update second ForeignKey for items cloned by first ForeignKey
	if ( getArrayValue($cloned_ids, $id) ) {
	$id = $cloned_ids[$id];
	$mode = 'update';
	}
	}

	$object->Load($id);
	$original_values = $object->FieldValues;

	if (!$skip_filenames) {
	$object->NameCopy($master, $foreign_key);
	}
	elseif ($master['TableName'] == $this->MasterTable) {
	// kCatDBItem class only has this attribute
	$object->useFilenames = false;
	}

	if (isset($foreign_key)) {
	$master_foreign_key_field = is_array($master['ForeignKey']) ? $master['ForeignKey'][$parent_prefix] : $master['ForeignKey'];
	$object->SetDBField($master_foreign_key_field, $foreign_key);
	}

	if ($mode == 'create') {
	$this->RaiseEvent('OnBeforeClone', $master['Prefix'], $special, Array($object->GetId()), $foreign_key);
	}

	$object->inCloning = true;
	$res = $mode == 'update' ? $object->Update() : $object->Create();
	$object->inCloning = false;

	if ($res)
	{
	if ( $mode == 'create' && is_array( getArrayValue($master, 'ForeignKey')) ) {
	// remember original => clone mapping for dual ForeignKey updating
	$this->AlreadyProcessed[$master['TableName']][$id] = $object->GetId();
	}

	if ($mode == 'create') {
	$this->RaiseEvent('OnAfterClone', $master['Prefix'], $special, Array($object->GetId()), $foreign_key, array('original_id' => $id) );
	$this->saveID($master['Prefix'], $special, $object->GetID());
	}

	if ( is_array(getArrayValue($master, 'SubTables')) ) {
	foreach($master['SubTables'] as $sub_table) {
	if (!getArrayValue($sub_table, 'AutoClone')) continue;
	$sub_TableName = ($object->mode == 't') ? $this->GetTempName($sub_table['TableName']) : $sub_table['TableName'];

	$foreign_key_field = is_array($sub_table['ForeignKey']) ? $sub_table['ForeignKey'][$master['Prefix']] : $sub_table['ForeignKey'];
	$parent_key_field = is_array($sub_table['ParentTableKey']) ? $sub_table['ParentTableKey'][$master['Prefix']] : $sub_table['ParentTableKey'];

	if (!$foreign_key_field \|\| !$parent_key_field) continue;

	$query = 'SELECT '.$sub_table['IdField'].' FROM '.$sub_TableName.'
	WHERE '.$foreign_key_field.' = '.$original_values[$parent_key_field];
	if (isset($sub_table['Constrain'])) $query .= ' AND '.$sub_table['Constrain'];

	$sub_ids = $this->Conn->GetCol($query);

	if ( is_array(getArrayValue($sub_table, 'ForeignKey')) ) {
	// $sub_ids could containt newly cloned items, we need to remove it here
	// to escape double cloning

	$cloned_ids = getArrayValue($this->AlreadyProcessed, $sub_table['TableName']);
	if ( !$cloned_ids ) $cloned_ids = Array();
	$new_ids = array_values($cloned_ids);
	$sub_ids = array_diff($sub_ids, $new_ids);
	}

	$parent_key = $object->GetDBField($parent_key_field);

	$this->CloneItems($sub_table['Prefix'], $special, $sub_ids, $sub_table, $parent_key, $master['Prefix']);
	}
	}
	}
	}

	if (!$ids) {
	$this->savedIDs[$prefix.($special ? '.' : '').$special] = Array();
	}

	return $this->savedIDs[$prefix.($special ? '.' : '').$special];
	}

	function DeleteItems($prefix, $special, $ids, $master=null, $foreign_key=null)
	{
	if (!isset($master)) $master = $this->Tables;
	if( strpos($prefix,'.') !== false ) list($prefix,$special) = explode('.', $prefix, 2);

	$prefix_special = rtrim($prefix.'.'.$special, '.');

	//recalling by different name, because we may get kDBList, if we recall just by prefix
	$recall_prefix = $prefix_special.($special ? '' : '.').'-item';
	$object =& $this->Application->recallObject($recall_prefix, $prefix, Array('skip_autoload' => true));

	foreach ($ids as $id)
	{
	$object->Load($id);
	$original_values = $object->FieldValues;
	if( !$object->Delete($id) ) continue;

	if ( is_array(getArrayValue($master, 'SubTables')) ) {
	foreach($master['SubTables'] as $sub_table) {
	if (!getArrayValue($sub_table, 'AutoDelete')) continue;
	$sub_TableName = ($object->mode == 't') ? $this->GetTempName($sub_table['TableName']) : $sub_table['TableName'];

	$foreign_key_field = is_array($sub_table['ForeignKey']) ? getArrayValue($sub_table, 'ForeignKey', $master['Prefix']) : $sub_table['ForeignKey'];
	$parent_key_field = is_array($sub_table['ParentTableKey']) ? getArrayValue($sub_table, 'ParentTableKey', $master['Prefix']) : $sub_table['ParentTableKey'];

	if (!$foreign_key_field \|\| !$parent_key_field) continue;

	$query = 'SELECT '.$sub_table['IdField'].' FROM '.$sub_TableName.'
	WHERE '.$foreign_key_field.' = '.$original_values[$parent_key_field];

	$sub_ids = $this->Conn->GetCol($query);

	$parent_key = $object->GetDBField(is_array($sub_table['ParentTableKey']) ? $sub_table['ParentTableKey'][$prefix] : $sub_table['ParentTableKey']);

	- $this->DeleteItems($sub_table['Prefix'], '', $sub_ids, $sub_table, $parent_key);
	+ $this->DeleteItems($sub_table['Prefix'], $special, $sub_ids, $sub_table, $parent_key);
	}
	}

	}
	}

	function DoCopyLiveToTemp($master, $ids, $parent_prefix=null)
	{
	// when two tables refers the same table as sub-sub-table, and ForeignKey and ParentTableKey are arrays
	// the table will be first copied by first sub-table, then dropped and copied over by last ForeignKey in the array
	// this should not do any problems :)
	if ( !preg_match("/.*\.[0-9]+/", $master['Prefix']) ) {
	if( $this->DropTempTable($master['TableName']) )
	{
	$this->CreateTempTable($master['TableName']);
	}
	}

	if (is_array($ids)) {
	$ids = join(',', $ids);
	}

	$table_sig = $master['TableName'].(isset($master['Constrain']) ? $master['Constrain'] : '');

	if ($ids != '' && !in_array($table_sig, $this->CopiedTables)) {
	if ( getArrayValue($master, 'ForeignKey') ) {
	if ( is_array($master['ForeignKey']) ) {
	$key_field = $master['ForeignKey'][$parent_prefix];
	}
	else {
	$key_field = $master['ForeignKey'];
	}
	}
	else {
	$key_field = $master['IdField'];
	}

	$query = 'INSERT INTO '.$this->GetTempName($master['TableName']).'
	SELECT * FROM '.$master['TableName'].'
	WHERE '.$key_field.' IN ('.$ids.')';
	if (isset($master['Constrain'])) $query .= ' AND '.$master['Constrain'];
	$this->Conn->Query($query);

	$this->CopiedTables[] = $table_sig;

	$query = 'SELECT '.$master['IdField'].' FROM '.$master['TableName'].'
	WHERE '.$key_field.' IN ('.$ids.')';
	if (isset($master['Constrain'])) $query .= ' AND '.$master['Constrain'];
	$this->RaiseEvent( 'OnAfterCopyToTemp', $master['Prefix'], '', $this->Conn->GetCol($query) );
	}

	if ( getArrayValue($master, 'SubTables') ) {
	foreach ($master['SubTables'] as $sub_table) {

	$parent_key = is_array($sub_table['ParentTableKey']) ? $sub_table['ParentTableKey'][$master['Prefix']] : $sub_table['ParentTableKey'];
	if (!$parent_key) continue;

	if ( $ids != '' && $parent_key != $key_field ) {
	$query = 'SELECT '.$parent_key.' FROM '.$master['TableName'].'
	WHERE '.$key_field.' IN ('.$ids.')';
	$sub_foreign_keys = join(',', $this->Conn->GetCol($query));
	}
	else {
	$sub_foreign_keys = $ids;
	}
	$this->DoCopyLiveToTemp($sub_table, $sub_foreign_keys, $master['Prefix']);
	}
	}
	}

	function GetForeignKeys($master, $sub_table, $live_id, $temp_id=null)
	{
	$mode = 1; //multi
	if (!is_array($live_id)) {
	$live_id = Array($live_id);
	$mode = 2; //single
	}
	if (isset($temp_id) && !is_array($temp_id)) $temp_id = Array($temp_id);

	if ( isset($sub_table['ParentTableKey']) ) {
	if ( is_array($sub_table['ParentTableKey']) ) {
	$parent_key_field = $sub_table['ParentTableKey'][$master['Prefix']];
	}
	else {
	$parent_key_field = $sub_table['ParentTableKey'];
	}
	}
	else {
	$parent_key_field = $master['IdField'];
	}

	if ( $cached = getArrayValue($this->FKeysCache, $master['TableName'].'.'.$parent_key_field) ) {
	if ( array_key_exists(serialize($live_id), $cached) ) {
	list($live_foreign_key, $temp_foreign_key) = $cached[serialize($live_id)];
	if ($mode == 1) {
	return $live_foreign_key;
	}
	else {
	return Array($live_foreign_key[0], $temp_foreign_key[0]);
	}
	}
	}

	if ($parent_key_field != $master['IdField']) {
	$query = 'SELECT '.$parent_key_field.' FROM '.$master['TableName'].'
	WHERE '.$master['IdField'].' IN ('.join(',', $live_id).')';
	$live_foreign_key = $this->Conn->GetCol($query);

	if (isset($temp_id)) {
	// because DoCopyTempToOriginal resets negative IDs to 0 in temp table (one by one) before copying to live
	$temp_key = $temp_id < 0 ? 0 : $temp_id;
	$query = 'SELECT '.$parent_key_field.' FROM '.$this->GetTempName($master['TableName']).'
	WHERE '.$master['IdField'].' IN ('.join(',', $temp_key).')';
	$temp_foreign_key = $this->Conn->GetCol($query);
	}
	else {
	$temp_foreign_key = Array();
	}
	}
	else {
	$live_foreign_key = $live_id;
	$temp_foreign_key = $temp_id;
	}

	$this->FKeysCache[$master['TableName'].'.'.$parent_key_field][serialize($live_id)] = Array($live_foreign_key, $temp_foreign_key);

	if ($mode == 1) {
	return $live_foreign_key;
	}
	else {
	return Array($live_foreign_key[0], $temp_foreign_key[0]);
	}
	}

	function DoCopyTempToOriginal($master, $parent_prefix = null, $current_ids = Array())
	{
	if (!$current_ids) {
	$query = 'SELECT '.$master['IdField'].' FROM '.$this->GetTempName($master['TableName']);
	if (isset($master['Constrain'])) $query .= ' WHERE '.$master['Constrain'];
	$current_ids = $this->Conn->GetCol($query);
	}

	$table_sig = $master['TableName'].(isset($master['Constrain']) ? $master['Constrain'] : '');

	if ($current_ids) {
	// delete all ids from live table - for MasterTable ONLY!
	// because items from Sub Tables get deteleted in CopySubTablesToLive !BY ForeignKey!
	if ($master['TableName'] == $this->MasterTable) {
	$this->RaiseEvent( 'OnBeforeDeleteFromLive', $master['Prefix'], '', $current_ids );

	$query = 'DELETE FROM '.$master['TableName'].' WHERE '.$master['IdField'].' IN ('.join(',', $current_ids).')';
	$this->Conn->Query($query);
	}

	if ( getArrayValue($master, 'SubTables') ) {
	if( in_array($table_sig, $this->CopiedTables) \|\| $this->FinalRefs[$table_sig] != $master['TableId'] ) return;

	foreach($current_ids AS $id)
	{
	$this->RaiseEvent( 'OnBeforeCopyToLive', $master['Prefix'], '', Array($id) );

	//reset negative ids to 0, so autoincrement in live table works fine
	if($id < 0)
	{
	$query = 'UPDATE '.$this->GetTempName($master['TableName']).'
	SET '.$master['IdField'].' = 0
	WHERE '.$master['IdField'].' = '.$id;
	if (isset($master['Constrain'])) $query .= ' AND '.$master['Constrain'];
	$this->Conn->Query($query);
	$id_to_copy = 0;
	}
	else
	{
	$id_to_copy = $id;
	}

	//copy current id_to_copy (0 for new or real id) to live table
	$query = 'INSERT INTO '.$master['TableName'].'
	SELECT * FROM '.$this->GetTempName($master['TableName']).'
	WHERE '.$master['IdField'].' = '.$id_to_copy;
	$this->Conn->Query($query);
	$insert_id = $id_to_copy == 0 ? $this->Conn->getInsertID() : $id_to_copy;

	$this->saveID($master['Prefix'], '', array($id => $insert_id));
	$this->RaiseEvent( 'OnAfterCopyToLive', $master['Prefix'], '', Array($insert_id), null, array('temp_id' => $id) );

	$this->UpdateForeignKeys($master, $insert_id, $id);

	//delete already copied record from master temp table
	$query = 'DELETE FROM '.$this->GetTempName($master['TableName']).'
	WHERE '.$master['IdField'].' = '.$id_to_copy;
	if (isset($master['Constrain'])) $query .= ' AND '.$master['Constrain'];
	$this->Conn->Query($query);
	}

	$this->CopiedTables[] = $table_sig;

	// when all of ids in current master has been processed, copy all sub-tables data
	$this->CopySubTablesToLive($master, $current_ids);
	}
	elseif( !in_array($table_sig, $this->CopiedTables) && ($this->FinalRefs[$table_sig] == $master['TableId']) ) { //If current master doesn't have sub-tables - we could use mass operations
	// We don't need to delete items from live here, as it get deleted in the beggining of the method for MasterTable
	// or in parent table processing for sub-tables
	$this->RaiseEvent('OnBeforeCopyToLive', $master['Prefix'], '', $current_ids);

	$live_ids = array();
	foreach ($current_ids as $an_id) {
	if ($an_id > 0) {
	$live_ids[$an_id] = $an_id;
	// positive (already live) IDs will be copied in on query all togather below,
	// so we just store it here
	continue;
	}
	else { // zero or negaitve ids should be copied one by one to get their InsertId
	// reseting to 0 so it get inserted into live table with autoincrement
	$query = 'UPDATE '.$this->GetTempName($master['TableName']).'
	SET '.$master['IdField'].' = 0
	WHERE '.$master['IdField'].' = '.$an_id;
	// constrain is not needed here because ID is already unique
	$this->Conn->Query($query);

	// copying
	$query = 'INSERT INTO '.$master['TableName'].'
	SELECT * FROM '.$this->GetTempName($master['TableName']).'
	WHERE '.$master['IdField'].' = 0';
	$this->Conn->Query($query);
	$live_ids[$an_id] = $this->Conn->getInsertID(); //storing newly created live id

	//delete already copied record from master temp table
	$query = 'DELETE FROM '.$this->GetTempName($master['TableName']).'
	WHERE '.$master['IdField'].' = 0';
	$this->Conn->Query($query);

	$this->UpdateChangeLogForeignKeys($master, $live_ids[$an_id], $an_id);
	}
	}

	// copy ALL records to live table
	$query = 'INSERT INTO '.$master['TableName'].'
	SELECT * FROM '.$this->GetTempName($master['TableName']);
	if (isset($master['Constrain'])) $query .= ' WHERE '.$master['Constrain'];
	$this->Conn->Query($query);

	$this->CopiedTables[] = $table_sig;
	$this->RaiseEvent('OnAfterCopyToLive', $master['Prefix'], '', $live_ids);

	$this->saveID($master['Prefix'], '', $live_ids);

	// no need to clear temp table - it will be dropped by next statement
	}
	}

	if ($this->FinalRefs[ $master['TableName'] ] != $master['TableId']) return;

	/*if ( is_array(getArrayValue($master, 'ForeignKey')) ) { //if multiple ForeignKeys
	if ( $master['ForeignKey'][$parent_prefix] != end($master['ForeignKey']) ) {
	return; // Do not delete temp table if not all ForeignKeys have been processed (current is not the last)
	}
	}*/
	$this->DropTempTable($master['TableName']);
	$this->Application->resetCounters($master['TableName']);

	if (!isset($this->savedIDs[ $master['Prefix'] ])) {
	$this->savedIDs[ $master['Prefix'] ] = Array();
	}

	return $this->savedIDs[ $master['Prefix'] ];
	}

	/**
	* Create separate connection for locking purposes
	*
	* @return kDBConnection
	*/
	function &_getSeparateConnection()
	{
	static $connection = null;

	if (!isset($connection)) {
	$connection = new kDBConnection(SQL_TYPE, Array(&$this->Application, 'handleSQLError') );
	$connection->debugMode = $this->Application->isDebugMode();
	$connection->Connect(SQL_SERVER, SQL_USER, SQL_PASS, SQL_DB, true);
	}

	return $connection;
	}

	function UpdateChangeLogForeignKeys($master, $live_id, $temp_id)
	{
	if ($live_id == $temp_id) {
	return ;
	}

	$prefix = $master['Prefix'];
	$main_prefix = $this->Application->GetTopmostPrefix($prefix);
	$ses_var_name = $main_prefix . '_changes_' . $this->Application->GetTopmostWid($this->Prefix);
	$changes = $this->Application->RecallVar($ses_var_name);
	$changes = $changes ? unserialize($changes) : Array ();

	foreach ($changes as $key => $rec) {
	if ($rec['Prefix'] == $prefix && $rec['ItemId'] == $temp_id) {
	// main item change log record
	$changes[$key]['ItemId'] = $live_id;
	}

	if ($rec['MasterPrefix'] == $prefix && $rec['MasterId'] == $temp_id) {
	// sub item change log record
	$changes[$key]['MasterId'] = $live_id;
	}

	if (in_array($prefix, $rec['ParentPrefix']) && $rec['ParentId'][$prefix] == $temp_id) {
	// parent item change log record
	$changes[$key]['ParentId'][$prefix] = $live_id;

	if (array_key_exists('DependentFields', $rec)) {
	// these are fields from table of $rec['Prefix'] table!
	// when one of dependent fields goes into idfield of it's parent item, that was changed
	$parent_table_key = $this->Application->getUnitOption($rec['Prefix'], 'ParentTableKey');
	$parent_table_key = is_array($parent_table_key) ? $parent_table_key[$prefix] : $parent_table_key;

	if ($parent_table_key == $master['IdField']) {
	$foreign_key = $this->Application->getUnitOption($rec['Prefix'], 'ForeignKey');
	$foreign_key = is_array($foreign_key) ? $foreign_key[$prefix] : $foreign_key;

	$changes[$key]['DependentFields'][$foreign_key] = $live_id;
	}
	}
	}
	}

	$this->Application->StoreVar($ses_var_name, serialize($changes));
	}

	function UpdateForeignKeys($master, $live_id, $temp_id)
	{
	$this->UpdateChangeLogForeignKeys($master, $live_id, $temp_id);

	foreach ($master['SubTables'] as $sub_table) {
	$foreign_key_field = is_array($sub_table['ForeignKey']) ? getArrayValue($sub_table, 'ForeignKey', $master['Prefix']) : $sub_table['ForeignKey'];

	if (!$foreign_key_field) {
	continue;
	}

	list ($live_foreign_key, $temp_foreign_key) = $this->GetForeignKeys($master, $sub_table, $live_id, $temp_id);

	//Update ForeignKey in sub TEMP table
	if ($live_foreign_key != $temp_foreign_key) {
	$query = 'UPDATE '.$this->GetTempName($sub_table['TableName']).'
	SET '.$foreign_key_field.' = '.$live_foreign_key.'
	WHERE '.$foreign_key_field.' = '.$temp_foreign_key;
	if (isset($sub_table['Constrain'])) $query .= ' AND '.$sub_table['Constrain'];
	$this->Conn->Query($query);
	}
	}
	}

	function CopySubTablesToLive($master, $current_ids) {
	foreach ($master['SubTables'] as $sub_table) {

	$table_sig = $sub_table['TableName'].(isset($sub_table['Constrain']) ? $sub_table['Constrain'] : '');

	// delete records from live table by foreign key, so that records deleted from temp table
	// get deleted from live
	if (count($current_ids) > 0 && !in_array($table_sig, $this->CopiedTables) ) {
	$foreign_key_field = is_array($sub_table['ForeignKey']) ? getArrayValue($sub_table, 'ForeignKey', $master['Prefix']) : $sub_table['ForeignKey'];
	if (!$foreign_key_field) continue;
	$foreign_keys = $this->GetForeignKeys($master, $sub_table, $current_ids);
	if (count($foreign_keys) > 0) {
	$query = 'SELECT '.$sub_table['IdField'].' FROM '.$sub_table['TableName'].'
	WHERE '.$foreign_key_field.' IN ('.join(',', $foreign_keys).')';
	if (isset($sub_table['Constrain'])) $query .= ' AND '.$sub_table['Constrain'];

	if ( $this->RaiseEvent( 'OnBeforeDeleteFromLive', $sub_table['Prefix'], '', $this->Conn->GetCol($query), $foreign_keys ) ){
	$query = 'DELETE FROM '.$sub_table['TableName'].'
	WHERE '.$foreign_key_field.' IN ('.join(',', $foreign_keys).')';
	if (isset($sub_table['Constrain'])) $query .= ' AND '.$sub_table['Constrain'];
	$this->Conn->Query($query);
	}
	}
	}
	//sub_table passed here becomes master in the method, and recursively updated and copy its sub tables
	$this->DoCopyTempToOriginal($sub_table, $master['Prefix']);
	}
	}

	function RaiseEvent($name, $prefix, $special, $ids, $foreign_key = null, $add_params = null)
	{
	if ( !is_array($ids) ) return ;

	$event_key = $prefix.($special ? '.' : '').$special.':'.$name;
	$event = new kEvent($event_key);
	if (isset($foreign_key)) {
	$event->setEventParam('foreign_key', $foreign_key);
	}

	$set_temp_id = ($name == 'OnAfterCopyToLive') && (!is_array($add_params) \|\| !array_key_exists('temp_id', $add_params));

	foreach($ids as $index => $id) {
	$event->setEventParam('id', $id);

	if ($set_temp_id) {
	$event->setEventParam('temp_id', $index);
	}

	if (is_array($add_params)) {
	foreach ($add_params as $name => $val) {
	$event->setEventParam($name, $val);
	}
	}

	$this->Application->HandleEvent($event);
	}

	return $event->status == erSUCCESS;
	}

	function DropTempTable($table)
	{
	if( in_array($table, $this->DroppedTables) ) return false;
	$query = sprintf("DROP TABLE IF EXISTS %s",
	$this->GetTempName($table)
	);
	array_push($this->DroppedTables, $table);
	$this->DroppedTables = array_unique($this->DroppedTables);
	$this->Conn->Query($query);

	return true;
	}

	function PrepareEdit()
	{
	$this->DoCopyLiveToTemp($this->Tables, $this->Tables['IDs']);
	if ($this->Application->getUnitOption($this->Tables['Prefix'],'CheckSimulatniousEdit')) {
	$this->CheckSimultaniousEdit();
	}
	}

	function SaveEdit($master_ids = Array())
	{
	// SessionKey field is required for deleting records from expired sessions
	$conn =& $this->_getSeparateConnection();

	$sleep_count = 0;
	do {
	// aquire lock
	$conn->ChangeQuery('LOCK TABLES '.TABLE_PREFIX.'Semaphores WRITE');

	$sql = 'SELECT SessionKey
	FROM ' . TABLE_PREFIX . 'Semaphores
	WHERE (MainPrefix = ' . $conn->qstr($this->Tables['Prefix']) . ')';
	$another_coping_active = $conn->GetOne($sql);

	if ($another_coping_active) {
	// another user is coping data from temp table to live -> release lock and try again after 1 second
	$conn->ChangeQuery('UNLOCK TABLES');
	$sleep_count++;
	sleep(1);
	}
	} while ($another_coping_active && ($sleep_count <= 30));

	if ($sleep_count > 30) {
	// another coping process failed to finished in 30 seconds
	$error_message = $this->Application->Phrase('la_error_TemporaryTableCopyingFailed');
	$this->Application->SetVar('_temp_table_message', $error_message);

	return false;
	}

	// mark, that we are coping from temp to live right now, so other similar attempt (from another script) will fail
	$fields_hash = Array (
	'SessionKey' => $this->Application->GetSID(),
	'Timestamp' => adodb_mktime(),
	'MainPrefix' => $this->Tables['Prefix'],
	);

	$conn->doInsert($fields_hash, TABLE_PREFIX.'Semaphores');
	$semaphore_id = $conn->getInsertID();

	// unlock table now to prevent permanent lock in case, when coping will end with SQL error in the middle
	$conn->ChangeQuery('UNLOCK TABLES');

	$ids = $this->DoCopyTempToOriginal($this->Tables, null, $master_ids);

	// remove mark, that we are coping from temp to live
	$conn->Query('LOCK TABLES '.TABLE_PREFIX.'Semaphores WRITE');

	$sql = 'DELETE FROM ' . TABLE_PREFIX . 'Semaphores
	WHERE SemaphoreId = ' . $semaphore_id;
	$conn->ChangeQuery($sql);

	$conn->ChangeQuery('UNLOCK TABLES');

	return $ids;
	}

	function CancelEdit($master=null)
	{
	if (!isset($master)) $master = $this->Tables;
	$this->DropTempTable($master['TableName']);
	if ( getArrayValue($master, 'SubTables') ) {
	foreach ($master['SubTables'] as $sub_table) {
	$this->CancelEdit($sub_table);
	}
	}
	}

	/**
	* Checks, that someone is editing selected records and returns true, when no one.
	*
	* @param Array $ids
	*
	* @return bool
	*/
	function CheckSimultaniousEdit($ids = null)
	{
	$tables = $this->Conn->GetCol('SHOW TABLES');
	$mask_edit_table = '/' . TABLE_PREFIX . 'ses_(.*)_edit_' . $this->MasterTable . '$/';

	$my_sid = $this->Application->GetSID();
	$my_wid = $this->Application->GetVar('m_wid');
	$ids = implode(',', isset($ids) ? $ids : $this->Tables['IDs']);
	$sids = Array ();
	if (!$ids) {
	return true;
	}

	foreach ($tables as $table) {
	if ( preg_match($mask_edit_table, $table, $rets) ) {
	$sid = preg_replace('/(.)_(.)/', '\\1', $rets[1]); // remove popup's wid from sid
	if ($sid == $my_sid) {
	if ($my_wid) {
	// using popups for editing
	if (preg_replace('/(.)_(.)/', '\\2', $rets[1]) == $my_wid) {
	// don't count window, that is being opened right now
	continue;
	}
	}
	else {
	// not using popups for editing -> don't count my session tables
	continue;
	}
	}

	$sql = 'SELECT COUNT(' . $this->Tables['IdField'] . ')
	FROM ' . $table . '
	WHERE ' . $this->Tables['IdField'] . ' IN (' . $ids . ')';
	$found = $this->Conn->GetOne($sql);

	if (!$found \|\| in_array($sid, $sids)) {
	continue;
	}

	$sids[] = $sid;
	}
	}

	if ($sids) {
	// detect who is it
	$sql = 'SELECT
	CONCAT(IF (s.PortalUserId = ' . USER_ROOT . ', \'root\',
	IF (s.PortalUserId = ' . USER_GUEST . ', \'Guest\',
	CONCAT(FirstName, \' \', LastName, \' (\', Login, \')\')
	)
	), \' IP: \', s.IpAddress, \'\') FROM ' . TABLE_PREFIX . 'UserSession AS s
	LEFT JOIN ' . TABLE_PREFIX . 'PortalUser AS u
	ON u.PortalUserId = s.PortalUserId
	WHERE s.SessionKey IN (' . implode(',', $sids) . ')';
	$users = $this->Conn->GetCol($sql);

	if ($users) {
	$this->Application->SetVar('_simultanious_edit_message',
	sprintf($this->Application->Phrase('la_record_being_edited_by'), join(",\n", $users))
	);

	return false;
	}
	}

	return true;
	}

	}
	\ No newline at end of file
	Index: branches/5.1.x/core/units/users/users_event_handler.php
	===================================================================
	--- branches/5.1.x/core/units/users/users_event_handler.php (revision 14432)
	+++ branches/5.1.x/core/units/users/users_event_handler.php (revision 14433)
	@@ -1,1693 +1,1694 @@
	<?php
	/**
	* @version $Id$
	* @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 UsersEventHandler extends kDBEventHandler
	{
	/**
	* Allows to override standart permission mapping
	*
	*/
	function mapPermissions()
	{
	parent::mapPermissions();
	$permissions = Array (
	// admin
	'OnSetPersistantVariable' => Array('self' => 'view'), // because setting to logged in user only
	'OnUpdateRootPassword' => Array('self' => true),
	'OnUpdatePassword' => Array('self' => true),

	// front
	'OnRefreshForm' => Array('self' => true),

	'OnForgotPassword' => Array('self' => true),
	'OnResetPassword' => Array('self' => true),
	'OnResetPasswordConfirmed' => Array('self' => true),

	'OnSubscribeQuery' => Array('self' => true),
	'OnSubscribeUser' => Array('self' => true),

	'OnRecommend' => Array('self' => true),

	'OnItemBuild' => Array('self' => true),
	'OnMassResetSettings' => Array('self' => 'edit'),
	'OnMassCloneUsers' => Array('self' => 'add'),
	);

	$this->permMapping = array_merge($this->permMapping, $permissions);
	}

	/**
	* Shows only admins when required
	*
	* @param kEvent $event
	*/
	function SetCustomQuery(&$event)
	{
	$object =& $event->getObject();
	/* @var $object kDBList */

	if ($event->Special == 'admins') {
	$object->addFilter('primary_filter', 'ug.GroupId = 11');
	}

	if ($event->Special == 'regular') {
	$object->addFilter('primary_filter', 'ug.GroupId <> 11 OR ug.GroupId IS NULL');
	}

	if (!$this->Application->isAdminUser) {
	$object->addFilter('status_filter', '%1$s.Status = '.STATUS_ACTIVE);
	}

	if ($event->Special == 'online') {
	$object->addFilter('online_users_filter', 's.PortalUserId IS NOT NULL');
	}

	if ($event->Special == 'group') {
	$group_id = $this->Application->GetVar('g_id');
	if ($group_id !== false) {
	// show only users, that user doesn't belong to current group
	$table_name = $this->Application->GetTempName(TABLE_PREFIX.'UserGroup', 'prefix:g');
	$sql = 'SELECT PortalUserId
	FROM ' . $table_name . '
	WHERE GroupId = ' . (int)$group_id;
	$user_ids = $this->Conn->GetCol($sql);
	// array_push($user_ids); // Guest & Everyone groups are set dynamically
	if ($user_ids) {
	$object->addFilter('already_member_filter', '%1$s.PortalUserId NOT IN ('.implode(',', $user_ids).')');
	}
	}
	}
	}

	/**
	* Checks permissions of user
	*
	* @param kEvent $event
	*/
	function CheckPermission(&$event)
	{
	if ($event->Name == 'OnLogin' \|\| $event->Name == 'OnLogout') {
	// permission is checked in OnLogin event directly
	return true;
	}

	if (!$this->Application->isAdminUser) {
	$user_id = $this->Application->RecallVar('user_id');
	$items_info = $this->Application->GetVar($event->getPrefixSpecial(true));

	if ($event->Name == 'OnCreate' && $user_id == USER_GUEST) {
	// "Guest" can create new users
	return true;
	}

	if ($event->Name == 'OnUpdate' && $user_id > 0) {
	$user_dummy =& $this->Application->recallObject($event->Prefix.'.-item', null, Array('skip_autoload' => true));
	foreach ($items_info as $id => $field_values) {
	if ($id != $user_id) {
	// registered users can update their record only
	return false;
	}

	$user_dummy->Load($id);
	$status_field = array_shift($this->Application->getUnitOption($event->Prefix, 'StatusField'));

	if ($user_dummy->GetDBField($status_field) != STATUS_ACTIVE) {
	// not active user is not allowed to update his record (he could not activate himself manually)
	return false;
	}

	if (isset($field_values[$status_field]) && $user_dummy->GetDBField($status_field) != $field_values[$status_field]) {
	// user can't change status by himself
	return false;
	}
	}
	return true;
	}

	if ($event->Name == 'OnUpdate' && $user_id <= 0) {
	// guests are not allowed to update their record, because they don't have it :)
	return false;
	}
	}

	return parent::CheckPermission($event);
	}

	/**
	* Handles session expiration (redirects to valid template)
	*
	* @param kEvent $event
	*/
	function OnSessionExpire(&$event)
	{
	$this->Application->resetCounters('UserSession');

	// place 2 of 2 (also in kHTTPQuery::getRedirectParams)
	$admin_url_params = Array (
	'm_cat_id' => 0, // category means nothing on admin login screen
	'm_wid' => '', // remove wid, otherwise parent window may add wid to its name breaking all the frameset (for <a> targets)
	'pass' => 'm', // don't pass any other (except "m") prefixes to admin session expiration template
	'expired' => 1, // expiration mark to show special error on login screen
	'no_pass_through' => 1, // this way kApplication::HREF won't add them again
	);

	if ($this->Application->isAdmin) {
	$this->Application->Redirect('index', $admin_url_params, '', 'index.php');
	}

	if ($this->Application->GetVar('admin') == 1) {
	// Front-End showed in admin's right frame
	$session_admin =& $this->Application->recallObject('Session.admin');
	/* @var $session_admin Session */

	if (!$session_admin->LoggedIn()) {
	// front-end session created from admin session & both expired
	$this->Application->DeleteVar('admin');
	$this->Application->Redirect('index', $admin_url_params, '', 'admin/index.php');
	}
	}

	// Front-End session expiration
	$get = $this->Application->HttpQuery->getRedirectParams();
	$t = $this->Application->GetVar('t');
	$get['js_redirect'] = $this->Application->ConfigValue('UseJSRedirect');
	$this->Application->Redirect($t ? $t : 'index', $get);
	}

	/**
	* [AGENT] Deletes expired sessions
	*
	* @param kEvent $event
	*/
	function OnDeleteExpiredSessions(&$event)
	{
	if (defined('IS_INSTALL') && IS_INSTALL) {
	return ;
	}

	$this->Application->Session->DeleteExpired();
	}

	/**
	* Checks user data and logs it in if allowed
	*
	* @param kEvent $event
	*/
	function OnLogin(&$event)
	{
	$email_as_login = $this->Application->ConfigValue('Email_As_Login');
	$username = $this->Application->GetVar($email_as_login && !$this->Application->isAdmin ? 'email' : 'login');
	$password = $this->Application->GetVar('password');
	$rember_login = $this->Application->GetVar('cb_remember_login') == 1;

	$user_helper =& $this->Application->recallObject('UserHelper');
	/* @var $user_helper UserHelper */

	$user_helper->event =& $event;
	$result = $user_helper->loginUser($username, $password, false, $rember_login);

	if ($result != LOGIN_RESULT_OK) {
	$object =& $user_helper->getUserObject();

	if ($result == LOGIN_RESULT_NO_PERMISSION) {
	$object->SetError('ValidateLogin', 'no_permission', 'la_no_permissions');
	}
	else {
	$object->SetID(USER_GUEST);
	$object->SetError('ValidateLogin', 'invalid_password', 'la_invalid_password');
	}

	$event->status = erFAIL;
	}
	}

	/**
	* [HOOK] Auto-Logins Front-End user when "Remember Login" cookie is found
	*
	* @param kEvent $event
	*/
	function OnAutoLoginUser(&$event)
	{
	$remember_login_cookie = $this->Application->GetVar('remember_login');

	if (!$remember_login_cookie \|\| $this->Application->isAdmin \|\| $this->Application->LoggedIn()) {
	return ;
	}

	$user_helper =& $this->Application->recallObject('UserHelper');
	/* @var $user_helper UserHelper */

	$user_helper->loginUser('', '', false, false, $remember_login_cookie);
	}

	/**
	* Called when user logs in using old in-portal
	*
	* @param kEvent $event
	*/
	function OnInpLogin(&$event)
	{
	$sync_manager =& $this->Application->recallObjectP('UsersSyncronizeManager', null, Array(), 'InPortalSyncronize');
	$sync_manager->performAction('LoginUser', $event->getEventParam('user'), $event->getEventParam('pass') );

	if ($event->redirect && is_string($event->redirect)) {
	// some real template specified instead of true
	$this->Application->Redirect($event->redirect, $event->redirect_params);
	}
	}

	/**
	* Called when user logs in using old in-portal
	*
	* @param kEvent $event
	*/
	function OnInpLogout(&$event)
	{
	$sync_manager =& $this->Application->recallObjectP('UsersSyncronizeManager', null, Array(), 'InPortalSyncronize');
	$sync_manager->performAction('LogoutUser');
	}

	function OnLogout(&$event)
	{
	$user_helper =& $this->Application->recallObject('UserHelper');
	/* @var $user_helper UserHelper */

	$user_helper->event =& $event;
	$user_helper->logoutUser();
	}

	/**
	* Redirects user after succesfull registration to confirmation template (on Front only)
	*
	* @param kEvent $event
	*/
	function OnAfterItemCreate(&$event)
	{
	parent::OnAfterItemCreate($event);

	$this->saveUserImages($event);

	if ($this->Application->GetVar('skip_set_primary')) return;
	$is_subscriber = $this->Application->GetVar('IsSubscriber');
	if(!$is_subscriber)
	{
	$object =& $event->getObject();

	$ug_table = TABLE_PREFIX.'UserGroup';
	if ($object->mode == 't') {
	$ug_table = $this->Application->GetTempName($ug_table, 'prefix:'.$event->Prefix);
	}

	$sql = 'UPDATE '.$ug_table.'
	SET PrimaryGroup = 0
	WHERE PortalUserId = '.$object->GetDBField('PortalUserId');
	$this->Conn->Query($sql);

	// set primary group to user
	if ($this->Application->isAdminUser && $this->Application->GetVar('user_group')) {
	// while in admin you can set any group for new users
	$group_id = $this->Application->GetVar('user_group');
	}
	else {
	$group_id = $object->GetDBField('UserGroup');

	if ($group_id) {
	// check, that group is allowed for Front-End
	$sql = 'SELECT GroupId
	FROM ' . TABLE_PREFIX . 'PortalGroup
	WHERE GroupId = ' . (int)$group_id . ' AND FrontRegistration = 1';
	$group_id = $this->Conn->GetOne($sql);
	}

	if (!$group_id) {
	// when group not selected -> use default group
	$group_id = $this->Application->ConfigValue('User_NewGroup');
	}
	}

	$sql = 'REPLACE INTO '.$ug_table.'(PortalUserId,GroupId,PrimaryGroup) VALUES (%s,%s,1)';
	$this->Conn->Query( sprintf($sql, $object->GetID(), $group_id) );
	}
	}

	/**
	* Login user if possible, if not then redirect to corresponding template
	*
	* @param kEvent $event
	*/
	function autoLoginUser(&$event)
	{
	$object =& $event->getObject();
	$this->Application->SetVar('u.current_id', $object->GetID());

	if ( $object->GetDBField('Status') == STATUS_ACTIVE ) {
	$user_helper =& $this->Application->recallObject('UserHelper');
	/* @var $user_helper UserHelper */

	if ( $user_helper->checkLoginPermission() ) {
	$user_helper->loginUserById( $object->GetID() );
	}
	}
	}


	/**
	* When creating user & user with such email exists then force to use OnUpdate insted of ?
	*
	* @param kEvent $event
	*/
	function OnSubstituteSubscriber(&$event)
	{
	$ret = false;
	$object =& $event->getObject( Array('skip_autoload' => true) );
	$items_info = $this->Application->GetVar( $event->getPrefixSpecial(true) );
	if($items_info)
	{
	list($id, $field_values) = each($items_info);
	$user_email = isset($field_values['Email']) ? $field_values['Email'] : false;
	if($user_email)
	{
	// check if is subscriber
	$verify_user =& $this->Application->recallObject('u.verify', null, Array('skip_autoload' => true) );
	$verify_user->Load($user_email, 'Email');
	if( $verify_user->isLoaded() && $verify_user->isSubscriberOnly() )
	{
	$items_info = Array( $verify_user->GetDBField('PortalUserId') => $field_values );
	$this->Application->SetVar($event->getPrefixSpecial(true), $items_info);
	$ret = true;
	}
	}
	}

	if( isset($event->MasterEvent) )
	{
	$event->MasterEvent->setEventParam('is_subscriber_only', $ret);
	}
	else
	{
	$event->setEventParam('is_subscriber_only', $ret);
	}
	}


	/**
	* Enter description here...
	*
	* @param kEvent $event
	* @param bool $dry_run
	* @return bool
	*/
	function isSubscriberOnly(&$event, $dry_run = false)
	{
	$event->CallSubEvent('OnSubstituteSubscriber');
	$is_subscriber = $event->getEventParam('is_subscriber_only');

	if ($dry_run) {
	return $is_subscriber;
	}

	if ($is_subscriber) {
	$object =& $event->getObject( Array('skip_autoload' => true) );
	$this->OnUpdate($event);

	if ($event->status == erSUCCESS) {
	$this->OnAfterItemCreate($event);
	$object->SendEmailEvents();

	if (!$this->Application->isAdmin && $event->redirect) {
	$this->autoLoginUser($event);
	}
	}
	}

	return $is_subscriber;
	}

	/**
	* Creates new user
	*
	* @param kEvent $event
	*/
	function OnCreate(&$event)
	{
	if (!$this->Application->isAdminUser) {
	$this->setUserStatus($event);
	}

	if (!$this->isSubscriberOnly($event)) {
	$object =& $event->getObject( Array('skip_autoload' => true) );
	/* @var $object kDBItem */
	if ($this->Application->ConfigValue('User_Password_Auto')) {
	$pass = makepassword4(rand(5,8));
	$object->SetField('Password', $pass);
	$object->SetField('VerifyPassword', $pass);
	$this->Application->SetVar('user_password',$pass);
	}
	parent::OnCreate($event);

	$this->Application->SetVar('u.current_id', $object->getID() ); // for affil:OnRegisterAffiliate after hook

	$this->setNextTemplate($event);

	if (!$this->Application->isAdmin && ($event->status == erSUCCESS) && $event->redirect) {
	$object->SendEmailEvents();
	$this->autoLoginUser($event);
	}
	}
	}

	/**
	* Set's new user status based on config options
	*
	* @param kEvent $event
	*/
	function setUserStatus(&$event)
	{
	$object =& $event->getObject( Array('skip_autoload' => true) );

	$new_users_allowed = $this->Application->ConfigValue('User_Allow_New');

	switch ($new_users_allowed) {
	case 1: // Immediate
	$object->SetDBField('Status', STATUS_ACTIVE);
	$next_template = $this->Application->GetVar('registration_confirm_template');
	if ($next_template) {
	$event->redirect = $next_template;
	}
	break;

	case 3: // Upon Approval
	case 4: // Email Activation
	$next_template = $this->Application->GetVar('registration_confirm_pending_template');
	if ($next_template) {
	$event->redirect = $next_template;
	}
	$object->SetDBField('Status', STATUS_PENDING);
	break;

	case 2: // Not Allowed
	$object->SetDBField('Status', STATUS_DISABLED);
	break;
	}
	}

	/**
	* Set's new unique resource id to user
	*
	* @param kEvent $event
	*/
	function OnBeforeItemCreate(&$event)
	{
	parent::OnBeforeItemCreate($event);

	$cs_helper =& $this->Application->recallObject('CountryStatesHelper');
	/* @var $cs_helper kCountryStatesHelper */

	if (!$this->isSubscriberOnly($event, true)) {
	$cs_helper->CheckStateField($event, 'State', 'Country');
	}
	else {
	// no need to make password required when guest user tries to subscribe to mailing
	$this->_makePasswordRequired($event);
	}
	$cs_helper->PopulateStates($event, 'State', 'Country');

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

	if ( $this->Application->ConfigValue('Email_As_Login') ) {
	$field_options = $object->GetFieldOptions('Email');
	$field_options['error_msgs']['unique'] = $this->Application->Phrase('lu_user_and_email_already_exist');
	$object->SetFieldOptions('Email', $field_options);
	}

	$object->setLogin();

	$user_helper =& $this->Application->recallObject('UserHelper');
	/* @var $user_helper UserHelper */

	if (!$user_helper->checkBanRules($object)) {
	$object->SetError('Login', 'banned');
	}
	}

	/**
	* Set's new unique resource id to user
	*
	* @param kEvent $event
	*/
	function OnAfterItemValidate(&$event)
	{
	$object =& $event->getObject();
	$resource_id = $object->GetDBField('ResourceId');
	if (!$resource_id)
	{
	$object->SetDBField('ResourceId', $this->Application->NextResourceId() );
	}
	}


	/**
	* Enter description here...
	*
	* @param kEvent $event
	*/
	function OnRecommend(&$event)
	{
	$friend_email = $this->Application->GetVar('friend_email');
	$friend_name = $this->Application->GetVar('friend_email');

	// used for error reporting only -> rewrite code + theme (by Alex)
	$object =& $this->Application->recallObject('u', null, Array('skip_autoload' => true)); // TODO: change theme too
	/* @var $object UsersItem */

	if (preg_match('/^(' . REGEX_EMAIL_USER . '@' . REGEX_EMAIL_DOMAIN . ')$/i', $friend_email))
	{
	/*$cutoff = adodb_mktime() + (int)$this->Application->ConfigValue('Suggest_MinInterval');
	$sql = 'SELECT *
	FROM ' . TABLE_PREFIX . 'SuggestMail
	WHERE email = ' . $this->Conn->qstr($friend_email) . ' AND sent < ' . $cutoff;
	if ($this->Conn->GetRow($sql) !== false) {
	$object->SetError('Email', 'send_error', 'lu_email_already_suggested');
	$event->status = erFAIL;
	return ;
	}*/

	$send_params = Array ();
	$send_params['to_email'] = $friend_email;
	$send_params['to_name'] = $friend_name;

	$user_id = $this->Application->RecallVar('user_id');
	$email_event =& $this->Application->EmailEventUser('USER.SUGGEST', $user_id, $send_params);
	$email_event =& $this->Application->EmailEventAdmin('USER.SUGGEST');

	if ($email_event->status == erSUCCESS){
	/*$fields_hash = Array (
	'email' => $friend_email,
	'sent' => adodb_mktime(),
	);

	$this->Conn->doInsert($fields_hash, TABLE_PREFIX . 'SuggestMail');*/

	$event->redirect_params = array('opener' => 's', 'pass' => 'all');
	$event->redirect = $this->Application->GetVar('template_success');
	}
	else {
	// $event->redirect_params = array('opener' => 's', 'pass' => 'all');
	// $event->redirect = $this->Application->GetVar('template_fail');

	$object->SetError('Email', 'send_error', 'lu_email_send_error');
	$event->status = erFAIL;
	}
	}
	else {
	$object->SetError('Email', 'invalid_email', 'lu_InvalidEmail');
	$event->status = erFAIL;
	}
	}

	/**
	* Saves address changes and mades no redirect
	*
	* @param kEvent $event
	*/
	function OnUpdateAddress(&$event)
	{
	$object =& $event->getObject( Array('skip_autoload' => true) );

	$items_info = $this->Application->GetVar( $event->getPrefixSpecial(true) );

	if ($items_info) {
	list ($id, $field_values) = each($items_info);
	if ($id > 0) {
	$object->Load($id);
	}

	$object->SetFieldsFromHash($field_values);
	$object->setID($id);
	$object->Validate();
	}

	$cs_helper =& $this->Application->recallObject('CountryStatesHelper');
	/* @var $cs_helper kCountryStatesHelper */

	$cs_helper->PopulateStates($event, 'State', 'Country');

	$event->redirect = false;
	}

	/**
	* Validate subscriber's email & store it to session -> redirect to confirmation template
	*
	* @param kEvent $event
	*/
	function OnSubscribeQuery(&$event)
	{
	$user_email = $this->Application->GetVar('subscriber_email');
	if (preg_match('/^(' . REGEX_EMAIL_USER . '@' . REGEX_EMAIL_DOMAIN . ')$/i', $user_email)) {

	$object =& $this->Application->recallObject($this->Prefix.'.subscriber', null, Array('skip_autoload' => true));
	/* @var $object UsersItem */

	$this->Application->StoreVar('SubscriberEmail', $user_email);

	$object->Load($user_email, 'Email');
	if ($object->isLoaded()) {
	$group_info = $this->GetGroupInfo($object->GetID());
	$event->redirect = $this->Application->GetVar($group_info ? 'unsubscribe_template' : 'subscribe_template');
	}
	else {
	$event->redirect = $this->Application->GetVar('subscribe_template');
	$this->Application->StoreVar('SubscriberEmail', $user_email);
	}
	}
	else {
	// used for error reporting only -> rewrite code + theme (by Alex)
	$object =& $this->Application->recallObject('u', null, Array('skip_autoload' => true)); // TODO: change theme too
	/* @var $object UsersItem */

	$object->SetError('SubscribeEmail', 'invalid_email', 'lu_InvalidEmail');
	$event->status = erFAIL;
	}
	}

	/**
	* Subscribe/Unsubscribe user based on email stored in previous step
	*
	* @param kEvent $event
	*/
	function OnSubscribeUser(&$event)
	{
	$object = &$this->Application->recallObject($this->Prefix.'.subscriber', null, Array('skip_autoload' => true));
	/* @var $object UsersItem */

	$user_email = $this->Application->RecallVar('SubscriberEmail');
	if (preg_match('/^(' . REGEX_EMAIL_USER . '@' . REGEX_EMAIL_DOMAIN . ')$/i', $user_email)) {
	$this->RemoveRequiredFields($object);
	$object->Load($user_email, 'Email');

	if ($object->isLoaded()) {
	$group_info = $this->GetGroupInfo($object->GetID());

	if ($group_info){
	if ($event->getEventParam('no_unsubscribe')) return;

	if ($group_info['PrimaryGroup']){
	- // delete user
	- $object->Delete();
	+ $this->Application->SetVar($object->getPrefixSpecial(true) . '_id', $object->GetID());
	+ $delete_event = new kEvent($object->getPrefixSpecial() . ':OnDelete');
	+ $this->Application->HandleEvent($delete_event);
	}
	else {
	$this->RemoveSubscriberGroup($object->GetID());
	}

	$event->redirect = $this->Application->GetVar('unsubscribe_ok_template');
	}
	else {
	$this->AddSubscriberGroup($object->GetID(), 0);
	$event->redirect = $this->Application->GetVar('subscribe_ok_template');
	}
	}
	else {
	$object->SetField('Email', $user_email);
	$object->SetField('Login', $user_email);
	$object->SetDBField('dob', 1);
	$object->SetDBField('dob_date', 1);
	$object->SetDBField('dob_time', 1);
	$object->SetDBField('Status', STATUS_ACTIVE); // make user subscriber Active by default
	$ip = getenv('HTTP_X_FORWARDED_FOR')?getenv('HTTP_X_FORWARDED_FOR'):getenv('REMOTE_ADDR');
	$object->SetDBField('ip', $ip);

	$this->Application->SetVar('IsSubscriber', 1);

	if ($object->Create()) {
	$this->AddSubscriberGroup($object->GetID(), 1);
	$event->redirect = $this->Application->GetVar('subscribe_ok_template');
	}

	$this->Application->SetVar('IsSubscriber', 0);
	}
	}
	}

	function AddSubscriberGroup($user_id, $is_primary)
	{
	$group_id = $this->Application->ConfigValue('User_SubscriberGroup');
	$sql = 'INSERT INTO ' . TABLE_PREFIX . 'UserGroup
	(PortalUserId, GroupId, PrimaryGroup) VALUES (%s, %s, ' . $is_primary . ')';
	$this->Conn->Query( sprintf($sql, $user_id, $group_id) );

	$this->Application->EmailEventAdmin('USER.SUBSCRIBE');
	$this->Application->EmailEventUser('USER.SUBSCRIBE', $user_id);
	}

	function RemoveSubscriberGroup($user_id)
	{
	$group_id = $this->Application->ConfigValue('User_SubscriberGroup');
	$sql = 'DELETE FROM ' . TABLE_PREFIX . 'UserGroup
	WHERE PortalUserId = ' . $user_id . '
	AND GroupId = ' . $this->Application->ConfigValue('User_SubscriberGroup');
	$this->Conn->Query($sql);

	$this->Application->EmailEventAdmin('USER.UNSUBSCRIBE');
	$this->Application->EmailEventUser('USER.UNSUBSCRIBE', $user_id);
	}

	/**
	* Allows to detect user subscription status (subscribed or not)
	*
	* @param int $user_id
	* @return bool
	*/
	function GetGroupInfo($user_id)
	{
	$sql = 'SELECT * FROM ' . TABLE_PREFIX . 'UserGroup
	WHERE (PortalUserId = ' . $user_id . ')
	AND (GroupId = ' . $this->Application->ConfigValue('User_SubscriberGroup') . ')';
	return $this->Conn->GetRow($sql);
	}

	function OnForgotPassword(&$event)
	{
	$user_object =& $this->Application->recallObject('u.forgot', null, Array('skip_autoload' => true));
	/* @var $user_object UsersItem */

	// used for error reporting only -> rewrite code + theme (by Alex)
	$user_current_object =& $this->Application->recallObject('u', null, Array('skip_autoload' => true)); // TODO: change theme too
	/* @var $user_current_object UsersItem */

	$username = $this->Application->GetVar('username');
	$email = $this->Application->GetVar('email');
	$found = false;
	$allow_reset = true;

	if (strlen($username)) {
	$user_object->Load($username, 'Login');
	if ($user_object->isLoaded()) {
	$found = ($user_object->GetDBField("Login")==$username && $user_object->GetDBField("Status")==1) && strlen($user_object->GetDBField("Password"));
	}
	}
	else if(strlen($email)) {
	$user_object->Load($email, 'Email');
	if ($user_object->isLoaded()) {
	$found = ($user_object->GetDBField("Email")==$email && $user_object->GetDBField("Status")==1) && strlen($user_object->GetDBField("Password"));
	}
	}

	if ($user_object->isLoaded()) {
	$PwResetConfirm = $user_object->GetDBField('PwResetConfirm');
	$PwRequestTime = $user_object->GetDBField('PwRequestTime');
	$PassResetTime = $user_object->GetDBField('PassResetTime');
	//$MinPwResetDelay = $user_object->GetDBField('MinPwResetDelay');
	$MinPwResetDelay = $this->Application->ConfigValue('Users_AllowReset');

	$allow_reset = (strlen($PwResetConfirm) ?
	adodb_mktime() > $PwRequestTime + $MinPwResetDelay :
	adodb_mktime() > $PassResetTime + $MinPwResetDelay);
	}

	if ($found && $allow_reset) {
	$this->Application->StoreVar('tmp_user_id', $user_object->GetDBField("PortalUserId"));
	$this->Application->StoreVar('tmp_email', $user_object->GetDBField("Email"));

	$confirm_template = $this->Application->GetVar('reset_confirm_template');
	if (!$confirm_template) {
	$this->Application->SetVar('reset_confirm_template', 'platform/login/forgotpass_reset');
	}
	$this->Application->EmailEventUser('USER.PSWDC', $user_object->GetDBField('PortalUserId'));

	$event->redirect = $this->Application->GetVar('template_success');
	}
	else {
	if (!strlen($username) && !strlen($email)) {
	$user_current_object->SetError('Login', 'forgotpw_nodata', 'lu_ferror_forgotpw_nodata');
	$user_current_object->SetError('Email', 'forgotpw_nodata', 'lu_ferror_forgotpw_nodata');
	}
	else {
	if ($allow_reset) {
	if (strlen($username)) {
	$user_current_object->SetError('Login', 'unknown_username', 'lu_ferror_unknown_username');
	}
	if (strlen($email)) {
	$user_current_object->SetError('Email', 'unknown_email', 'lu_ferror_unknown_email');
	}
	}
	else {
	if (strlen($username)) {
	$user_current_object->SetError('Login', 'reset_denied', 'lu_ferror_reset_denied');
	}

	if (strlen($email)) {
	$user_current_object->SetError('Email', 'reset_denied', 'lu_ferror_reset_denied');
	}
	}
	}

	if($user_current_object->FieldErrors){
	$event->redirect = false;
	}
	}
	}

	/**
	* Enter description here...
	*
	* @param kEvent $event
	*/
	function OnResetPassword(&$event)
	{
	$user_object =& $this->Application->recallObject('u.forgot');

	if($user_object->Load($this->Application->RecallVar('tmp_user_id'))){

	$this->Application->EmailEventUser('USER.PSWDC', $user_object->GetDBField("PortalUserId"));
	$event->redirect = $this->Application->GetVar('template_success');

	$m_cat_id = $this->Application->findModule('Name', 'In-Commerce', 'RootCat');
	$this->Application->SetVar('m_cat_id', $m_cat_id);
	$event->SetRedirectParam('pass', 'm');
	}
	}

	function OnResetPasswordConfirmed(&$event)
	{
	// used for error reporting only -> rewrite code + theme (by Alex)
	$user_current_object =& $this->Application->recallObject('u', null, Array('skip_autoload' => true));// TODO: change theme too
	/* @var $user_current_object UsersItem */

	$passed_key = trim($this->Application->GetVar('user_key'));

	if (!$passed_key) {
	$event->redirect_params = Array('opener' => 's', 'pass' => 'all');
	$event->redirect = false;

	$user_current_object->SetError('PwResetConfirm', 'code_is_not_valid', 'lu_code_is_not_valid');
	}

	$user_object =& $this->Application->recallObject('u.forgot', null, Array('skip_autoload' => true));
	/* @var $user_object UsersItem */

	$user_object->Load($passed_key, 'PwResetConfirm');

	if ($user_object->isLoaded()) {
	$exp_time = $user_object->GetDBField('PwRequestTime') + 3600;
	$user_object->SetDBField('PwResetConfirm', '');
	$user_object->SetDBField('PwRequestTime', 0);

	if ($exp_time > adodb_mktime()) {
	$newpw = makepassword4();

	$this->Application->StoreVar('password', $newpw);

	$user_object->SetField('Password', $newpw);
	$user_object->SetField('VerifyPassword', $newpw);

	$user_object->SetDBField('PassResetTime', adodb_mktime());
	$user_object->SetDBField('PwResetConfirm', '');
	$user_object->SetDBField('PwRequestTime', 0);
	$user_object->Update();

	$this->Application->SetVar('ForgottenPassword', $newpw);

	$email_event_user =& $this->Application->EmailEventUser('USER.PSWD', $user_object->GetDBField('PortalUserId'));
	$email_event_admin =& $this->Application->EmailEventAdmin('USER.PSWD');

	$this->Application->DeleteVar('ForgottenPassword');

	if ($email_event_user->status == erSUCCESS) {
	$event->redirect_params = array('opener' => 's', 'pass' => 'all');
	$event->redirect = $this->Application->GetVar('template_success');
	}
	} else {
	$user_current_object->SetError('PwResetConfirm', 'code_expired', 'lu_code_expired');
	$event->redirect = false;
	}
	} else {
	$user_current_object->SetError('PwResetConfirm', 'code_is_not_valid', 'lu_code_is_not_valid');
	$event->redirect = false;
	}
	}

	function OnUpdate(&$event)
	{
	parent::OnUpdate($event);

	$this->setNextTemplate($event);
	}

	/**
	* Checks state against country
	*
	* @param kEvent $event
	*/
	function OnBeforeItemUpdate(&$event)
	{
	parent::OnBeforeItemUpdate($event);

	$cs_helper =& $this->Application->recallObject('CountryStatesHelper');
	/* @var $cs_helper kCountryStatesHelper */

	$cs_helper->CheckStateField($event, 'State', 'Country');
	$cs_helper->PopulateStates($event, 'State', 'Country');

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

	$object->setLogin();
	}

	/**
	* Enter description here...
	*
	* @param kEvent $event
	*/
	function setNextTemplate(&$event)
	{
	if ($this->Application->isAdmin) {
	return ;
	}

	$event->redirect_params['opener'] = 's';
	$object =& $event->getObject();

	if ($object->GetDBField('Status') == STATUS_ACTIVE) {
	$next_template = $this->Application->GetVar('next_template');

	if ($next_template) {
	$event->redirect = $next_template;
	}
	}
	}

	/**
	* Delete users from groups if their membership is expired
	*
	* @param kEvent $event
	*/
	function OnCheckExpiredMembership(&$event)
	{
	// send pre-expiration reminders: begin
	$pre_expiration = adodb_mktime() + $this->Application->ConfigValue('User_MembershipExpirationReminder') * 3600 * 24;
	$sql = 'SELECT PortalUserId, GroupId
	FROM '.TABLE_PREFIX.'UserGroup
	WHERE (MembershipExpires IS NOT NULL) AND (ExpirationReminderSent = 0) AND (MembershipExpires < '.$pre_expiration.')';

	$skip_clause = $event->getEventParam('skip_clause');
	if ($skip_clause) {
	$sql .= ' AND !('.implode(') AND !(', $skip_clause).')';
	}

	$records = $this->Conn->Query($sql);
	if ($records) {
	$conditions = Array();
	foreach ($records as $record) {
	$email_event_user =& $this->Application->EmailEventUser('USER.MEMBERSHIP.EXPIRATION.NOTICE', $record['PortalUserId']);
	$email_event_admin =& $this->Application->EmailEventAdmin('USER.MEMBERSHIP.EXPIRATION.NOTICE');
	$conditions[] = '(PortalUserId = '.$record['PortalUserId'].' AND GroupId = '.$record['GroupId'].')';
	}
	$sql = 'UPDATE '.TABLE_PREFIX.'UserGroup
	SET ExpirationReminderSent = 1
	WHERE '.implode(' OR ', $conditions);
	$this->Conn->Query($sql);
	}
	// send pre-expiration reminders: end

	// remove users from groups with expired membership: begin
	$sql = 'SELECT PortalUserId
	FROM '.TABLE_PREFIX.'UserGroup
	WHERE (MembershipExpires IS NOT NULL) AND (MembershipExpires < '.adodb_mktime().')';
	$user_ids = $this->Conn->GetCol($sql);
	if ($user_ids) {
	foreach ($user_ids as $id) {
	$email_event_user =& $this->Application->EmailEventUser('USER.MEMBERSHIP.EXPIRED', $id);
	$email_event_admin =& $this->Application->EmailEventAdmin('USER.MEMBERSHIP.EXPIRED');
	}
	}
	$sql = 'DELETE FROM '.TABLE_PREFIX.'UserGroup
	WHERE (MembershipExpires IS NOT NULL) AND (MembershipExpires < '.adodb_mktime().')';
	$this->Conn->Query($sql);
	// remove users from groups with expired membership: end
	}

	/**
	* Enter description here...
	*
	* @param kEvent $event
	*/
	function OnRefreshForm(&$event)
	{
	$event->redirect = false;
	$item_info = $this->Application->GetVar($event->Prefix_Special);
	list($id, $fields) = each($item_info);

	$object =& $event->getObject( Array('skip_autoload' => true) );
	$object->setID($id);
	$object->IgnoreValidation = true;
	$object->SetFieldsFromHash($fields);
	}

	/**
	* Sets persistant variable
	*
	* @param kEvent $event
	*/
	function OnSetPersistantVariable(&$event)
	{
	$field = $this->Application->GetVar('field');
	$value = $this->Application->GetVar('value');
	$this->Application->StorePersistentVar($field, $value);

	$force_tab = $this->Application->GetVar('SetTab');
	if ($force_tab) {
	$this->Application->StoreVar('force_tab', $force_tab);
	}
	}

	/**
	* Overwritten to return user from order by special .ord
	*
	* @param kEvent $event
	*/
	function getPassedID(&$event)
	{
	switch ($event->Special) {
	case 'ord':
	$order =& $this->Application->recallObject('ord');
	/* @var $order OrdersItem */

	$id = $order->GetDBField('PortalUserId');
	break;

	case 'profile':
	$id = $this->Application->GetVar('user_id');
	if (!$id) {
	// if none user_id given use current user id
	$id = $this->Application->RecallVar('user_id');
	}
	break;

	default:
	$id = parent::getPassedID($event);
	break;
	}

	return $id;
	}

	/**
	* Allows to change root password
	*
	* @param kEvent $event
	*/
	function OnUpdateRootPassword(&$event)
	{
	return $this->OnUpdatePassword($event);
	}

	/**
	* Allows to change root password
	*
	* @param kEvent $event
	*/
	function OnUpdatePassword(&$event)
	{
	$items_info = $this->Application->GetVar( $event->getPrefixSpecial(true) );
	if (!$items_info) return ;
	list ($id, $field_values) = each($items_info);
	$user_id = $this->Application->RecallVar('user_id');
	if ($id == $user_id && ($user_id > 0 \|\| $user_id == USER_ROOT)) {
	$user_dummy =& $this->Application->recallObject($event->Prefix.'.-item', null, Array('skip_autoload' => true));
	/* @var $user_dummy kDBItem */

	$user_dummy->Load($id);
	$status_field = array_shift($this->Application->getUnitOption($event->Prefix, 'StatusField'));

	if ($user_dummy->GetDBField($status_field) != STATUS_ACTIVE) {
	// not active user is not allowed to update his record (he could not activate himself manually)
	return false;
	}
	}

	if ($user_id == USER_ROOT) {
	$object =& $event->getObject( Array('skip_autoload' => true) );
	/* @var $object UsersItem */

	// put salt to user's config
	$field_options = $object->GetFieldOptions('RootPassword');
	$field_options['salt'] = 'b38';
	$object->SetFieldOptions('RootPassword', $field_options);
	$verify_options = $object->GetFieldOptions('VerifyRootPassword');
	$verify_options['salt'] = 'b38';
	$object->SetFieldOptions('VerifyRootPassword', $verify_options);

	// this is internal hack to allow root/root passwords for dev
	if ($this->Application->isDebugMode() && $field_values['RootPassword'] == 'root') {
	$this->Application->ConfigHash['Min_Password'] = 4;
	}

	$this->RemoveRequiredFields($object);
	$object->SetDBField('RootPassword', $this->Application->ConfigValue('RootPass'));
	$object->SetFieldsFromHash($field_values);
	$object->setID(-1);
	$status = $object->Validate();
	if ($status) {
	// validation on, password match too
	$fields_hash = Array (
	'VariableValue' => $object->GetDBField('RootPassword')
	);
	$conf_table = $this->Application->getUnitOption('conf', 'TableName');
	$this->Conn->doUpdate($fields_hash, $conf_table, 'VariableName = "RootPass"');
	$event->SetRedirectParam('opener', 'u');
	}
	else {
	$event->status = erFAIL;
	$event->redirect = false;
	return;
	}
	}
	else {
	$object =& $event->getObject();
	$object->SetFieldsFromHash($field_values);

	if (!$object->Update()) {
	$event->status = erFAIL;
	$event->redirect = false;
	}
	}

	$event->SetRedirectParam('opener', 'u');
	$event->redirect == true;
	}

	/**
	* Apply custom processing to item
	*
	* @param kEvent $event
	*/
	function customProcessing(&$event, $type)
	{
	if ($event->Name == 'OnCreate' && $type == 'before') {
	$object =& $event->getObject();
	/* @var $object kDBItem */

	// if auto password has not been set already - store real one - to be used in email events
	if (!$this->Application->GetVar('user_password')) {
	$this->Application->SetVar('user_password', $object->GetDirtyField('Password'));
	$object->SetDBField('Password_plain', $object->GetDirtyField('Password'));
	}

	// validate here, because subscribing procedure should not validate captcha code
	if ($this->Application->ConfigValue('RegistrationCaptcha')) {
	$captcha_helper =& $this->Application->recallObject('CaptchaHelper');
	/* @var $captcha_helper kCaptchaHelper */

	$captcha_helper->validateCode($event, false);
	}
	}
	}

	function OnMassResetSettings(&$event)
	{
	if ($this->Application->CheckPermission('SYSTEM_ACCESS.READONLY', 1)) {
	$event->status = erFAIL;
	return;
	}

	$ids = $this->StoreSelectedIDs($event);

	$default_user_id = $this->Application->ConfigValue('DefaultSettingsUserId');
	if (in_array($default_user_id, $ids)) {
	array_splice($ids, array_search($default_user_id, $ids), 1);
	}
	if ($ids) {
	$q = 'DELETE FROM '.TABLE_PREFIX.'PersistantSessionData WHERE PortalUserId IN ('.join(',', $ids).') AND
	(VariableName LIKE "%_columns_%"
	OR
	VariableName LIKE "%_filter%"
	OR
	VariableName LIKE "%_PerPage%")';
	$this->Conn->Query($q);
	}
	$this->clearSelectedIDs($event);
	}

	/**
	* Checks, that currently loaded item is allowed for viewing (non permission-based)
	*
	* @param kEvent $event
	* @return bool
	*/
	function checkItemStatus(&$event)
	{
	$object =& $event->getObject();
	if (!$object->isLoaded()) {
	return true;
	}

	$virtual_users = Array (USER_ROOT, USER_GUEST);
	return ($object->GetDBField('Status') == STATUS_ACTIVE) \|\| in_array($object->GetID(), $virtual_users);
	}

	/**
	* Sends approved/declined email event on user status change
	*
	* @param kEvent $event
	*/
	function OnAfterItemUpdate(&$event)
	{
	parent::OnAfterItemUpdate($event);

	$this->saveUserImages($event);

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

	if (!$this->Application->isAdmin \|\| $object->IsTempTable()) {
	return ;
	}

	$this->sendStatusChangeEvent($object->GetID(), $object->GetOriginalField('Status'), $object->GetDBField('Status'));
	}

	/**
	* Stores user's original Status before overwriting with data from temp table
	*
	* @param kEvent $event
	*/
	function OnBeforeDeleteFromLive(&$event)
	{
	$user_status = $this->Application->GetVar('user_status');
	if (!$user_status) {
	$user_status = Array ();
	}

	$user_id = $event->getEventParam('id');
	if ($user_id > 0) {
	$user_status[$user_id] = $this->getUserStatus($user_id);
	$this->Application->SetVar('user_status', $user_status);
	}
	}

	/**
	* Sends approved/declined email event on user status change (in temp tables during editing)
	*
	* @param kEvent $event
	*/
	function OnAfterCopyToLive(&$event)
	{
	parent::OnAfterCopyToLive($event);

	$temp_id = $event->getEventParam('temp_id');
	if ($temp_id == 0) {
	// this is new user create, don't send email events
	return ;
	}

	$new_status = $this->getUserStatus($temp_id);
	$user_status = $this->Application->GetVar('user_status');

	$this->sendStatusChangeEvent($temp_id, $user_status[$temp_id], $new_status);
	}

	/**
	* Returns user status (active, pending, disabled) based on ID and temp mode setting
	*
	* @param int $user_id
	* @return int
	*/
	function getUserStatus($user_id)
	{
	$id_field = $this->Application->getUnitOption($this->Prefix, 'IDField');
	$table_name = $this->Application->getUnitOption($this->Prefix, 'TableName');

	$sql = 'SELECT Status
	FROM '.$table_name.'
	WHERE '.$id_field.' = '.$user_id;
	return $this->Conn->GetOne($sql);
	}

	/**
	* Sends approved/declined email event on user status change
	*
	* @param int $user_id
	* @param int $prev_status
	* @param int $new_status
	*/
	function sendStatusChangeEvent($user_id, $prev_status, $new_status)
	{
	$status_events = Array (
	STATUS_ACTIVE => 'USER.APPROVE',
	STATUS_DISABLED => 'USER.DENY',
	);
	$email_event = isset($status_events[$new_status]) ? $status_events[$new_status] : false;

	if (($prev_status != $new_status) && $email_event) {
	$this->Application->EmailEventUser($email_event, $user_id);
	$this->Application->EmailEventAdmin($email_event);
	}

	// deletes sessions from users, that are no longer active
	if (($prev_status != $new_status) && ($new_status != STATUS_ACTIVE)) {
	$sql = 'SELECT SessionKey
	FROM ' . TABLE_PREFIX . 'UserSession
	WHERE PortalUserId = ' . $user_id;
	$session_ids = $this->Conn->GetCol($sql);

	$this->Application->Session->DeleteSessions($session_ids);
	}
	}

	/**
	* OnAfterConfigRead for users
	*
	* @param kEvent $event
	*/
	function OnAfterConfigRead(&$event)
	{
	parent::OnAfterConfigRead($event);

	// 1. arrange user registration countries
	$site_helper =& $this->Application->recallObject('SiteHelper');
	/* @var $site_helper SiteHelper */

	$first_country = $site_helper->getDefaultCountry('', false);

	if ($first_country === false) {
	$first_country = $this->Application->ConfigValue('User_Default_Registration_Country');
	}

	$fields = $this->Application->getUnitOption($event->Prefix, 'Fields');

	if ($first_country) {
	// update user country dropdown sql
	$fields['Country']['options_sql'] = preg_replace('/ORDER BY (.*)/', 'ORDER BY IF (CountryStateId = '.$first_country.', 1, 0) DESC, \\1', $fields['Country']['options_sql']);
	}

	$fields['Login']['min_len'] = $this->Application->ConfigValue('Min_UserName');
	$this->Application->setUnitOption($event->Prefix, 'Fields', $fields);

	// 2. set default user registration group
	$virtual_fields = $this->Application->getUnitOption($event->Prefix, 'VirtualFields');
	$virtual_fields['UserGroup']['default'] = $this->Application->ConfigValue('User_NewGroup');
	$this->Application->setUnitOption($event->Prefix, 'VirtualFields', $virtual_fields);

	// 3. allow avatar upload on Front-End
	$file_helper =& $this->Application->recallObject('FileHelper');
	/* @var $file_helper FileHelper */

	$file_helper->createItemFiles($event->Prefix, true); // create image fields

	if ($this->Application->isAdminUser) {
	// 4. when in administrative console, then create all users with Active status
	$fields = $this->Application->getUnitOption($event->Prefix, 'Fields');
	// $fields['Password']['required'] = 1; // set password required (will broke approve/decline buttons)
	$fields['Status']['default'] = STATUS_ACTIVE;
	$this->Application->setUnitOption($event->Prefix, 'Fields', $fields);

	// 5. remove groups tab on editing forms when AdvancedUserManagement config variable not set
	if (!$this->Application->ConfigValue('AdvancedUserManagement')) {
	$edit_tab_presets = $this->Application->getUnitOption($event->Prefix, 'EditTabPresets');

	foreach ($edit_tab_presets as $preset_name => $preset_tabs) {
	if (array_key_exists('groups', $preset_tabs)) {
	unset($edit_tab_presets[$preset_name]['groups']);

	if (count($edit_tab_presets[$preset_name]) == 1) {
	// only 1 tab left -> remove it too
	$edit_tab_presets[$preset_name] = Array ();
	}
	}
	}

	$this->Application->setUnitOption($event->Prefix, 'EditTabPresets', $edit_tab_presets);
	}
	}
	}

	/**
	* OnMassCloneUsers
	*
	* @param kEvent $event
	*/
	function OnMassCloneUsers(&$event)
	{
	if ($this->Application->CheckPermission('SYSTEM_ACCESS.READONLY', 1)) {
	$event->status = erFAIL;
	return;
	}

	$event->status=erSUCCESS;
	$ids = $this->StoreSelectedIDs($event);

	$this->Application->SetVar('skip_set_primary', 1); // otherwise it will default primary group, search for skip_set_primary above
	$temp_handler =& $this->Application->recallObject($event->Prefix.'_TempHandler', 'kTempTablesHandler');
	/* @var $temp_handler kTempTablesHandler */
	$cloned_users = $temp_handler->CloneItems($event->Prefix, '', $ids);
	$this->clearSelectedIDs($event);
	}

	/**
	* When cloning users, reset password (set random)
	*
	* @param kEvent $event
	*/
	function OnBeforeClone(&$event)
	{
	$object =& $event->getObject();
	/* @var $object kDBItem */
	$object->setRequired('Password', 0);
	$object->setRequired('VerifyPassword', 0);
	$object->SetDBField('Password', rand(100000000, 999999999));
	$object->SetDBField('CreatedOn', adodb_mktime());
	$object->SetDBField('ResourceId', false); // this will reset it

	// change email cause it should be unique
	$object->NameCopy(array(), $object->GetID(), 'Email', 'copy%1$s.%2$s');

	$object->UpdateFormattersSubFields();
	}

	/**
	* Copy user groups after copying user
	*
	* @param kEvent $event
	*/
	function OnAfterClone(&$event)
	{
	$id = $event->getEventParam('id');
	$original_id = $event->getEventParam('original_id');

	$sql = 'INSERT '.TABLE_PREFIX."UserGroup SELECT $id, GroupId, MembershipExpires, PrimaryGroup, 0 FROM ".TABLE_PREFIX."UserGroup WHERE PortalUserId = $original_id";
	$this->Conn->Query($sql);
	}

	/**
	* Saves selected ids to session
	*
	* @param kEvent $event
	*/
	function OnSaveSelected(&$event)
	{
	$this->StoreSelectedIDs($event);

	// remove current ID, otherwise group selector will use it in filters
	$this->Application->DeleteVar($event->getPrefixSpecial(true).'_id');
	}

	/**
	* Adds selected link to listing
	*
	* @param kEvent $event
	*/
	function OnProcessSelected(&$event)
	{
	$event->SetRedirectParam('opener', 'u');
	$user_ids = $this->getSelectedIDs($event, true);
	$this->clearSelectedIDs($event);

	$dst_field = $this->Application->RecallVar('dst_field');
	if ($dst_field != 'PrimaryGroupId') {
	return ;
	}

	$group_ids = $this->Application->GetVar('g');
	$primary_group_id = $group_ids ? array_shift( array_keys($group_ids) ) : false;

	if (!$user_ids \|\| !$primary_group_id) {
	return ;
	}

	$table_name = $this->Application->getUnitOption('ug', 'TableName');

	$sql = 'SELECT PortalUserId
	FROM '.$table_name.'
	WHERE (GroupId = '.$primary_group_id.') AND (PortalUserId IN ('.implode(',', $user_ids).'))';
	$existing_members = $this->Conn->GetCol($sql);

	// 1. reset primary group mark
	$sql = 'UPDATE '.$table_name.'
	SET PrimaryGroup = 0
	WHERE PortalUserId IN ('.implode(',', $user_ids).')';
	$this->Conn->Query($sql);

	foreach ($user_ids as $user_id) {
	if (in_array($user_id, $existing_members)) {
	// 2. already member of that group -> just make primary
	$sql = 'UPDATE '.$table_name.'
	SET PrimaryGroup = 1
	WHERE (PortalUserId = '.$user_id.') AND (GroupId = '.$primary_group_id.')';
	$this->Conn->Query($sql);
	}
	else {
	// 3. not member of that group -> make member & make primary
	$fields_hash = Array (
	'GroupId' => $primary_group_id,
	'PortalUserId' => $user_id,
	'PrimaryGroup' => 1,
	);
	$this->Conn->doInsert($fields_hash, $table_name);
	}
	}
	}

	/**
	* Loads user images
	*
	* @param kEvent $event
	*/
	function OnAfterItemLoad(&$event)
	{
	parent::OnAfterItemLoad($event);

	// linking existing images for item with virtual fields
	$image_helper =& $this->Application->recallObject('ImageHelper');
	/* @var $image_helper ImageHelper */

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

	$image_helper->LoadItemImages($object);

	$cs_helper =& $this->Application->recallObject('CountryStatesHelper');
	/* @var $cs_helper kCountryStatesHelper */

	$cs_helper->PopulateStates($event, 'State', 'Country');
	}

	/**
	* Save user images
	*
	* @param kEvent $event
	*/
	function saveUserImages(&$event)
	{
	if (!$this->Application->isAdmin) {
	$image_helper =& $this->Application->recallObject('ImageHelper');
	/* @var $image_helper ImageHelper */

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

	// process image upload in virtual fields
	$image_helper->SaveItemImages($object);
	}
	}

	/**
	* Makes password required for new users
	*
	* @param kEvent $event
	*/
	function OnPreCreate(&$event)
	{
	parent::OnPreCreate($event);

	if ($event->status == erSUCCESS) {
	$this->_makePasswordRequired($event);
	}
	}

	/**
	* Makes password required for new users
	*
	* @param kEvent $event
	*/
	function OnNew(&$event)
	{
	parent::OnNew($event);

	if ($event->status == erSUCCESS) {
	$this->_makePasswordRequired($event);
	}
	}

	/**
	* Makes password required for new users
	*
	* @param kEvent $event
	*/
	function _makePasswordRequired(&$event)
	{
	$object =& $event->getObject();
	/* @var $object kDBItem */

	$required_fields = Array ('Password', 'Password_plain', 'VerifyPassword', 'VerifyPassword_plain');
	foreach ($required_fields as $required_field) {
	$object->setRequired($required_field);
	}
	}

	/**
	* Load item if id is available
	*
	* @param kEvent $event
	*/
	function LoadItem(&$event)
	{
	$id = $this->getPassedID($event);

	if ($id < 0) {
	// when root, guest and so on

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

	$object->Clear($id);
	return ;
	}

	parent::LoadItem($event);
	}

	/**
	* Occurs just after login (for hooking)
	*
	* @param kEvent $event
	*/
	function OnAfterLogin(&$event)
	{

	}

	/**
	* Occurs just before logout (for hooking)
	*
	* @param kEvent $event
	*/
	function OnBeforeLogout(&$event)
	{

	}
	}

in-portalNo OneTemporaryActions

File Metadata

in-portalView Options

Event Timeline

in-portal
No OneTemporary
Actions

in-portal
View Options