<?php
/*
 +-------------------------------------------------------------------------+
 | Copyright (C) 2004-2026 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/                                                   |
 +-------------------------------------------------------------------------+
*/

/**
 * Deletes graphs based on the provided local graph IDs and delete type.
 *
 * @param array $local_graph_ids An array of local graph IDs to be deleted.
 * @param int   $delete_type     The type of deletion to perform:
 *                               - 1: Remove graphs only.
 *                               - 2: Remove graphs and all associated data sources.
 * @param bool  $update_totals   Optional. Whether to update object cache totals. Default is true.
 *
 * @return void
 */
function api_delete_graphs(array &$local_graph_ids, int $delete_type, bool $update_totals = true) : void {
	// check for a bad local_graph_id = 0, and remove graphs
	api_graph_remove_bad_graphs($local_graph_ids);

	if (!cacti_sizeof($local_graph_ids)) {
		return;
	}

	if ($update_totals) {
		if ($delete_type == 2) {
			object_cache_get_totals('graph_delete', $local_graph_ids);
		} else {
			object_cache_get_totals('graph_leave', $local_graph_ids);
		}
	}

	api_graph_remove_aggregate_items($local_graph_ids);

	switch ($delete_type) {
		case '2': // delete all data sources referenced by this graph
			$all_data_sources = array_rekey(
				db_fetch_assoc('SELECT DISTINCT dtd.local_data_id
					FROM data_template_data AS dtd
					INNER JOIN data_template_rrd AS dtr
					ON dtd.local_data_id=dtr.local_data_id
					INNER JOIN graph_templates_item AS gti
					ON dtr.id=gti.task_item_id
					WHERE ' . db_in_clause('gti.local_graph_id', $local_graph_ids) . '
					AND gti.local_graph_id NOT IN(SELECT local_graph_id FROM aggregate_graphs)
					AND dtd.local_data_id > 0'),
				'local_data_id', 'local_data_id'
			);

			if (cacti_sizeof($all_data_sources)) {
				$data_sources = array_rekey(
					db_fetch_assoc('SELECT dtd.local_data_id,
						COUNT(DISTINCT gti.local_graph_id) AS graphs
						FROM data_template_data AS dtd
						INNER JOIN data_template_rrd AS dtr
						ON dtd.local_data_id=dtr.local_data_id
						INNER JOIN graph_templates_item AS gti
						ON dtr.id=gti.task_item_id
						WHERE dtd.local_data_id > 0
						AND gti.local_graph_id NOT IN(SELECT local_graph_id FROM aggregate_graphs)
						GROUP BY dtd.local_data_id
						HAVING graphs = 1
						AND ' . db_in_clause('local_data_id', $all_data_sources)),
					'local_data_id', 'local_data_id'
				);

				if (cacti_sizeof($data_sources)) {
					api_data_source_remove_multi($data_sources, false);
				}

				api_graph_remove_multi($local_graph_ids);

				// Remove orphaned data sources
				$data_sources = array_rekey(
					db_fetch_assoc('SELECT DISTINCT dtd.local_data_id
						FROM data_template_data AS dtd
						INNER JOIN data_template_rrd AS dtr
						ON dtd.local_data_id=dtr.local_data_id
						LEFT JOIN graph_templates_item AS gti
						ON dtr.id=gti.task_item_id
						WHERE ' . db_in_clause('dtd.local_data_id', $all_data_sources) . '
						AND gti.local_graph_id IS NULL
						AND gti.local_graph_id NOT IN(SELECT local_graph_id FROM aggregate_graphs)
						AND dtd.local_data_id > 0'),
					'local_data_id', 'local_data_id'
				);

				if (cacti_sizeof($data_sources)) {
					api_data_source_remove_multi($data_sources, false);
				}
			} else {
				api_graph_remove_multi($local_graph_ids);
			}

			break;
		case '1':
			api_graph_remove_multi($local_graph_ids);

			break;
	}

	if ($update_totals) {
		object_cache_update_totals('delete');
	}

	/**
	 * Save the last time a graph was created/updated
	 * for Caching.
	 */
	set_config_option('time_last_change_graph', time());
}

/**
 * Removes a graph and its associated items from the database.
 *
 * @param int $local_graph_id The ID of the local graph to be removed.
 *
 * @return void
 */
function api_graph_remove(int $local_graph_id) : void {
	if (empty($local_graph_id)) {
		$local_graph_ids = [$local_graph_id];
		api_graph_remove_bad_graphs($local_graph_ids);

		return;
	}

	object_cache_get_totals('graph_leave', $local_graph_id);

	api_plugin_hook_function('graphs_remove', [$local_graph_id]);

	api_graph_remove_aggregate_items($local_graph_id);

	db_execute_prepared('DELETE FROM graph_templates_graph WHERE local_graph_id = ?', [$local_graph_id]);
	db_execute_prepared('DELETE FROM graph_templates_item WHERE local_graph_id = ?', [$local_graph_id]);
	db_execute_prepared('DELETE FROM graph_tree_items WHERE local_graph_id = ?', [$local_graph_id]);
	db_execute_prepared('DELETE FROM reports_items WHERE local_graph_id = ?', [$local_graph_id]);
	db_execute_prepared('DELETE FROM graph_local WHERE id = ?', [$local_graph_id]);

	object_cache_update_totals('delete');

	/**
	 * Save the last time a graph was created/updated
	 * for Caching.
	 */
	set_config_option('time_last_change_graph', time());
}

/**
 * Removes bad graphs from the provided list of local graph IDs and deletes
 * corresponding entries from the database.
 *
 * @param array $local_graph_ids An array of local graph IDs to be checked and cleaned.
 *
 * @return void
 */
function api_graph_remove_bad_graphs(array &$local_graph_ids = []) : void {
	if (cacti_sizeof($local_graph_ids)) {
		$bad_graph = array_search(0, $local_graph_ids, true);

		if ($bad_graph !== false) {
			unset($local_graph_ids[$bad_graph]);

			db_execute('DELETE FROM graph_local
				WHERE id = 0');

			db_execute('DELETE FROM graph_templates_graph
				WHERE local_graph_id = 0
				AND graph_template_id = 0');

			db_execute('DELETE FROM graph_templates_item
				WHERE hash = ""
				AND local_graph_id = 0');
		}
	}

	/**
	 * Save the last time a graph was created/updated
	 * for Caching.
	 */
	set_config_option('time_last_change_graph', time());
}

/**
 * Removes aggregate items associated with the given local graph IDs.
 *
 * @param mixed $local_graph_ids An array of local graph IDs or a comma-separated string of local graph IDs.
 *
 * @return void
 */
function api_graph_remove_aggregate_items(mixed $local_graph_ids) : void {
	if (!is_array($local_graph_ids)) {
		$local_graph_ids = explode(',', $local_graph_ids);
	}

	$local_graph_ids = array_values(array_filter(array_map('intval', $local_graph_ids), static fn (int $id): bool => $id > 0));

	foreach ($local_graph_ids as $lgid) {
		$aggregate_graphs = array_rekey(
			db_fetch_assoc_prepared('SELECT DISTINCT aggregate_graph_id
				FROM aggregate_graphs_items
				WHERE local_graph_id = ?',
				[$lgid]),
			'aggregate_graph_id', 'aggregate_graph_id'
		);

		if (cacti_sizeof($aggregate_graphs)) {
			foreach ($aggregate_graphs as $ag) {
				$lgids = [$lgid];

				api_aggregate_disassociate($ag, $lgids);
			}
		}
	}
}

/**
 * Removes multiple graphs based on their local graph IDs.
 *
 * @param array $local_graph_ids An array of local graph IDs to be removed.
 *
 * @return void
 */
function api_graph_remove_multi(array $local_graph_ids) : void {
	// check for a bad local_graph_id = 0, and remove graphs
	api_graph_remove_bad_graphs($local_graph_ids);

	if (!cacti_sizeof($local_graph_ids)) {
		return;
	}

	api_plugin_hook_function('graphs_remove', $local_graph_ids);

	// Delete in chunks so the IN list stays bounded on large removals.
	foreach (array_chunk($local_graph_ids, 1000) as $chunk) {
		api_graph_remove_aggregate_items($chunk);

		db_execute('DELETE FROM graph_templates_graph WHERE ' . db_in_clause('local_graph_id', $chunk));
		db_execute('DELETE FROM graph_templates_item WHERE ' . db_in_clause('local_graph_id', $chunk));
		db_execute('DELETE FROM graph_tree_items WHERE ' . db_in_clause('local_graph_id', $chunk));
		db_execute('DELETE FROM reports_items WHERE ' . db_in_clause('local_graph_id', $chunk));
		db_execute('DELETE FROM graph_local WHERE ' . db_in_clause('id', $chunk));
	}

	/**
	 * Save the last time a graph was created/updated
	 * for Caching.
	 */
	set_config_option('time_last_change_graph', time());
}

/**
 * Resizes the selected graph, overriding the template value
 *
 * @param int $local_graph_id The ID of the local graph to resize.
 * @param int $graph_width    The new width of the graph.
 * @param int $graph_height   The new height of the graph.
 *
 * @return void
 */
function api_resize_graphs(int $local_graph_id, int $graph_width, int $graph_height) : void {
	// get graphs template id
	db_execute_prepared('UPDATE graph_templates_graph
		SET width = ?, height = ?
		WHERE local_graph_id = ?',
		[$graph_width, $graph_height, $local_graph_id]);
}

/**
 * Reapplies the suggested graph title for a given local graph ID.
 *
 * @param int $local_graph_id The ID of the local graph to update.
 *
 * @return bool True if the title was successfully updated, false otherwise.
 */
function api_reapply_suggested_graph_title(int $local_graph_id) : bool {
	// get graphs template id
	$graph_template_id = db_fetch_cell_prepared('SELECT graph_template_id
		FROM graph_templates_graph
		WHERE local_graph_id = ?',
		[$local_graph_id]);

	// if a non-template graph, simply return
	if ($graph_template_id == 0) {
		return false;
	}

	/* get the host associated with this graph for data queries only
	 * there's no "reapply suggested title" for "simple" graph templates */
	$graph_local = db_fetch_row_prepared('SELECT *
		FROM graph_local
		WHERE id = ?',
		[$local_graph_id]);

	// if this is not a data query graph, simply return
	if (!isset($graph_local['host_id'])) {
		return false;
	}

	// no snmp query graph id found
	if ($graph_local['snmp_query_graph_id'] == 0) {
		return false;
	}

	// get the suggested values from the suggested values cache
	$suggested_values = db_fetch_assoc_prepared("SELECT text, field_name
		FROM snmp_query_graph_sv
		WHERE snmp_query_graph_id = ?
		AND field_name = 'title'
		ORDER BY sequence",
		[$graph_local['snmp_query_graph_id']]);

	$matches = [];

	$suggested_values_graph = [];

	if (cacti_sizeof($suggested_values)) {
		foreach ($suggested_values as $suggested_value) {
			// once we find a match; don't try to find more
			if (!isset($suggested_values_graph[$suggested_value['field_name']])) {
				$max_chars = intval(read_config_option('max_data_query_field_length'));

				if (empty($max_chars)) {
					$max_chars = 40;
				}

				$subs_string = substitute_snmp_query_data($suggested_value['text'], $graph_local['host_id'], $graph_local['snmp_query_id'], $graph_local['snmp_index'], $max_chars);

				// if there are no '|' characters, all of the substitutions were successful
				if (!substr_count($subs_string, '|query')) {
					if (in_array($suggested_value['field_name'], $matches, true)) {
						continue;
					}

					$matches[] = $suggested_value['field_name'];

					db_execute_prepared('UPDATE graph_templates_graph
						SET ' . $suggested_value['field_name'] . ' = ?
						WHERE local_graph_id = ?',
						[$suggested_value['text'], $local_graph_id]);

					// once we find a working value for this very field, stop
					$suggested_values_graph[$suggested_value['field_name']] = true;
				}
			}
		}

		if (cacti_sizeof($matches)) {
			return true;
		}
	}

	return false;
}

/**
 * Retrieves a list of graphs associated with a specific data source.
 *
 * @param int $local_data_id The local data ID of the data source.
 *
 * @return array An associative array of graphs with graph IDs as keys and graph names as values.
 */
function api_get_graphs_from_datasource(int $local_data_id) : array {
	return array_rekey(db_fetch_assoc_prepared('SELECT DISTINCT graph_templates_graph.local_graph_id AS id,
		graph_templates_graph.title_cache AS name
		FROM (graph_templates_graph
		INNER JOIN graph_templates_item
		ON graph_templates_graph.local_graph_id = graph_templates_item.local_graph_id)
		INNER JOIN data_template_rrd
		ON graph_templates_item.task_item_id = data_template_rrd.id
		WHERE graph_templates_graph.local_graph_id > 0
		AND data_template_rrd.local_data_id = ?', [$local_data_id]), 'id', 'name');
}

/**
 * Duplicates a graph or graph template.
 *
 * @param int    $_local_graph_id    The ID of the local graph to duplicate. If provided, the function will duplicate this graph.
 * @param int    $_graph_template_id The ID of the graph template to duplicate. If provided, the function will duplicate this template.
 * @param string $graph_title        The title for the new graph or template. Placeholders in the title will be replaced accordingly.
 * @param bool   $map_to_data_query  Whether to map the duplicated graph template to a data query. Default is true.
 *
 * @return int|false The ID of the newly created local graph or graph template, or false on failure.
 */
function api_duplicate_graph(int $_local_graph_id, int $_graph_template_id, string $graph_title, bool $map_to_data_query = true) : int|false {
	global $struct_graph, $struct_graph_item;

	$local_graph_id        = 0;
	$graph_template_id     = 0;
	$graph_template_inputs = [];
	$graph_item_mappings   = [];
	$graph_template_items  = [];
	$graph_template_graph  = [];
	$transaction_started   = false;

	if (!empty($_local_graph_id)) {
		$graph_local = db_fetch_row_prepared('SELECT *
			FROM graph_local
			WHERE id = ?',
			[$_local_graph_id]);

		if (!cacti_sizeof($graph_local)) {
			return false;
		}

		$graph_template_graph = db_fetch_row_prepared('SELECT *
			FROM graph_templates_graph
			WHERE local_graph_id = ?',
			[$_local_graph_id]);

		$graph_template_items = db_fetch_assoc_prepared('SELECT *
			FROM graph_templates_item
			WHERE local_graph_id = ?',
			[$_local_graph_id]);

		// create new entry: graph_local
		$save       = [];
		$save['id'] = 0;

		$save['graph_template_id'] = $graph_local['graph_template_id'];
		$save['host_id']           = $graph_local['host_id'];
		$save['snmp_query_id']     = $graph_local['snmp_query_id'];
		$save['snmp_index']        = $graph_local['snmp_index'];

		$transaction_started = db_begin_transaction();

		if (!$transaction_started) {
			return false;
		}

		$local_graph_id = sql_save($save, 'graph_local');

		if (!$local_graph_id) {
			db_rollback_transaction();

			return false;
		}

		$graph_template_graph['title'] = str_replace('<graph_title>', $graph_template_graph['title'], $graph_title);
	} elseif (!empty($_graph_template_id)) {
		$graph_template        = db_fetch_row_prepared('SELECT *
			FROM graph_templates
			WHERE id = ?',
			[$_graph_template_id]);

		if (!cacti_sizeof($graph_template)) {
			return false;
		}

		$graph_template_graph  = db_fetch_row_prepared('SELECT *
			FROM graph_templates_graph
			WHERE graph_template_id = ?
			AND local_graph_id=0',
			[$_graph_template_id]);

		$graph_template_items  = db_fetch_assoc_prepared('SELECT *
			FROM graph_templates_item
			WHERE graph_template_id = ?
			AND local_graph_id=0',
			[$_graph_template_id]);

		$graph_template_inputs = db_fetch_assoc_prepared('SELECT *
			FROM graph_template_input
			WHERE graph_template_id = ?',
			[$_graph_template_id]);

		foreach ($graph_template_inputs as $graph_template_input) {
			if (!graph_template_input_column_is_allowed($graph_template_input['column_name'])) {
				cacti_log('ERROR: Graph template duplication refused an invalid Graph Item Input field', false, 'SECURITY');

				return false;
			}
		}

		$invalid_input_definitions = db_fetch_cell_prepared('SELECT COUNT(*)
			FROM graph_template_input_defs AS gtid
			INNER JOIN graph_template_input AS gti
			ON gti.id = gtid.graph_template_input_id
			LEFT JOIN graph_templates_item AS item
			ON item.id = gtid.graph_template_item_id
			WHERE gti.graph_template_id = ?
			AND (item.id IS NULL OR item.graph_template_id <> gti.graph_template_id OR item.local_graph_id <> 0)',
			[$_graph_template_id]);

		if ($invalid_input_definitions > 0) {
			cacti_log('ERROR: Graph template duplication refused invalid input ownership', false, 'SECURITY');

			return false;
		}

		// create new entry: graph_templates
		$transaction_started = db_begin_transaction();

		if (!$transaction_started) {
			return false;
		}

		$save       = [];
		$save['id'] = 0;

		$save['hash']     = get_hash_graph_template(0);
		$save['name']     = str_replace('<template_title>', $graph_template['name'], $graph_title);
		$save['multiple'] = $graph_template['multiple'];

		$graph_template_id = sql_save($save, 'graph_templates');

		if (!$graph_template_id) {
			db_rollback_transaction();

			return false;
		}
	}

	$save       = [];
	$save['id'] = 0;

	// create new entry: graph_templates_graph
	$save['local_graph_id']                = $local_graph_id;
	$save['local_graph_template_graph_id'] = ($graph_template_graph['local_graph_template_graph_id'] ?? 0);
	$save['graph_template_id']             = (!empty($_local_graph_id) ? $graph_template_graph['graph_template_id'] : $graph_template_id);
	$save['title_cache']                   = $graph_template_graph['title_cache'];

	foreach ($struct_graph as $field => $array) {
		if ($array['method'] == 'spacer') {
			continue;
		}
		$save[$field]        = $graph_template_graph[$field];
		$save['t_' . $field] = $graph_template_graph['t_' . $field];
	}

	$graph_templates_graph_id = sql_save($save, 'graph_templates_graph');

	if (!$graph_templates_graph_id) {
		db_rollback_transaction();

		return false;
	}

	// create new entry(s): graph_templates_item
	if (cacti_sizeof($graph_template_items)) {
		foreach ($graph_template_items as $graph_template_item) {
			$save       = [];
			$save['id'] = 0;

			// save a hash only for graph_template copy operations
			$save['hash']                         = (!empty($_graph_template_id) ? get_hash_graph_template(0, 'graph_template_item') : 0);
			$save['local_graph_id']               = $local_graph_id;
			$save['graph_template_id']            = (!empty($_local_graph_id) ? $graph_template_item['graph_template_id'] : $graph_template_id);
			$save['local_graph_template_item_id'] = ($graph_template_item['local_graph_template_item_id'] ?? 0);

			foreach ($struct_graph_item as $field => $array) {
				$save[$field] = $graph_template_item[$field];
			}

			$graph_item_mappings[$graph_template_item['id']] = sql_save($save, 'graph_templates_item');

			if (!$graph_item_mappings[$graph_template_item['id']]) {
				db_rollback_transaction();

				return false;
			}
		}
	}

	if (!empty($_graph_template_id)) {
		// create new entry(s): graph_template_input (graph template only)
		if (cacti_sizeof($graph_template_inputs)) {
			foreach ($graph_template_inputs as $graph_template_input) {
				$save       = [];
				$save['id'] = 0;

				$save['graph_template_id'] = $graph_template_id;
				$save['name']              = $graph_template_input['name'];
				$save['description']       = $graph_template_input['description'];
				$save['column_name']       = $graph_template_input['column_name'];
				$save['hash']              = get_hash_graph_template(0, 'graph_template_input');

				$graph_template_input_id   = sql_save($save, 'graph_template_input');

				if (!$graph_template_input_id) {
					db_rollback_transaction();

					return false;
				}

				$graph_template_input_defs = db_fetch_assoc_prepared('SELECT *
					FROM graph_template_input_defs
					WHERE graph_template_input_id = ?',
					[$graph_template_input['id']]);

				// create new entry(s): graph_template_input_defs (graph template only)
				if (cacti_sizeof($graph_template_input_defs)) {
					foreach ($graph_template_input_defs as $graph_template_input_def) {
						if (!isset($graph_item_mappings[$graph_template_input_def['graph_template_item_id']]) || !db_execute_prepared('INSERT INTO graph_template_input_defs
							(graph_template_input_id, graph_template_item_id)
							VALUES (?, ?)',
							[
								$graph_template_input_id,
								$graph_item_mappings[$graph_template_input_def['graph_template_item_id']]
							]
						)) {
							db_rollback_transaction();

							return false;
						}
					}
				}
			}
		}
	}

	if (!empty($_local_graph_id)) {
		update_graph_title_cache($local_graph_id);
	} elseif ($map_to_data_query) {
		// Graph Template, Check for Data Query Associated Graph Template
		$data_query_graphs = db_fetch_assoc_prepared('SELECT *
			FROM snmp_query_graph
			WHERE graph_template_id = ?',
			[$_graph_template_id]);

		if (cacti_sizeof($data_query_graphs)) {
			$name = db_fetch_cell_prepared('SELECT name
				FROM graph_templates
				WHERE id = ?',
				[$graph_template_id]);

			foreach ($data_query_graphs as $dqg) {
				$save       = [];
				$save['id'] = 0;

				$save['hash']              = get_hash_data_query(0, 'data_query_graph');
				$save['snmp_query_id']     = $dqg['snmp_query_id'];
				$save['name']              = $name;
				$save['graph_template_id'] = $graph_template_id;

				$snmp_query_graph_id = sql_save($save, 'snmp_query_graph');

				// map the snmp_query_graph_rrds
				if (!empty($snmp_query_graph_id)) {
					$snmp_query_graph_rrds = db_fetch_assoc_prepared('SELECT *
						FROM snmp_query_graph_rrd
						WHERE snmp_query_graph_id = ?',
						[$dqg['id']]);

					if (cacti_sizeof($snmp_query_graph_rrds)) {
						foreach ($snmp_query_graph_rrds as $sqgr) {
							db_execute_prepared('INSERT INTO snmp_query_graph_rrd
								(snmp_query_graph_id, data_template_id, data_template_rrd_id, snmp_field_name)
								VALUES (?, ?, ?, ?)',
								[
									$snmp_query_graph_id,
									$sqgr['data_template_id'],
									$sqgr['data_template_rrd_id'],
									$sqgr['snmp_field_name']
								]
							);
						}
					}
				}

				// map data source suggested values
				$snames = db_fetch_assoc_prepared('SELECT *
					FROM snmp_query_graph_rrd_sv
					WHERE snmp_query_graph_id = ?',
					[$dqg['id']]);

				if (cacti_sizeof($snames)) {
					foreach ($snames as $sn) {
						$save       = [];
						$save['id'] = 0;

						$save['hash']                = get_hash_data_query(0, 'data_query_sv_data_source');
						$save['snmp_query_graph_id'] = $snmp_query_graph_id;
						$save['data_template_id']    = $sn['data_template_id'];
						$save['sequence']            = $sn['sequence'];
						$save['field_name']          = $sn['field_name'];
						$save['text']                = $sn['text'];

						sql_save($save, 'snmp_query_graph_rrd_sv');
					}
				}

				// map graph suggested values
				$snames = db_fetch_assoc_prepared('SELECT *
					FROM snmp_query_graph_sv
					WHERE snmp_query_graph_id = ?',
					[$dqg['id']]);

				if (cacti_sizeof($snames)) {
					foreach ($snames as $sn) {
						$save       = [];
						$save['id'] = 0;

						$save['hash']                = get_hash_data_query(0, 'data_query_sv_graph');
						$save['snmp_query_graph_id'] = $snmp_query_graph_id;
						$save['sequence']            = $sn['sequence'];
						$save['field_name']          = $sn['field_name'];
						$save['text']                = $sn['text'];

						sql_save($save, 'snmp_query_graph_sv');
					}
				}
			}
		}
	}

	/**
	 * Save the last time a graph was created/updated
	 * for Caching.
	 */
	set_config_option('time_last_change_graph', time());

	if ($_local_graph_id > 0) {
		db_commit_transaction();

		return $local_graph_id;
	}

	if ($_graph_template_id > 0) {
		db_commit_transaction();

		return $graph_template_id;
	} else {
		if ($transaction_started) {
			db_rollback_transaction();
		}

		return false;
	}
}

/**
 * Changes the device associated with a given graph.
 *
 * @param int $local_graph_id The ID of the local graph to update.
 * @param int $host_id        The ID of the new host to associate with the graph.
 *
 * @return bool Returns true if the device was successfully changed, false otherwise.
 */
function api_graph_change_device(int $local_graph_id, int $host_id) : bool {
	$proceed = false;

	$graph = db_fetch_row_prepared('SELECT *
		FROM graph_local
		WHERE id = ?',
		[$local_graph_id]);

	if (cacti_sizeof($graph)) {
		if ($graph['snmp_query_id'] > 0) {
			$exists = db_fetch_cell_prepared('SELECT snmp_query_id
				FROM host_snmp_query
				WHERE snmp_query_id = ?
				AND host_id = ?',
				[$graph['snmp_query_id'], $host_id]);

			if ($exists > 0) {
				$proceed = true;
			}
		} else {
			$proceed = true;
		}
	}

	if ($proceed) {
		db_execute_prepared('UPDATE graph_local
			SET host_id = ?
			WHERE id = ?',
			[$host_id, $local_graph_id]);

		update_graph_title_cache($local_graph_id);

		// update the data sources as well
		$data_ids = db_fetch_assoc_prepared('SELECT DISTINCT dtr.local_data_id
			FROM graph_templates_item AS gti
			INNER JOIN data_template_rrd AS dtr
			ON gti.task_item_id = dtr.id
			WHERE gti.local_graph_id = ?',
			[$local_graph_id]);

		if (cacti_sizeof($data_ids)) {
			foreach ($data_ids as $data_id) {
				db_execute_prepared('UPDATE data_local
					SET host_id = ?
					WHERE id = ?',
					[$host_id, $data_id['local_data_id']]);

				db_execute_prepared('UPDATE poller_item
					SET host_id = ?
					WHERE local_data_id = ?',
					[$host_id, $data_id['local_data_id']]);
			}
		}

		return true;
	}

	return false;
}