Khaganat-NeL/khanat-opennel-code
2
0
Fork 0
Code Issues 21 Pull requests Projects Releases 1 Packages Wiki Activity
khanat-opennel-code/code/web/public_php/admin/functions_tool_main.php

1723 lines
50 KiB
PHP
Raw Normal View History

Changed: Updated translations
2015-12-18 12:02:31 +00:00
<?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 ($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 .= '<27> Mount : '. $row['hd_mount'] .'<br>';
$outp .= '<27> Size : '. $row['hd_size'] .'<br>';
$outp .= '<27> Used : '. $row['hd_used'] .'<br>';
$outp .= '<27> 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_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 = 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);
}
}
?>
Reference in a new issue Copy permalink