<?php

	$refresh_rates = array( 
							array('desc' => 'Every 5 secs',
								  'secs' => 5,
								  ),
							array('desc' => 'Every 30 secs',
								  'secs' => 30,
								  ),
							array('desc' => 'Every 1 min.',
								  'secs' => 60,
								  ),
							array('desc' => 'Every 5 min.',
								  'secs' => 300,
								  ),
							array('desc' => 'Every 10 min.',
								  'secs' => 600,
								  ),
							array('desc' => 'Every 30 min.',
								  'secs' => 1800,
								  ),
							array('desc' => 'Never',
								  'secs' => 0,
								  ),
							);

	class MyAdminService extends CAdminServiceWeb
	{
		function commandResult($serviceModuleName, $result)
		{
			global $tpl;
			global $command_return_data;

			nt_common_add_debug("Service $serviceModuleName returned '$result'");

			$data = "===[ Service ". strtoupper($serviceModuleName) ." returned ]===\n". trim($result) ."\n\n";

			if (isset($command_return_data))	$command_return_data[] = explode("\n", $data);
			$tpl->append('tool_execute_result', $data);
		}

		function invokeError($methodName, $errorString)
		{
			global $tpl;

			nt_common_add_debug("AS Error in '$methodName' : $errorString");
			$tpl->assign('tool_as_error', "AS Error in '$methodName' : $errorString");
		}
	}


	function tool_main_check_user_domain($domain_id)
	{
		global $nel_user;

		if (!$domain_id) return false;

		$ud = $nel_user['access']['domains'];

		if (is_array($ud))
		{
			reset($ud);
			foreach($ud as $udomain)
			{
				if ($domain_id == $udomain['domain_id'])	return true;
			}
		}

		return false;
	}

	function tool_main_check_user_shard($shard_id)
	{
		global $nel_user;

		if (!$shard_id) return false;

		$us = $nel_user['access']['shards'];

		if (is_array($us))
		{
			reset($us);
			foreach($us as $ushard)
			{
				if ($shard_id == $ushard['shard_id'])	return true;
			}
		}

		return false;
	}

	function tool_main_get_domain_name($domain_id)
	{
		global $nel_user;

		reset($nel_user['access']['domains']);
		foreach($nel_user['access']['domains'] as $domain)
		{
			if ($domain['domain_id'] == $domain_id)
			{
				return $domain['domain_name'];
			}
		}

		return null;
	}

	function tool_main_get_domain_data($domain_id, $field)
	{
		global $nel_user;
		reset($nel_user['access']['domains']);
		foreach($nel_user['access']['domains'] as $domain)
		{
			if ($domain['domain_id'] == $domain_id)
			{
//		echo "ok $domain_id : $field : ".$domain[$field];
				return $domain[$field];
			}
		}
		return null;
	}


	function tool_main_get_domain_rrd_path($domain_id)
	{
		global $nel_user;

		reset($nel_user['access']['domains']);
		foreach($nel_user['access']['domains'] as $domain)
		{
			if ($domain['domain_id'] == $domain_id)
			{
				return $domain['domain_rrd_path'];
			}
		}

		return null;
	}

	function tool_main_get_shard_name($shard_id)
	{
		global $nel_user;

		reset($nel_user['access']['shards']);
		foreach($nel_user['access']['shards'] as $shard)
		{
			if ($shard['shard_id'] == $shard_id)
			{
				return $shard['shard_name'];
			}
		}

		return null;
	}

	function tool_main_get_shard_as_id($shard_id)
	{
		global $nel_user;

		reset($nel_user['access']['shards']);
		foreach($nel_user['access']['shards'] as $shard)
		{
			if ($shard['shard_id'] == $shard_id)
			{
				return $shard['shard_as_id'];
			}
		}

		return null;
	}

	function tool_main_get_shard_data($shard_id, $field)
	{
		global $nel_user;

		reset($nel_user['access']['shards']);
		foreach($nel_user['access']['shards'] as $shard)
		{
			if ($shard['shard_id'] == $shard_id)
			{
				return $shard[$field];
			}
		}

		return null;
	}


	function tool_main_get_domain_host($domain_id)
	{
		global $nel_user;

		reset($nel_user['access']['domains']);
		foreach($nel_user['access']['domains'] as $domain)
		{
			if ($domain['domain_id'] == $domain_id)
			{
				return $domain['domain_as_host'];
			}
		}

		return null;
	}

	function tool_main_get_domain_port($domain_id)
	{
		global $nel_user;

		reset($nel_user['access']['domains']);
		foreach($nel_user['access']['domains'] as $domain)
		{
			if ($domain['domain_id'] == $domain_id)
			{
				return $domain['domain_as_port'];
			}
		}

		return null;
	}

	function tool_main_get_elapsed_time_string($seconds, &$string)
	{
		//returns an array of numeric values representing days, hours, minutes & seconds respectively
		$ret=array('days'=>0,'hours'=>0,'minutes'=>0,'seconds'=>0,'totalseconds'=>0);

		$totalsec = $seconds;
		$ret['totalseconds'] = $totalsec;
		//print $earlierDate. ":". $laterDate. ":". $totalsec ."<br>";

		if ($totalsec >= 86400)
		{
			$ret['days'] = floor($totalsec/86400);
			$totalsec = $totalsec % 86400;
		}
		if ($totalsec >= 3600)
		{
			$ret['hours'] = floor($totalsec/3600);
			$totalsec = $totalsec % 3600;
		}
		if ($totalsec >= 60)
		{
			$ret['minutes'] = floor($totalsec/60);
		}
		$ret['seconds'] = $totalsec % 60;

		$string = '';
		$string .= ($ret['days'] > 0) ? tool_main_leftpad($ret['days']).'d ' : '';
		$string .= (($ret['hours'] > 0) || (strlen($string) > 0)) ? tool_main_leftpad($ret['hours']).'h ' : '';
		$string .= (($ret['minutes'] > 0) || (strlen($string) > 0)) ? tool_main_leftpad($ret['minutes']).'m ' : '';
		$string .= (($ret['seconds'] > 0) || (strlen($string) > 0)) ? tool_main_leftpad($ret['seconds']).'s ' : '';

		$ret['string'] = trim($string);

		return $ret;
	}

	function tool_main_leftpad($n,$cc=2,$ch='0')
	{
		return str_pad($n, $cc, $ch, STR_PAD_LEFT);
	}

	function tool_main_get_shards_from_status($status, $filters)
	{
		$result = array();

		if (is_array($status) && sizeof($status))
		{
			reset($status);
			foreach($status as $sline)
			{
				$shard_name = trim($sline['ShardName']);

				if (($shard_name != '') && (isset($filters[$shard_name]) || isset($filters['_all_'])))
				{
					$result[] = $shard_name;
				}
			}
			$result = array_values(array_unique($result));
		}

		return $result;
	}

	function tool_main_get_aes_from_status($status)
	{
		$result = array();
		if (is_array($status) && sizeof($status))
		{
			reset($status);
			foreach($status as $skey => $sline)
			{
				$short_name		= trim($sline['ShortName']);
				$running_state	= trim($sline['RunningState']);
				if (($short_name == 'AES') && ($running_state == 'online'))
				{
					$result[] = $sline['AliasName'];
				}
			}
		}
		return $result;
	}

	function tool_main_parse_status($status)
	{
		$check_graphs = tool_admin_applications_check('tool_main_graphs');

		$_sort_list = array();
		$domainServices = array();
		$sortedServices = array();
		if (is_array($status) && sizeof($status))
		{
			reset($status);
			foreach($status as $sline)
			{
				$vars = array();
				$vars['_flags_'] = array();

				$sline_vars = explode("\t", $sline);
				reset($sline_vars);
				foreach($sline_vars as $sline_var)
				{
					$sline_parts = explode("=", $sline_var);
					if (!isset($sline_parts[1])) {
						$sline_parts[1] = '';
					}

					if ($sline_parts[0] == 'RunningState')
					{
						// this is a small fix to an unknown server bug :)
						if 		(trim($sline_parts[1]) == 'topped') $sline_parts[1] = 'rs_stopped';
						elseif	(trim($sline_parts[1]) == 'nline') $sline_parts[1] = 'rs_online';

						$vars['_flags_'][$sline_parts[1]] = true;
						$sline_parts[1] = substr($sline_parts[1], 3);
					}
					elseif ($sline_parts[0] == 'RunningOrders')
					{
						$vars['_flags_'][$sline_parts[1]] = true;
						$sline_parts[1] = substr($sline_parts[1], 3);
					}
					elseif ($sline_parts[0] == 'RunningTags')
					{
						$_tmp = explode(" ", trim($sline_parts[1]));
						reset($_tmp);
						foreach($_tmp as $_tmp_key => $_tmp_part)
						{
							$vars['_flags_'][$_tmp_part] = true;
							$_tmp_part			= str_replace('_',' ',substr($_tmp_part, 3));
							$_tmp[$_tmp_key]	= $_tmp_part;
						}
						$sline_parts[1] = implode(' / ', $_tmp);
					}
					elseif ($sline_parts[0] == 'NoReportSince')
					{
						$_today		= time();
						$_day		= date("d", $_today);
						$_month		= date("m", $_today);
						$_year		= date("Y", $_today);
						$_base_day	= mktime(0, 0, 0, $_month, $_day, $_year);

						if ($sline_parts[1] >= $_base_day)
						{
							$sline_parts[1] = 'n/a';
						}
						else
						{
							$time0 = 0 + $sline_parts[1]; // convert to a number ;)
							if 		($time0 > 60)	$vars['_flags_']['alert_red'] = true;
							elseif  ($time0 > 40)	$vars['_flags_']['alert_orange_dark'] = true;
							elseif  ($time0 > 25)	$vars['_flags_']['alert_orange_light'] = true;

							tool_main_get_elapsed_time_string($sline_parts[1],$sline_parts[1]);
						}
					}
					elseif ($sline_parts[0] == 'UpTime')
					{
						$_today		= time();
						$_day		= date("d", $_today);
						$_month		= date("m", $_today);
						$_year		= date("Y", $_today);
						$_base_day	= mktime(0, 0, 0, $_month, $_day, $_year);

						if ($sline_parts[1] >= $_base_day)
						{
							$sline_parts[1] = 'n/a';
						}
						else
						{
							tool_main_get_elapsed_time_string($sline_parts[1],$sline_parts[1]);
						}
					}
					elseif ($sline_parts[0] == 'State')
					{
						if (strtolower($sline_parts[1]) == 'stalled')		$vars['_flags_']['alert_red'] = true;
						elseif (strtolower($sline_parts[1]) == 'halted')	$vars['_flags_']['alert_red'] = true;
						$vars['_flags_'][$sline_parts[1]] = true;
					}
					elseif ($sline_parts[0] == 'Hostname')
					{
						$sline_parts[1] = substr($sline_parts[1], 0, strpos($sline_parts[1], '.'));
					}
					elseif ($sline_parts[0] == 'AliasName')
					{
						$vars['_flags_']['alias_code'] = '';
					}

					$vars[$sline_parts[0]] = $sline_parts[1];
				}

				// check is service is chain crashing
				if (in_array('rt_chain_crashing', array_keys($vars['_flags_'])))
				{
					// check is service is online (anything that is not stopped)
					if (!in_array('rs_stopped', array_keys($vars['_flags_'])))
					{
						// check the start counts for crashing age
						$crash_counts = explode(' ', $vars['StartCounter']);
						if     ($crash_counts[0] >= 5)	$vars['_flags_']['alert_red'] = true;
						elseif ($crash_counts[1] >= 5)	$vars['_flags_']['alert_orange_dark'] = true;
						elseif ($crash_counts[2] >= 5)	$vars['_flags_']['alert_orange_light'] = true;
					}
				}

				//$vars['_flags_']['has_graphs'] = tool_main_check_rrd_files($vars['AliasName']);
				$_sort_list[] = $vars['AliasName'];

				$domainServices[] = $vars;
			}

			sort($_sort_list);

			reset($_sort_list);
			foreach($_sort_list as $_sort_name)
			{
				reset($domainServices);
				foreach($domainServices as $serviceRow)
				{
					if ($_sort_name == $serviceRow['AliasName'])
					{
						$sortedServices[] = $serviceRow;
						break;
					}
				}
			}
		}

        return $sortedServices;
	}

	function tool_main_check_rrd_files($service)
	{
		if ($handle = opendir(NELTOOL_RRDBASE))
		{
   			while (false !== ($file = readdir($handle)))
   			{
       			if ($file != "." && $file != "..")
       			{
       				$file_parts = explode(".", $file);
       				if (sizeof($file_parts) == 3)
       				{
       					if (($service == $file_parts[0]) && (($file_parts[2] == 'rrd') || ($file_parts[2] == 'hrd')))
       					{
       						closedir($handle);
       						return true;
       					}
       				}
       			}
   			}
   			closedir($handle);
		}

		return false;
	}

	function tool_main_get_checked_services()
	{
		global $NELTOOL;

		$services = array();

		reset($NELTOOL['POST_VARS']);
		foreach($NELTOOL['POST_VARS'] as $post_key => $post_val)
		{
			$val = 'service_'. $post_val;
			if ($post_key == $val)
			{
				$services[] = $post_val;
			}
		}

		return $services;
	}

	function tool_main_get_shard_ids($shard_id)
	{
		global $nel_user;

		$data = array();
		reset($nel_user['access']['shards']);
		foreach($nel_user['access']['shards'] as $shards)
		{
			if ($shards['shard_id'] == $shard_id)
			{
				$shards_tmp = trim($shards['shard_as_id']);
				if ($shards_tmp == '*')
				{
					$data['_all_'] = true;
				}
				elseif ($shards_tmp == '?')
				{
					$data['_unknown_'] = true;
				}
				else
				{
					$shard_parts = explode(':', $shards_tmp);
					reset($shard_parts);
					foreach($shard_parts as $shard_as_id)
					{
						if ($shard_as_id == '?')
						{
							$data['_unknown_'] = true;
						}
						else
						{
							$data[$shard_as_id] = true;
						}
					}
				}

			}
		}

		return $data;
	}

	function tool_main_get_shards_orders($orders)
	{
		$data = array();

		if (is_array($orders) && sizeof($orders))
		{
			reset($orders);
			foreach($orders as $order_line)
			{
				$order_items = explode("\t", $order_line);

				$shard_name		= "";
				$shard_order	= "";

				reset($order_items);
				foreach($order_items as $order_parts)
				{
					$order_bits = explode("=", $order_parts);

					$order_bits[0] = trim($order_bits[0]);
					$order_bits[1] = trim($order_bits[1]);

					if ($order_bits[0] == 'ShardName')
					{
						$shard_name = $order_bits[1];
					}
					elseif ($order_bits[0] == 'Orders')
					{
						$shard_order = substr($order_bits[1],3);
					}
				}

				if ($shard_name != "" && $shard_order != "")
				{
					$data[$shard_name] = $shard_order;
				}

			}
		}

		return $data;
	}

	function tool_main_get_last_hd_time_for_domain($domain_id)
	{
		global $db;

		$timer = 0;

		$sql = "SELECT * FROM ". NELDB_STAT_HD_TIME_TABLE ." WHERE hd_domain_id=". $domain_id;
		if ($result = $db->sql_query($sql))
		{
			if ($db->sql_numrows($result))
			{
				$data = $db->sql_fetchrow($result);
				$timer = $data['hd_last_time'];
			}
		}

		return $timer;
	}

	function tool_main_update_hd_time_for_domain($domain_id, $now)
	{
		global $db;

		//if ($stat_time == 0)	$sql = "INSERT INTO ". NELDB_STAT_HD_TIME_TABLE ." (`hd_domain_id`,`hd_last_time`) VALUES (". $domain_id .",". $now .")";
		//else					$sql = "UPDATE ". NELDB_STAT_HD_TIME_TABLE ." SET hd_last_time=". $now ." WHERE hd_domain_id=". $domain_id;

		$sql = "SELECT * FROM ". NELDB_STAT_HD_TIME_TABLE ." WHERE hd_domain_id=". $domain_id;
		if ($result = $db->sql_query($sql))
		{
			if ($db->sql_numrows($result))
			{
				$sql = "UPDATE ". NELDB_STAT_HD_TIME_TABLE ." SET hd_last_time=". $now ." WHERE hd_domain_id=". $domain_id;
				$db->sql_query($sql);
			}
			else
			{
				$sql = "INSERT INTO ". NELDB_STAT_HD_TIME_TABLE ." (`hd_domain_id`,`hd_last_time`) VALUES (". $domain_id .",". $now .")";
				$db->sql_query($sql);
			}
		}
	}

	function tool_main_update_hd_data_for_domain($domain_id, $data)
	{
		global $db;

		$aes_status = array();

		if (is_array($data) && sizeof($data))
		{
			reset($data);
			foreach($data as $aes)
			{
				$aes_server = null;

				//$hd_found_slash_mount		= null;
				//$hd_found_slash_home 		= null;
				//$hd_found_slash_home_nevrax = null;
				//$hd_found_slash 			= null;

				$aes_hd_ready	= false;

				$aes_data = explode("\n", $aes);
				reset($aes_data);
				foreach($aes_data as $aes_line)
				{
					$aes_line = trim($aes_line);

					// clean up the multiple blank characters
					$aes_line = ereg_replace("[[:space:]]+"," ",$aes_line);

					if (ereg("^===\[ Service AES_([^[:space:]]+) returned \]===$", $aes_line, $regs))
					{
						$aes_server = strtolower($regs[1]);
						$aes_status[$aes_server] = array();
					}
					elseif (ereg("^-* Command output begin -*$", $aes_line, $regs))
					{
						$aes_hd_ready = true;
					}
					elseif (ereg("^-* Command output end -*$", $aes_line, $regs))
					{
						$aes_hd_ready = false;
					}

					if ($aes_hd_ready)
					{
						$aes_line_data = explode(" ", $aes_line);

						if (($aes_line_data[0] != 'Filesystem') && ($aes_line_data[1] != 'Command'))
						{
							//if	((strpos($aes_line_data[5],"/mnt/rsbk") == 0)
							// ||	($aes_line_data[5] == "/home")
							// ||	($aes_line_data[5] == "/home/nevrax")
							// ||	($aes_line_data[5] == "/"))
							//{
								$aes_status[$aes_server][] = array(	'device'		=>	$aes_line_data[0],
																	'size'			=>	$aes_line_data[1],
																	'used'			=>	$aes_line_data[2],
																	'free'			=>	$aes_line_data[3],
																	'usedpercent'	=>	str_replace('%','',$aes_line_data[4]),
																	'mount'			=>	$aes_line_data[5],
																	);

							//}
						}

					}

					//if ((substr($aes_line, 0, 5) == "/dev/") && $aes_server)
					//{
                    //
					//	$aes_line_data = explode(" ", $aes_line);
                    //
					//	// 0 : device name
					//	// 1 : device size
					//	// 2 : used
					//	// 3 : available
					//	// 4 : used percentage
					//	// 5 : mount point
                    //
					//	if 	($aes_line_data[5] == "/home")
					//	{
					//		$hd_found_slash_home = $aes_line_data;
					//	}
                    //
					//	if	($aes_line_data[5] == "/home/nevrax")
					//	{
					//		$hd_found_slash_home_nevrax = $aes_line_data;
					//	}
                    //
					//	if	($aes_line_data[5] == "/")
					//	{
					//		$hd_found_slash = $aes_line_data;
					//	}
                    //
					//	//if (($aes_line_data[5] == "/") || ($aes_line_data[5] == "/home/nevrax"))
					//	//{
					//	//	$aes_status[$aes_server][] = array(	'device'		=>	$aes_line_data[0],
					//	//										'size'			=>	$aes_line_data[1],
					//	//										'used'			=>	$aes_line_data[2],
					//	//										'free'			=>	$aes_line_data[3],
					//	//										'usedpercent'	=>	str_replace('%','',$aes_line_data[4]),
					//	//										'mount'			=>	$aes_line_data[5],
					//	//										);
					//	//}
                    //
					//}
				}

				//$tmp = null;
                //
				//if		(is_array($hd_found_slash_mount))		$tmp = $hd_found_slash_mount;
				//elseif	(is_array($hd_found_slash_home))		$tmp = $hd_found_slash_home;
				//elseif	(is_array($hd_found_slash_home_nevrax))	$tmp = $hd_found_slash_home_nevrax;
				//elseif	(is_array($hd_found_slash))				$tmp = $hd_found_slash;
                //
				//if (is_array($tmp))
				//{
				//	$aes_status[$aes_server][] = array(	'device'		=>	$tmp[0],
				//										'size'			=>	$tmp[1],
				//										'used'			=>	$tmp[2],
				//										'free'			=>	$tmp[3],
				//										'usedpercent'	=>	str_replace('%','',$tmp[4]),
				//										'mount'			=>	$tmp[5],
				//										);
				//}
			}

			if (sizeof($aes_status))
			{
				nt_common_add_debug($aes_status);
				//echo '<pre>'. print_r($aes_status, true) .'</pre>';


				$sql = "DELETE FROM ". NELDB_STAT_HD_TABLE ." WHERE hd_domain_id=". $domain_id;
				$db->sql_query($sql);

				reset($aes_status);
				foreach($aes_status as $server_name => $server_datas)
				{
					reset($server_datas);
					foreach($server_datas as $server_hd)
					{
						if (trim($server_name) != '')
						{
							$sql  = "INSERT INTO ". NELDB_STAT_HD_TABLE ." (`hd_domain_id`,`hd_server`,`hd_device`,`hd_size`,`hd_used`,`hd_free`,`hd_percent`,`hd_mount`)";
							$sql .= " VALUES (". $domain_id .",'". $server_name ."','". $server_hd['device'] ."','". $server_hd['size'] ."',";
							$sql .= "'". $server_hd['used'] ."','". $server_hd['free'] ."','". $server_hd['usedpercent'] ."','". $server_hd['mount'] ."')";
							$db->sql_query($sql);
						}
						if (defined('NELTOOL_CRON_DEBUG')) echo "<br />SQL:$sql";
					}
				}

				tool_main_update_hd_time_for_domain($domain_id, time());
			}
		}

	}

	function tool_main_get_hd_data_for_domain($domain_id)
	{
		global $db;

		$data = array();

		//$sql = "SELECT * FROM ". NELDB_STAT_HD_TABLE ." WHERE hd_domain_id=". $domain_id ." AND hd_mount='/' ORDER BY hd_percent DESC";
		$sql = "SELECT * FROM ". NELDB_STAT_HD_TABLE ." WHERE hd_domain_id=". $domain_id ." ORDER BY hd_percent DESC";
		if ($result = $db->sql_query($sql))
		{
			if ($db->sql_numrows($result))
			{
				while ($row = $db->sql_fetchrow($result))
				{
					$outp  = '<b>'. $row['hd_server'] .'</b> : '. $row['hd_device'] .'<br>';
					$outp .= '� Mount : '. $row['hd_mount'] .'<br>';
					$outp .= '� Size : '. $row['hd_size'] .'<br>';
					$outp .= '� Used : '. $row['hd_used'] .'<br>';
					$outp .= '� Free : '. $row['hd_free'] .'<br>';

					$row['summary'] = $outp;
					$data[] = $row;
				}
			}
		}

		return $data;
	}

	function tool_main_get_annotation($domain_id, $shard_id)
	{
		global $db;

		$data = null;

		$sql = "SELECT * FROM ". NELDB_ANNOTATION_TABLE ." WHERE 1=0";
		if ($domain_id > 0)	$sql .= " OR annotation_domain_id=". $domain_id;
		if ($shard_id  > 0)	$sql .= " OR annotation_shard_id=". $shard_id;
		$sql .= " ORDER BY annotation_date DESC";

		if ($result = $db->sql_query($sql))
		{
			if ($db->sql_numrows($result))
			{
				$data = $db->sql_fetchrow($result);
			}
		}

		return $data;
	}

	function tool_main_get_lock($domain_id, $shard_id)
	{
		global $db;

		$data = null;

		$sql = "SELECT * FROM ". NELDB_LOCK_TABLE ." WHERE 1=0 ";
		if ($domain_id > 0)	$sql .= " OR lock_domain_id=". $domain_id;
		if ($shard_id  > 0) $sql .= " OR lock_shard_id=". $shard_id;
		$sql .= " ORDER BY lock_date DESC";

		if ($result = $db->sql_query($sql))
		{
			if ($db->sql_numrows($result))
			{
				$data = $db->sql_fetchrow($result);
			}
		}

		return $data;
	}

	function tool_main_delete_lock_shard($shard_id)
	{
		global $db;
		global $nel_user;
		global $AS_Name, $AS_ShardName;

		nt_log("Shard Unlock (Domain: '". $AS_Name ."' - Shard: '". $AS_ShardName ."') by '". $nel_user['user_name'] ."'");
		$sql = "DELETE FROM ". NELDB_LOCK_TABLE ." WHERE lock_shard_id=". $shard_id;
		$db->sql_query($sql);
	}

	function tool_main_delete_lock_domain($domain_id)
	{
		global $db;
		global $nel_user;
		global $AS_Name, $AS_ShardName;

		nt_log("Domain Unlock (Domain: '". $AS_Name ."') by '". $nel_user['user_name'] ."'");
		$sql = "DELETE FROM ". NELDB_LOCK_TABLE ." WHERE lock_domain_id=". $domain_id;
		$db->sql_query($sql);
	}


	function tool_main_set_lock_shard($domain_id, $shard_id, $log=true)
	{
		global $db;
		global $nel_user;
		global $AS_Name, $AS_ShardName;

		// we need to check if the shard is *all*
		// if its the case, we go for a lock domain instead

		$sql = "SELECT * FROM ". NELDB_SHARD_TABLE ." WHERE shard_id=". $shard_id;
		if ($result = $db->sql_query($sql))
		{
			if ($db->sql_numrows($result))
			{
				$shard_row = $db->sql_fetchrow($result);

				if ($shard_row['shard_as_id'] == "*")
				{
					return tool_main_set_lock_domain($domain_id, $log);
				}
			}
		}

		$data = tool_main_get_lock($domain_id, $shard_id);
		$now = time();

		if (is_array($data) && ($data['lock_shard_id'] > 0))
		{
			if ($log) nt_log("Shard Lock (Domain: '". $AS_Name ."' - Shard: '". $AS_ShardName ."') by '". $nel_user['user_name'] ."'");
			$sql = "UPDATE ". NELDB_LOCK_TABLE ." SET lock_user_name='". $nel_user['user_name'] ."',lock_update=". $now ." WHERE lock_id=". $data['lock_id'];
			$db->sql_query($sql);
		}
		elseif (!$data)
		{
			if ($log) nt_log("Shard Lock (Domain: '". $AS_Name ."' - Shard: '". $AS_ShardName ."') by '". $nel_user['user_name'] ."'");
			$sql = "INSERT INTO ". NELDB_LOCK_TABLE ." (`lock_shard_id`,`lock_user_name`,`lock_date`,`lock_update`) VALUES (". $shard_id .",'". $nel_user['user_name'] ."',". $now .",". $now .")";
			$db->sql_query($sql);
		}

	}

	function tool_main_get_domain_shard_list($domain_id)
	{
		global $db;

		$data = array();

		$sql = "SELECT * FROM ". NELDB_SHARD_TABLE ." WHERE shard_domain_id=". $domain_id;
		if ($result = $db->sql_query($sql))
		{
			if ($db->sql_numrows($result))
			{
				while ($row = $db->sql_fetchrow($result))
				{
					$data[] = $row['shard_id'];
				}
			}
		}

		return $data;
	}

	function tool_main_set_lock_domain($domain_id, $log=true)
	{
		global $db;
		global $nel_user;
		global $AS_Name, $AS_ShardName;

		// to lock a domain you need to remove all locks from any shard in it

		$lock_data = tool_main_get_lock($domain_id, 0);

		$now = time();

		if (is_array($lock_data))
		{
			$sql = "UPDATE ". NELDB_LOCK_TABLE ." SET lock_user_name='". $nel_user['user_name'] ."',lock_update=". $now ." WHERE lock_id=". $lock_data['lock_id'];
			$db->sql_query($sql);
		}
		else
		{
			$shard_list = tool_main_get_domain_shard_list($domain_id);
			$shard_list = array_values($shard_list);

			$sql = "DELETE FROM ". NELDB_LOCK_TABLE ." WHERE lock_shard_id IN (". implode(',', $shard_list) .")";
			$db->sql_query($sql);

			$sql = "INSERT INTO ". NELDB_LOCK_TABLE ." (`lock_domain_id`,`lock_user_name`,`lock_date`,`lock_update`) VALUES (". $domain_id .",'". $nel_user['user_name'] ."',". $now .",". $now .")";
			$db->sql_query($sql);
		}

		if ($log) nt_log("Domain Lock (Domain: '". $AS_Name ."') by '". $nel_user['user_name'] ."'");
	}

	function tool_main_set_annotation($domain_id, $shard_id, $annotation)
	{
		global $db;
		global $nel_user;
		global $AS_Name, $AS_ShardName;

		$annotation = htmlentities(trim($annotation), ENT_QUOTES);

		$data = tool_main_get_lock($domain_id, $shard_id);

		if ($data['lock_domain_id'])
		{
			// its a domain lock
			$shard_list = tool_main_get_domain_shard_list($domain_id);
			$shard_list = array_values($shard_list);

			$sql = "DELETE FROM ". NELDB_ANNOTATION_TABLE ." WHERE annotation_shard_id IN (". implode(',', $shard_list) .")";
			$db->sql_query($sql);

			$annotation_data = tool_main_get_annotation($domain_id, 0);
			if ($annotation_data)
			{
				nt_log("Domain Annotation (Domain: '". $AS_Name ."') by '". $nel_user['user_name'] ."' : ". $annotation);
				$sql = "UPDATE ". NELDB_ANNOTATION_TABLE ." SET annotation_data='". $annotation ."',annotation_user_name='". $nel_user['user_name'] ."',annotation_date=". time() ." WHERE annotation_id=". $annotation_data['annotation_id'];
				$db->sql_query($sql);
			}
			else
			{
				nt_log("Domain Annotation (Domain: '". $AS_Name ."') by '". $nel_user['user_name'] ."' : ". $annotation);
				$sql  = "INSERT INTO ". NELDB_ANNOTATION_TABLE ." (`annotation_domain_id`,`annotation_data`,`annotation_user_name`,`annotation_date`) VALUES ";
				$sql .= "(". $domain_id .",'". $annotation ."','". $nel_user['user_name'] ."',". time() .")";
				$db->sql_query($sql);
			}

		}
		else
		{
			// its a shard lock
			$annotation_data = tool_main_get_annotation(0, $shard_id);
			if ($annotation_data)
			{
				nt_log("Shard Annotation (Domain: '". $AS_Name ."' - Shard: '". $AS_ShardName ."') by '". $nel_user['user_name'] ."' : ". $annotation);
				$sql = "UPDATE ". NELDB_ANNOTATION_TABLE ." SET annotation_data='". $annotation ."',annotation_user_name='". $nel_user['user_name'] ."',annotation_date=". time() ." WHERE annotation_id=". $annotation_data['annotation_id'];
				$db->sql_query($sql);
			}
			else
			{
				nt_log("Shard Annotation (Domain: '". $AS_Name ."' - Shard: '". $AS_ShardName ."') by '". $nel_user['user_name'] ."' : ". $annotation);
				$sql  = "INSERT INTO ". NELDB_ANNOTATION_TABLE ." (`annotation_shard_id`,`annotation_data`,`annotation_user_name`,`annotation_date`) VALUES ";
				$sql .= "(". $shard_id .",'". $annotation ."','". $nel_user['user_name'] ."',". time() .")";
				$db->sql_query($sql);
			}
		}
	}


	function tool_main_get_shards_info_from_db($application, $status, $filters, $ringsqlstring='')
	{
		$shard_list			= array();
		$shard_list2		= array();
		$shard_list_result	= array();

		//nt_common_add_debug('in tool_main_get_shards_info_from_db()');
		//nt_common_add_debug($status);

		if (is_array($status) && sizeof($status))
		{
			reset($status);
			foreach($status as $sline)
			{
				$shard_name = trim($sline['ShardName']);
				$shard_id	= isset($sline['ShardId']) ? trim($sline['ShardId']) : '';

				if (($shard_name != '' && $shard_id != '') && (isset($filters[$shard_name]) || isset($filters['_all_'])))
				{
					if (!in_array($shard_name, array_values($shard_list)))
					{
						$shard_list[$shard_id] = $shard_name;
					}
				}
			}
		}

		nt_common_add_debug('shard_list :');
		nt_common_add_debug($shard_list);

		reset($shard_list);
		foreach($shard_list as $shard_key => $shard_application)
		{
			if (is_numeric($shard_key))
			{
				$shard_list2[$shard_key] = $shard_application;
			}
		}

		//nt_common_add_debug('shard_list2 :');
		//nt_common_add_debug($shard_list2);

		if ($ringsqlstring == '')
		{
			global $db;
			$db->sql_select_db('nel');

			//$sql = "SELECT * FROM shard WHERE ShardId IN (". implode(',', array_keys($shard_list)) .")";
			if (is_array($shard_list2) && sizeof($shard_list2))
			{
				$sql = "SELECT * FROM shard, domain WHERE shard.domain_id=domain.domain_id AND shard.ShardId IN (". implode(',', array_keys($shard_list2)) .") AND domain.domain_name='". $application ."'";

				if ($result = $db->sql_query($sql))
				{
					if ($db->sql_numrows($result))
					{
						while ($row = $db->sql_fetchrow($result))
						{
							// patch to support live and ats mysql changes
							$state = '';
							if (isset($row['State']))				$state = $row['State'];
							elseif (isset($row['RequiredState']))	$state = $row['RequiredState'];

							$shard_name = $shard_list[$row['ShardId']];
							$shard_list_result[$shard_name] = array('shard_id'	=> $row['ShardId'],
																	'version'	=> $row['Version'],
																	'state'		=> substr($state,3),
																	'motd'		=> $row['MOTD'],
																	);
						}
					}
				}
			}

			$db->sql_reselect_db();
		}
		else
		{
			$db = new sql_db_string($ringsqlstring);
			if (is_object($db))
			{
				if (is_array($shard_list2) && sizeof($shard_list2))
				{
					//nt_common_add_debug("tool_main_get_shards_info_from_db()");
					//nt_common_add_debug($shard_list2);

					$sql = "SELECT * FROM shard WHERE shard_id IN (". implode(',', array_keys($shard_list2)) .")";

					if ($result = $db->sql_query($sql))
					{
						if ($db->sql_numrows($result))
						{
							while ($row = $db->sql_fetchrow($result))
							{
								// patch to support live and ats mysql changes
								$state = '';
								if (isset($row['State']))				$state = $row['State'];
								elseif (isset($row['RequiredState']))	$state = $row['RequiredState'];

								$shard_name = $shard_list[$row['shard_id']];
								$shard_list_result[$shard_name] = array('shard_id'	=> $row['shard_id'],
																		//'version'	=> $row['Version'],
																		'state'		=> substr($state,3),
																		'motd'		=> $row['MOTD'],
																		);
							}
						}
					}
				}
				else
				{
					nt_common_add_debug('in tool_main_get_shards_info_from_db() : shard_list2 is empty !');
					//nt_common_add_debug('dumping : filters');
					//nt_common_add_debug($filters);
				}
			}
			else
			{
				// db error
			}

		}


		return $shard_list_result;
	}

	function tool_main_get_su_from_status($status)
	{
		if (is_array($status) && sizeof($status))
		{
			reset($status);
			foreach($status as $sline)
			{
				if ($sline['ShortName'] == 'SU')
				{
					return $sline['AliasName'];
				}
			}
		}

		return null;
	}

	function tool_main_set_restart_mode($domain_id, $shard_id, $restart_mode=0)
	{
		global $db, $nel_user, $tpl;
		global $AS_ShardRestart, $AS_ShardDomainRestart;

		$sequence_info = tool_main_get_restart_sequence($nel_user['user_name'], $domain_id, $shard_id);

		if (!$sequence_info)
		{
			$sequence_info = tool_main_add_restart_sequence($nel_user['user_name'], $domain_id, $shard_id, $restart_mode);
		}

		if ($sequence_info)
		{
			$sql = "UPDATE ". NELDB_SHARD_TABLE ." SET shard_restart=". $sequence_info['restart_sequence_id'] ." WHERE shard_id=". $shard_id ." AND shard_domain_id=". $domain_id;
			$db->sql_query($sql);

			// update shards information
			$nel_user['access']['user_shards']	= tool_admin_users_shards_get_list($nel_user['user_id']);
			$nel_user['access']['group_shards']	= tool_admin_groups_shards_get_list($nel_user['user_group_id']);
			$nel_user['access']['shards'] 		= tool_admin_users_groups_shards_merge();
			$tpl->assign('tool_shard_list',	$nel_user['access']['shards']);

			// update shard restart information
			$AS_ShardRestart		= tool_main_get_shard_data($shard_id, 'shard_restart');
			$AS_ShardDomainRestart	= tool_main_get_domain_shard_restart($view_domain_id);
			$tpl->assign('tool_shard_restart_status', 		$AS_ShardRestart);
			$tpl->assign('tool_domain_has_shard_restart',	$AS_ShardDomainRestart);
		}

		return $sequence_info;
	}

	function tool_main_add_restart_sequence($user_name, $domain_id, $shard_id, $step=0)
	{
		global $db;
		global $nel_user;
		global $AS_Name, $AS_ShardName;
		global $restart_notification_emails;

		$now = time();

		$sql  = "INSERT INTO ". NELDB_RESTART_SEQUENCE_TABLE;
		$sql .= " (`restart_sequence_domain_id`,`restart_sequence_shard_id`,`restart_sequence_user_name`,";
		$sql .= "  `restart_sequence_step`,`restart_sequence_date_start`,`restart_sequence_date_end`) VALUES ";
		$sql .= " (". $domain_id .",". $shard_id .",'". $user_name ."',";
		$sql .=       $step .",". $now .",". $now .")";
		$db->sql_query($sql);

		$sequence_info = tool_main_get_restart_sequence_by_id($db->sql_nextid());

		nt_log("Shard Restart (Domain: '". $AS_Name ."' - Shard: '". $AS_ShardName ."' - Sequence: '". $sequence_info['restart_sequence_id'] ."') started by '". $nel_user['user_name'] ."'");

		$email_subject	= "[Shard Admin Tool] Restart Sequence Begins (id: ".$sequence_info['restart_sequence_id'].", step: ". $step .") for shard ".$AS_Name."/".$AS_ShardName." by ".$nel_user['user_name'];
		$email_message	= $email_subject;
		nt_email($email_subject,$email_message,$restart_notification_emails);

		return $sequence_info;
	}

	function tool_main_get_restart_sequence($user_name, $domain_id, $shard_id)
	{
		global $db;

		$data = null;

		$sql = "SELECT * FROM ". NELDB_RESTART_SEQUENCE_TABLE ." WHERE restart_sequence_domain_id=". $domain_id ." AND restart_sequence_shard_id=". $shard_id ." AND restart_sequence_user_name='". $user_name ."' AND restart_sequence_step=0 AND restart_sequence_date_start=restart_sequence_date_end";
		if ($result = $db->sql_query($sql))
		{
			if ($db->sql_numrows($result))
			{
				$data = $db->sql_fetchrow($result);
			}
		}

		return $data;
	}

	function tool_main_get_restart_sequence_by_id($sequence_id)
	{
		global $db;

		$data = null;

		$sql = "SELECT * FROM ". NELDB_RESTART_SEQUENCE_TABLE ." WHERE restart_sequence_id=". $sequence_id;
		if ($result = $db->sql_query($sql))
		{
			if ($db->sql_numrows($result))
			{
				$data = $db->sql_fetchrow($result);
			}
		}

		return $data;
	}

	function tool_main_set_next_restart_sequence_step($sequence_id, $step=null)
	{
		global $db;
		global $nel_user;
		global $AS_Name, $AS_ShardName;
		global $restart_notification_emails;

		$now = time();

		if ($step === null)
		{
			$sequence_info = tool_main_get_restart_sequence_by_id($sequence_id);
			$step = $sequence_info['restart_sequence_step'] + 1;
		}

		$sql = "UPDATE ". NELDB_RESTART_SEQUENCE_TABLE ." SET restart_sequence_step=". $step .",restart_sequence_date_end=". $now ." WHERE restart_sequence_id=". $sequence_id;
		$db->sql_query($sql);

		nt_log("Shard Restart (Domain: '". $AS_Name ."' - Shard: '". $AS_ShardName ."' - Sequence: '". $sequence_id ."') - ". $nel_user['user_name'] ." moved to step ". $step);

		if ($step !== null)
		{
			$email_subject	= "[Shard Admin Tool] Restart Sequence Updated (id: ".$sequence_id.", step: ". $step .") for shard ".$AS_Name."/".$AS_ShardName." by ".$nel_user['user_name'];
			$email_message	= $email_subject;
			nt_email($email_subject,$email_message,$restart_notification_emails);
		}

		return tool_main_get_restart_sequence_by_id($sequence_id);
	}

	function tool_main_set_end_restart_sequence($sequence_id)
	{
		global $db;
		global $nel_user;
		global $AS_Name, $AS_ShardName;
		global $restart_notification_emails;

		//$sequence_info = tool_main_set_next_restart_sequence_step($sequence_id);
		$sequence_info = tool_main_get_restart_sequence_by_id($sequence_id);

		$sql = "UPDATE ". NELDB_SHARD_TABLE ." SET shard_restart=0 WHERE shard_domain_id=". $sequence_info['restart_sequence_domain_id'] ." AND shard_id=". $sequence_info['restart_sequence_shard_id'];
		$db->sql_query($sql);

		nt_log("Shard Restart (Domain: '". $AS_Name ."' - Shard: '". $AS_ShardName ."' - Sequence: '". $sequence_id ."') - ". $nel_user['user_name'] ." ended the sequence !". $step);

		$email_subject	= "[Shard Admin Tool] Restart Sequence Ends (id: ".$sequence_info['restart_sequence_id'].", step: ". $sequence_info['restart_sequence_step'] .") for shard ".$AS_Name."/".$AS_ShardName." by ".$nel_user['user_name'];
		$email_message	= $email_subject;
		nt_email($email_subject,$email_message,$restart_notification_emails);
	}

	function tool_main_get_domain_shard_restart($domain_id)
	{
		global $db;

		$num = 0;
		$sql = "SELECT * FROM ". NELDB_SHARD_TABLE ." WHERE shard_domain_id=". $domain_id ." AND shard_restart>0";
		if ($result = $db->sql_query($sql))
		{
			$num = $db->sql_numrows($result);
		}

		return $num;
	}

	function tool_main_get_restart_services($InternalName, $domainServices, $restart_list)
	{
		// lets sort each services by 'type'
		nt_common_add_debug("RESTART DEBUG");
		nt_common_add_debug($domainServices);

		$sortedServices = array();

		reset($domainServices);
		foreach($domainServices as $domainService)
		{
			if ($domainService['ShardName'] == $InternalName)
			{
				// this should be the real 'type'
				// $type = $domainService['ShortName'];
				// but instead we'll take the first part of the AliasName (as in "rws" or "rws_aniro")
				$type = explode('_',$domainService['AliasName']);
				$type = trim(strtolower($type[0]));

				if (!isset($sortedServices[$type]))
				{
					$sortedServices[$type] = array();
				}

				$sortedServices[$type][] = $domainService['AliasName'];
				nt_common_add_debug("Adding '". $domainService['AliasName'] ."' to '$type'");
			}
		}

		reset($restart_list);
		foreach($restart_list as $restart_key => $restart_group)
		{
			$group_list = explode(',', $restart_group['restart_group_list']);
			$tmp_list = array();

			reset($group_list);
			foreach($group_list as $group_service_type)
			{
				$group_service_type = trim($group_service_type);
				nt_common_add_debug("looking for '$group_service_type'");

				if (isset($sortedServices[$group_service_type]))
				{
					$tmp_list[] = implode(',',$sortedServices[$group_service_type]);
				}
				else
				{
					nt_common_add_debug("not found!");
				}
			}

			$restart_list[$restart_key]['service_list'] = implode(',',$tmp_list);

		}

        nt_common_add_debug("RESTART SERVICES DEBUG");
		nt_common_add_debug($restart_list);

		return $restart_list;
	}

	function tool_main_get_all_restart_services($restart_list)
	{
		$stop_data = array();
		$stop_list = '';

		reset($restart_list);
		foreach($restart_list as $restart_key => $restart_group)
		{
			$stop_data[] = $restart_group['service_list'];
		}

		$stop_list = implode(',', $stop_data);
		return $stop_list;
	}

	function tool_main_get_shardid_from_status($domainServices, $InternalName)
	{
		reset($domainServices);
		foreach($domainServices as $service)
		{
			if (($service['ShardName'] == $InternalName) && (is_numeric($service['ShardId'])))
			{
				return $service['ShardId'];
			}
		}

		return null;
	}

	function tool_main_get_egs_from_status($domainServices, $InternalName)
	{
		reset($domainServices);
		foreach ($domainServices as $service)
		{
			if (($service['ShardName'] == $InternalName) && ($service['ShortName'] == 'EGS'))
			{
				return $service['AliasName'];
			}
		}

		return null;
	}

	function tool_main_set_restart_sequence_timer($sequence_id, $timer)
	{
		global $db;

		$now 		= time();
		$timer 		= $timer;
		$new_timer	= $now + $timer;

		$sql = "UPDATE ". NELDB_RESTART_SEQUENCE_TABLE ." SET restart_sequence_date_end=". $now .",restart_sequence_timer=". $new_timer ." WHERE restart_sequence_id=". $sequence_id;
		$db->sql_query($sql);

		return array('start' => $now, 'end' => $new_timer);
	}

	function tool_main_change_restart_notification($event_list, $mode, $sql_connection)
	{
		if ($sql_connection != '' && sizeof($event_list))
		{
			$csdb = new sql_db_string($sql_connection);
			if (is_object($csdb))
			{
				$sql = "UPDATE Sorbot_events SET event_action=". $mode .",event_time=". time() .",event_lap=0 WHERE event_id IN (". implode(',', array_values($event_list)) .")";
				$csdb->sql_query($sql);

				$csdb->sql_close();
			}
		}
	}

	function tool_main_add_restart_notification($sequence_id, $service_su, $service_egs, $shard_id, $sorbot_message_type, $sql_connection, $shard_lang='en')
	{
		nt_common_add_debug('tool_main_add_restart_notification()');

		if ($sql_connection != '')
		{
			$csdb = new sql_db_string($sql_connection);
			if (is_object($csdb))
			{
				$sequence_info	= tool_main_get_restart_sequence_by_id($sequence_id);
				$shard_info		= tool_main_get_domain_shard_data($sequence_info['restart_sequence_domain_id'], $sequence_info['restart_sequence_shard_id']);

				if ($sorbot_message_type == 4102)
				{
					//$open_timer	= 60*25; // 25 minutes before a shard opens itself
					// new timer
					$open_timer	= 60*10; // 10 minutes before a shard opens itself
				}
				else // 4101
				{
					$open_timer = 0;
				}

				if ($sequence_info && $shard_info)
				{
					// lets find the shard id used by the ticket system
					$sql = "SELECT * FROM ForumCS_tickets_shards WHERE shard_ca='". $shard_info['domain_application'] ."' AND shard_id='". $shard_id ."'";
					if ($result = $csdb->sql_query($sql))
					{
						if ($csdb->sql_numrows($result))
						{
							$ticketsystem_shard_info = $csdb->sql_fetchrow($result);
							nt_common_add_debug($ticketsystem_shard_info);

							$ticketsystem_shard_id = $ticketsystem_shard_info['id'];

							// now we have the shard id, lets see which klients servers wants events for it
							$sql = "SELECT * FROM Sorbot_botconfig WHERE config_name='shardRestart' AND config_value LIKE '%:". $ticketsystem_shard_id .":%'";
							if ($result2 = $csdb->sql_query($sql))
							{
								if ($csdb->sql_numrows($result2))
								{
									//$klients_servers = array();
									//while ($row = $csdb->sql_fetchrow($result2))
									//{
									//	$klients_servers[] = $row['server_name'];
									//}

									// NOTE: live but not in CVS yet !
									$local_timer = $open_timer;

									$klients_servers = array();
									while ($row = $csdb->sql_fetchrow($result2))
									{
										$klients_servers[] = $row['server_name'];

										// lets find if there is any specific opening timer, and keep the lowest one
										$sql = "SELECT * FROM Sorbot_botconfig WHERE server_name='". $row['server_name'] ."' AND config_name='shardRestartOpenTimer'";
										if ($result3 = $csdb->sql_query($sql))
										{
											if ($csdb->sql_numrows($result3))
											{
												$timer_row = $csdb->sql_fetchrow($result3);
												if ($timer_row['config_value'] < $local_timer)
												{
													$local_timer = $timer_row['config_value'];
												}
											}
										}
									}

									$open_timer = $local_timer;
									// END NOTE: live but not in CVS yet !

									// ok now we the list of servers that want this event, lets give it to them

									// lets build some messages
									$klients_countdown = '';
									tool_main_get_elapsed_time_string($sequence_info['restart_sequence_timer'] - $sequence_info['restart_sequence_date_end'], $klients_countdown);
									$klients_countdown = trim($klients_countdown);

									$klients_open_countdown = '';
									tool_main_get_elapsed_time_string($open_timer, $klients_open_countdown);
									$klients_open_countdown = trim($klients_open_countdown);

									$opening_message = tool_admin_restart_messages_get_list_from_name('opening',$shard_lang);
									$opening_message = $opening_message[0]['restart_message_value'];

									$opened_message = tool_admin_restart_messages_get_list_from_name('opened',$shard_lang);
									$opened_message = $opening_message[0]['restart_message_value'];

									$klients_messages = array(	'before' => array(
																	".topic Shard Maintenance in progress for '". $ticketsystem_shard_info['shard_name'] ."' - Shard LOCKED - (". date("r",$sequence_info['restart_sequence_date_start']) ." - Countdown set to ". $klients_countdown .")",
																	"[Shard Maintenance] A Shard Restart has been triggered for shard '". $ticketsystem_shard_info['shard_name'] ."' on ". date("r",$sequence_info['restart_sequence_date_start']),
																	"[Shard Maintenance] Shard is LOCKED and should go down in ". $klients_countdown,
																),
																'at' => array(
																	".topic Shard Maintenance in progress for '". $ticketsystem_shard_info['shard_name'] ."' - Shard DOWN - (". date("r",$sequence_info['restart_sequence_date_start']) .")",
																	"[Shard Maintenance] A Shard Restart has been triggered for shard '". $ticketsystem_shard_info['shard_name'] ."' on ". date("r",$sequence_info['restart_sequence_date_start']),
																	"[Shard Maintenance] Shard is DOWN after a countdown of ". $klients_countdown,
																),
																'over' => array(
																	".topic Shard Maintenance in finished for '". $ticketsystem_shard_info['shard_name'] ."' - Shard LOCKED - Ready for CSRs ! ETA : |EventETA| - To Open : .sorOpenShard |EventID| 0",
																	"[Shard Maintenance] The Shard Restart that has been triggered for shard '". $ticketsystem_shard_info['shard_name'] ."' on ". date("r",$sequence_info['restart_sequence_date_start']) ." is now finished !",
																	"[Shard Maintenance] Shard is LOCKED and Ready for CSRs, it will OPEN automatically in |EventTIME| !",/*. $klients_open_countdown ." !",*/
																	"[Shard Maintenance] To change the OPEN countdown,  you need to send me the command : .sorOpenShard |EventID| <seconds>",
																	"[Shard Maintenance] Example to OPEN the Shard now, you need to send me the command : .sorOpenShard |EventID| 0",
																),
																'open' => array(
																	".topic Shard Maintenance over for '". $ticketsystem_shard_info['shard_name'] ."' - Shard OPEN ",
																	"[Shard Maintenance] The shard '". $ticketsystem_shard_info['shard_name'] ."' should now be OPEN to all !",
																),
																'cancel' => array(
																	".topic Shard Maintenance has been cancelled for '". $ticketsystem_shard_info['shard_name'] ."' - Shard OPEN",
																	"[Shard Maintenance] The shard restart has been CANCELLED for '". $ticketsystem_shard_info['shard_name'] ."', the shard is OPEN again !",
																),
																'giveup' => array(
																	".topic Shard Maintenance for '". $ticketsystem_shard_info['shard_name'] ."' is on hold for technical issues - Shard DOWN",
																	"[Shard Maintenance] The shard restart has been set ON HOLD for technical issues !",
																),
																'opening' => $opening_message,
																'opened' => $opened_message,
																);

									$notification_info = array(	'sequence'	=> $sequence_info,
																'ts'		=> $ticketsystem_shard_info,
																'messages'	=> $klients_messages,
																'shard'		=> $shard_info,
																'opentimer'	=> $open_timer,
																'shardid'	=> $shard_id,
																'shardsu'	=> $service_su,
																'shardegs'	=> $service_egs,
																);

									$notification_data = base64_encode(serialize($notification_info));

									$event_insert_ids = array();

									$sql = "LOCK TABLES Sorbot_events WRITE";
									$csdb->sql_query($sql);

									reset($klients_servers);
									foreach($klients_servers as $klient_server)
									{
										$sql  = "INSERT INTO Sorbot_events (`server_name`,`event_action`,`event_time`,`event_lap`,`event_params`) ";
										$sql .= " VALUES ('". $klient_server ."',". $sorbot_message_type .",". time() .",". $open_timer .",'". $notification_data ."')";
										$csdb->sql_query($sql);
										$event_insert_ids[] = $csdb->sql_nextid();
									}

									// we have a list of all the events, lets save them somewhere
									// lets inform each events of all other events for the same sequence
									if (sizeof($event_insert_ids))
									{
										$notification_info['eventlist'] = array_values($event_insert_ids);
										$notification_data = base64_encode(serialize($notification_info));

										$sql = "UPDATE Sorbot_events SET event_params='". $notification_data ."' WHERE event_id IN (". implode(',', array_values($event_insert_ids)) .")";
										$csdb->sql_query($sql);

										// save the events locally too
										tool_main_set_restart_sequence_events($sequence_id, implode(',',array_values($event_insert_ids)));
									}

									$sql = "UNLOCK TABLES";
									$csdb->sql_query($sql);
								}
								else
								{
									nt_common_add_debug('no klients server found wanting to hear about this event');
								}
							}
						}
						else
						{
							nt_common_add_debug('no shard found in TS matching the application and shard id');
						}
					}
					else
					{
						nt_common_add_debug('query failed ?!');
					}
				}
				else
				{
					nt_common_add_debug('missing some information about the sequence ?!');
				}

				$csdb->sql_close();
			}
			else
			{
				nt_common_add_debug('failed to init db!');
			}
		}
		else
		{
			nt_common_add_debug('no db string to work with');
		}
	}

	function tool_main_set_restart_sequence_events($sequence_id, $events)
	{
		global $db;

		$sql = "UPDATE ". NELDB_RESTART_SEQUENCE_TABLE ." SET restart_sequence_events='". $events ."' WHERE restart_sequence_id=". $sequence_id;
		$db->sql_query($sql);
	}

	function tool_main_get_domain_shard_data($domain_id, $shard_id)
	{
		global $db;

		$data = null;

		$sql  = "SELECT ". NELDB_DOMAIN_TABLE .".domain_id,";
		$sql .=            NELDB_DOMAIN_TABLE .".domain_name,";
		$sql .=            NELDB_DOMAIN_TABLE .".domain_as_host,";
		$sql .=            NELDB_DOMAIN_TABLE .".domain_as_port,";
		$sql .=            NELDB_DOMAIN_TABLE .".domain_application,";
		$sql .=            NELDB_SHARD_TABLE .".shard_id,";
		$sql .=            NELDB_SHARD_TABLE .".shard_name,";
		$sql .=            NELDB_SHARD_TABLE .".shard_as_id,";
		$sql .=            NELDB_SHARD_TABLE .".shard_domain_id,";
		$sql .=            NELDB_SHARD_TABLE .".shard_lang,";
		$sql .=            NELDB_SHARD_TABLE .".shard_restart";
		$sql .= " FROM ". NELDB_DOMAIN_TABLE .",". NELDB_SHARD_TABLE;
		$sql .= " WHERE domain_id=shard_domain_id AND domain_id=". $domain_id ." AND shard_id=". $shard_id;

		if ($result = $db->sql_query($sql))
		{
			if ($db->sql_numrows($result))
			{
				$data = $db->sql_fetchrow($result);
			}
		}

		return $data;
	}

	function tool_main_set_restart_sequence_user($AS_ShardRestart)
	{
		global $db;
		global $AS_Name, $AS_ShardName;
		global $nel_user;
		global $restart_notification_emails;

		$sequence_info	= tool_main_get_restart_sequence_by_id($AS_ShardRestart);

		if ($sequence_info)
		{
			$sql = "UPDATE ". NELDB_RESTART_SEQUENCE_TABLE ." SET restart_sequence_user_name='". $nel_user['user_name'] ."' WHERE restart_sequence_id=". $AS_ShardRestart;
			$db->sql_query($sql);

			nt_log("Shard Restart (Domain: '". $AS_Name ."' - Shard: '". $AS_ShardName ."' - Sequence: '". $AS_ShardRestart ."') owner set to '". $nel_user['user_name'] ."'");

			$email_subject	= "[Shard Admin Tool] Restart Sequence Takeover (id: ".$sequence_info['restart_sequence_id'].", step: ". $sequence_info['restart_sequence_step'] .") for shard ".$AS_Name."/".$AS_ShardName." by ".$nel_user['user_name'];
			$email_message	= $email_subject;
			nt_email($email_subject,$email_message,$restart_notification_emails);
		}
	}


?>