Files
cacti/lib/variables.php
T
Jeff Pasnak 6e9f636abf #0002492 - Standardize mysql syntax - final pass
git-svn-id: svn+ssh://repo.cacti.net/var/data/svnroot/cacti/cacti/branches/0.8.8@7621 860744bd-22fc-0310-8c96-e9fe5004b5ca
2014-12-28 21:09:38 +00:00

268 lines
13 KiB
PHP

<?php
/*
+-------------------------------------------------------------------------+
| Copyright (C) 2004-2014 The Cacti Group |
| |
| This program is free software; you can redistribute it and/or |
| modify it under the terms of the GNU General Public License |
| as published by the Free Software Foundation; either version 2 |
| of the License, or (at your option) any later version. |
| |
| This program is distributed in the hope that it will be useful, |
| but WITHOUT ANY WARRANTY; without even the implied warranty of |
| MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| GNU General Public License for more details. |
+-------------------------------------------------------------------------+
| Cacti: The Complete RRDTool-based Graphing Solution |
+-------------------------------------------------------------------------+
| This code is designed, written, and maintained by the Cacti Group. See |
| about.php and/or the AUTHORS file for specific developer information. |
+-------------------------------------------------------------------------+
| http://www.cacti.net/ |
+-------------------------------------------------------------------------+
*/
/* update_data_source_title_cache_from_template - updates the title cache for all data sources
that match a given data template
@arg $data_template_id - (int) the ID of the data template to match */
function update_data_source_title_cache_from_template($data_template_id) {
$data = db_fetch_assoc("SELECT local_data_id FROM data_template_data WHERE data_template_id=$data_template_id AND local_data_id>0");
if (sizeof($data) > 0) {
foreach ($data as $item) {
update_data_source_title_cache($item["local_data_id"]);
}
}
}
/* update_data_source_title_cache_from_query - updates the title cache for all data sources
that match a given data query/index combination
@arg $snmp_query_id - (int) the ID of the data query to match
@arg $snmp_index - the index within the data query to match */
function update_data_source_title_cache_from_query($snmp_query_id, $snmp_index) {
$data = db_fetch_assoc("SELECT id FROM data_local WHERE snmp_query_id=$snmp_query_id AND snmp_index='$snmp_index'");
if (sizeof($data) > 0) {
foreach ($data as $item) {
update_data_source_title_cache($item["id"]);
}
}
}
/* update_data_source_title_cache_from_host - updates the title cache for all data sources
that match a given host
@arg $host_id - (int) the ID of the host to match */
function update_data_source_title_cache_from_host($host_id) {
$data = db_fetch_assoc("SELECT id FROM data_local WHERE host_id=$host_id");
if (sizeof($data) > 0) {
foreach ($data as $item) {
update_data_source_title_cache($item["id"]);
}
}
}
/* update_data_source_title_cache - updates the title cache for a single data source
@arg $local_data_id - (int) the ID of the data source to update the title cache for */
function update_data_source_title_cache($local_data_id) {
db_execute("UPDATE data_template_data set name_cache='" . addslashes(get_data_source_title($local_data_id)) . "' WHERE local_data_id=$local_data_id");
api_plugin_hook_function('update_data_source_title_cache', $local_data_id);
}
/* update_graph_title_cache_from_template - updates the title cache for all graphs
that match a given graph template
@arg $graph_template_id - (int) the ID of the graph template to match */
function update_graph_title_cache_from_template($graph_template_id) {
$graphs = db_fetch_assoc("SELECT local_graph_id FROM graph_templates_graph WHERE graph_template_id=$graph_template_id AND local_graph_id>0");
if (sizeof($graphs) > 0) {
foreach ($graphs as $item) {
update_graph_title_cache($item["local_graph_id"]);
}
}
}
/* update_graph_title_cache_from_query - updates the title cache for all graphs
that match a given data query/index combination
@arg $snmp_query_id - (int) the ID of the data query to match
@arg $snmp_index - the index within the data query to match */
function update_graph_title_cache_from_query($snmp_query_id, $snmp_index) {
$graphs = db_fetch_assoc("SELECT id FROM graph_local WHERE snmp_query_id=$snmp_query_id AND snmp_index='$snmp_index'");
if (sizeof($graphs) > 0) {
foreach ($graphs as $item) {
update_graph_title_cache($item["id"]);
}
}
}
/* update_graph_title_cache_from_host - updates the title cache for all graphs
that match a given host
@arg $host_id - (int) the ID of the host to match */
function update_graph_title_cache_from_host($host_id) {
$graphs = db_fetch_assoc("SELECT id FROM graph_local WHERE host_id=$host_id");
if (sizeof($graphs) > 0) {
foreach ($graphs as $item) {
update_graph_title_cache($item["id"]);
}
}
}
/* update_graph_title_cache - updates the title cache for a single graph
@arg $local_graph_id - (int) the ID of the graph to update the title cache for */
function update_graph_title_cache($local_graph_id) {
db_execute("UPDATE graph_templates_graph set title_cache='" . addslashes(get_graph_title($local_graph_id)) . "' WHERE local_graph_id=$local_graph_id");
}
/* null_out_substitutions - takes a string and cleans out any host variables that do not have values
@arg $string - the string to clean out unsubstituted variables for
@returns - the cleaned up string */
function null_out_substitutions($string) {
global $regexps;
return preg_replace("/\|host_" . VALID_HOST_FIELDS . "\|( - )?/i", "", $string);
}
/* expand_title - takes a string and substitutes all data query variables contained in it or cleans
them out if no data query is in use
@arg $host_id - (int) the host ID to match
@arg $snmp_query_id - (int) the data query ID to match
@arg $snmp_index - the data query index to match
@arg $title - the original string that contains the data query variables
@returns - the original string with all of the variable substitutions made */
function expand_title($host_id, $snmp_query_id, $snmp_index, $title) {
if ((strstr($title, "|")) && (!empty($host_id))) {
if (($snmp_query_id != "0") && ($snmp_index != "")) {
return substitute_snmp_query_data(null_out_substitutions(substitute_host_data($title, "|", "|", $host_id)), $host_id, $snmp_query_id, $snmp_index, read_config_option("max_data_query_field_length"));
}else{
return null_out_substitutions(substitute_host_data($title, "|", "|", $host_id));
}
}else{
return null_out_substitutions($title);
}
}
/* substitute_script_query_path - takes a string and substitutes all path variables contained in it
@arg $path - the string to make path variable substitutions on
@returns - the original string with all of the variable substitutions made */
function substitute_script_query_path($path) {
global $config;
$path = clean_up_path(str_replace("|path_cacti|", $config["base_path"], $path));
$path = clean_up_path(str_replace("|path_php_binary|", read_config_option("path_php_binary"), $path));
return $path;
}
/* substitute_host_data - takes a string and substitutes all host variables contained in it
@arg $string - the string to make host variable substitutions on
@arg $l_escape_string - the character used to escape each variable on the left side
@arg $r_escape_string - the character used to escape each variable on the right side
@arg $host_id - (int) the host ID to match
@returns - the original string with all of the variable substitutions made */
function substitute_host_data($string, $l_escape_string, $r_escape_string, $host_id) {
if (!empty($host_id)) {
if (!isset($_SESSION["sess_host_cache_array"][$host_id])) {
$host = db_fetch_row("SELECT * FROM host WHERE id=$host_id");
$_SESSION["sess_host_cache_array"][$host_id] = $host;
}
$string = str_replace($l_escape_string . "host_management_ip" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["hostname"], $string); /* for compatability */
$string = str_replace($l_escape_string . "host_hostname" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["hostname"], $string);
$string = str_replace($l_escape_string . "host_description" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["description"], $string);
$string = str_replace($l_escape_string . "host_snmp_community" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["snmp_community"], $string);
$string = str_replace($l_escape_string . "host_snmp_version" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["snmp_version"], $string);
$string = str_replace($l_escape_string . "host_snmp_username" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["snmp_username"], $string);
$string = str_replace($l_escape_string . "host_snmp_password" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["snmp_password"], $string);
$string = str_replace($l_escape_string . "host_snmp_auth_protocol" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["snmp_auth_protocol"], $string);
$string = str_replace($l_escape_string . "host_snmp_priv_passphrase" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["snmp_priv_passphrase"], $string);
$string = str_replace($l_escape_string . "host_snmp_priv_protocol" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["snmp_priv_protocol"], $string);
$string = str_replace($l_escape_string . "host_snmp_context" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["snmp_context"], $string);
$string = str_replace($l_escape_string . "host_snmp_port" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["snmp_port"], $string);
$string = str_replace($l_escape_string . "host_snmp_timeout" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["snmp_timeout"], $string);
$string = str_replace($l_escape_string . "host_ping_retries" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["ping_retries"], $string);
$string = str_replace($l_escape_string . "host_max_oids" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["max_oids"], $string);
$string = str_replace($l_escape_string . "host_id" . $r_escape_string, $_SESSION["sess_host_cache_array"][$host_id]["id"], $string);
}
return $string;
}
/* substitute_snmp_query_data - takes a string and substitutes all data query variables contained in it
@arg $string - the original string that contains the data query variables
@arg $host_id - (int) the host ID to match
@arg $snmp_query_id - (int) the data query ID to match
@arg $snmp_index - the data query index to match
@arg $max_chars - the maximum number of characters to substitute
@returns - the original string with all of the variable substitutions made */
function substitute_snmp_query_data($string, $host_id, $snmp_query_id, $snmp_index, $max_chars = 0) {
$snmp_cache_data = db_fetch_assoc("SELECT field_name,field_value FROM host_snmp_cache WHERE host_id=$host_id AND snmp_query_id=$snmp_query_id AND snmp_index='$snmp_index'");
if (sizeof($snmp_cache_data) > 0) {
foreach ($snmp_cache_data as $data) {
if ($data["field_value"] != "") {
if ($max_chars > 0) {
$data["field_value"] = substr($data["field_value"], 0, $max_chars);
}
$string = stri_replace("|query_" . $data["field_name"] . "|", $data["field_value"], $string);
}
}
}
return $string;
}
/* substitute_data_input_data - takes a string and substitutes all data input variables contained in it
@arg $string - the original string that contains the data input variables
@arg $local_data_id - (int) the local data id to match
@arg $max_chars - the maximum number of characters to substitute
@returns - the original string with all of the variable substitutions made */
function substitute_data_input_data($string, $graph, $local_data_id, $max_chars = 0) {
if (empty($local_data_id)) {
if (isset($graph['local_graph_id'])) {
$local_data_ids = array_rekey(db_fetch_assoc("SELECT DISTINCT local_data_id
FROM data_template_rrd
INNER JOIN graph_templates_item
ON data_template_rrd.id=graph_templates_item.task_item_id
WHERE local_graph_id=" . $graph["local_graph_id"]), "local_data_id", "local_data_id");
if (sizeof($local_data_ids)) {
$data_template_data_id = db_fetch_cell("SELECT id FROM data_template_data WHERE local_data_id IN (" . implode(",", $local_data_ids) . ")");
}else{
$data_template_data_id = 0;
}
}else{
$data_template_data_id = 0;
}
}else{
$data_template_data_id = db_fetch_cell("SELECT id FROM data_template_data WHERE local_data_id=$local_data_id");
}
if (!empty($data_template_data_id)) {
$data = db_fetch_assoc("SELECT
dif.data_name, did.value
FROM data_input_fields AS dif
INNER JOIN data_input_data AS did
ON dif.id=did.data_input_field_id
WHERE data_template_data_id=$data_template_data_id
AND input_output='in'");
if (sizeof($data)) {
foreach ($data as $item) {
if ($item["value"] != "") {
if ($max_chars > 0) {
$item["value"] = substr($item["field_value"], 0, $max_chars);
}
$string = stri_replace("|input_" . $item["data_name"] . "|", $item["value"], $string);
}
}
}
}
return $string;
}