mirror of
https://github.com/librenms/librenms.git
synced 2024-10-07 16:52:45 +00:00
1d777693e1
* Refactor remove use of pear Net_IPv4 and Net_IPv6 Caution, I added tests to test the functionality of the new functions, but I'm not 100% certain the replaced usages match 100%. Please test. Left usage in generate-iplist.php because I'm not sure the use of that script, so I didn't want to implement additional functionality to support it. Add support for ipv6 fo ipInNetwork() function Add phpdocs to functions Remove accidental inclusion Use binary operations instead of string for networKFromIp() Tidy up binary operations in ipInNetwork() tidy parsing cidr network Change to a class based implementation. Update phpdocs. Fully catch exceptions for hex parsing. Fix mistake. support older phpunit versions Fix php shifting to negative with php 5 * Fix graph authorization. Uncaught exception and checking an ipv4 against an ipv6 network == fail. * Also remove colons from hex strings. * Fix typo in bgp polling Two passes of removing invalid characters from hex strings. (That way we don't mangle valid IPs)
1643 lines
54 KiB
PHP
1643 lines
54 KiB
PHP
<?php
|
|
|
|
/*
|
|
* LibreNMS
|
|
*
|
|
* Copyright (c) 2014 Neil Lathwood <https://github.com/laf/ http://www.lathwood.co.uk/fa>
|
|
*
|
|
* 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 3 of the License, or (at your
|
|
* option) any later version. Please see LICENSE.txt at the top level of
|
|
* the source code distribution for details.
|
|
*/
|
|
|
|
function authToken(\Slim\Route $route)
|
|
{
|
|
$app = \Slim\Slim::getInstance();
|
|
$token = $app->request->headers->get('X-Auth-Token');
|
|
if (isset($token) && !empty($token)) {
|
|
if (!function_exists('get_user')) {
|
|
$username = dbFetchCell('SELECT `U`.`username` FROM `api_tokens` AS AT JOIN `users` AS U ON `AT`.`user_id`=`U`.`user_id` WHERE `AT`.`token_hash`=?', array($token));
|
|
} else {
|
|
$username = get_user(dbFetchCell('SELECT `AT`.`user_id` FROM `api_tokens` AS AT WHERE `AT`.`token_hash`=?', array($token)));
|
|
}
|
|
if (!empty($username)) {
|
|
$authenticated = true;
|
|
} else {
|
|
$authenticated = false;
|
|
}
|
|
} else {
|
|
$authenticated = false;
|
|
}
|
|
|
|
if ($authenticated === false) {
|
|
$app->response->setStatus(401);
|
|
$output = array(
|
|
'status' => 'error',
|
|
'message' => 'API Token is missing or invalid; please supply a valid token',
|
|
);
|
|
echo _json_encode($output);
|
|
$app->stop();
|
|
}
|
|
}
|
|
|
|
|
|
|
|
function get_graph_by_port_hostname()
|
|
{
|
|
// This will return a graph for a given port by the ifName
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$hostname = $router['hostname'];
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$vars = array();
|
|
$vars['port'] = urldecode($router['ifname']);
|
|
$vars['type'] = $router['type'] ?: 'port_bits';
|
|
if (!empty($_GET['from'])) {
|
|
$vars['from'] = $_GET['from'];
|
|
}
|
|
|
|
if (!empty($_GET['to'])) {
|
|
$vars['to'] = $_GET['to'];
|
|
}
|
|
|
|
if ($_GET['ifDescr'] == true) {
|
|
$port = 'ifDescr';
|
|
} else {
|
|
$port = 'ifName';
|
|
}
|
|
|
|
$vars['width'] = $_GET['width'] ?: 1075;
|
|
$vars['height'] = $_GET['height'] ?: 300;
|
|
$auth = '1';
|
|
$vars['id'] = dbFetchCell("SELECT `P`.`port_id` FROM `ports` AS `P` JOIN `devices` AS `D` ON `P`.`device_id` = `D`.`device_id` WHERE `D`.`device_id`=? AND `P`.`$port`=? AND `deleted` = 0 LIMIT 1", array($device_id, $vars['port']));
|
|
$app->response->headers->set('Content-Type', get_image_type());
|
|
rrdtool_initialize(false);
|
|
include 'includes/graphs/graph.inc.php';
|
|
rrdtool_close();
|
|
}
|
|
|
|
|
|
function get_port_stats_by_port_hostname()
|
|
{
|
|
// This will return port stats based on a devices hostname and ifName
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$hostname = $router['hostname'];
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$ifName = urldecode($router['ifname']);
|
|
$port = dbFetchRow('SELECT * FROM `ports` WHERE `device_id`=? AND `ifName`=? AND `deleted` = 0', array($device_id, $ifName));
|
|
|
|
$in_rate = $port['ifInOctets_rate'] * 8;
|
|
$out_rate = $port['ifOutOctets_rate'] * 8;
|
|
$port['in_rate'] = formatRates($in_rate);
|
|
$port['out_rate'] = formatRates($out_rate);
|
|
$port['in_perc'] = number_format($in_rate / $port['ifSpeed'] * 100, 2, '.', '');
|
|
$port['out_perc'] = number_format($out_rate / $port['ifSpeed'] * 100, 2, '.', '');
|
|
$port['in_pps'] = format_bi($port['ifInUcastPkts_rate']);
|
|
$port['out_pps'] = format_bi($port['ifOutUcastPkts_rate']);
|
|
|
|
//only return requested columns
|
|
if (isset($_GET['columns'])) {
|
|
$cols = explode(",", $_GET['columns']);
|
|
foreach (array_keys($port) as $c) {
|
|
if (!in_array($c, $cols)) {
|
|
unset($port[$c]);
|
|
}
|
|
}
|
|
}
|
|
|
|
$output = array(
|
|
'status' => 'ok',
|
|
'port' => $port,
|
|
);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function get_graph_generic_by_hostname()
|
|
{
|
|
// This will return a graph type given a device id.
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$hostname = $router['hostname'];
|
|
$sensor_id = $router['sensor_id'] ?: null;
|
|
$vars = array();
|
|
$vars['type'] = $router['type'] ?: 'device_uptime';
|
|
if (isset($sensor_id)) {
|
|
$vars['id'] = $sensor_id;
|
|
$vars['type'] = str_replace('device_', 'sensor_', $vars['type']);
|
|
}
|
|
|
|
// use hostname as device_id if it's all digits
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$device = device_by_id_cache($device_id);
|
|
|
|
if (!empty($_GET['from'])) {
|
|
$vars['from'] = $_GET['from'];
|
|
}
|
|
|
|
if (!empty($_GET['to'])) {
|
|
$vars['to'] = $_GET['to'];
|
|
}
|
|
|
|
$vars['width'] = $_GET['width'] ?: 1075;
|
|
$vars['height'] = $_GET['height'] ?: 300;
|
|
$auth = '1';
|
|
$vars['device'] = dbFetchCell('SELECT `D`.`device_id` FROM `devices` AS `D` WHERE `D`.`hostname`=?', array($hostname));
|
|
$app->response->headers->set('Content-Type', get_image_type());
|
|
rrdtool_initialize(false);
|
|
include 'includes/graphs/graph.inc.php';
|
|
rrdtool_close();
|
|
}
|
|
|
|
|
|
function get_device()
|
|
{
|
|
// return details of a single device
|
|
$app = \Slim\Slim::getInstance();
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$hostname = $router['hostname'];
|
|
|
|
// use hostname as device_id if it's all digits
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
|
|
// find device matching the id
|
|
$device = device_by_id_cache($device_id);
|
|
if (!$device) {
|
|
$app->response->setStatus(404);
|
|
$output = array(
|
|
'status' => 'error',
|
|
'message' => "Device $hostname does not exist",
|
|
);
|
|
echo _json_encode($output);
|
|
$app->stop();
|
|
} else {
|
|
$host_id = get_vm_parent_id($device);
|
|
if (is_numeric($host_id)) {
|
|
$device = array_merge($device, array('parent_id' => $host_id));
|
|
}
|
|
$output = array(
|
|
'status' => 'ok',
|
|
'devices' => array($device),
|
|
);
|
|
echo _json_encode($output);
|
|
}
|
|
}
|
|
|
|
function list_devices()
|
|
{
|
|
// This will return a list of devices
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$order = $_GET['order'];
|
|
$type = $_GET['type'];
|
|
$query = mres($_GET['query']);
|
|
$param = array();
|
|
$join = '';
|
|
if (empty($order)) {
|
|
$order = 'hostname';
|
|
}
|
|
|
|
if (stristr($order, ' desc') === false && stristr($order, ' asc') === false) {
|
|
$order = '`'.$order.'` ASC';
|
|
}
|
|
|
|
if ($type == 'all' || empty($type)) {
|
|
$sql = '1';
|
|
} elseif ($type == 'location') {
|
|
$sql = "`location` LIKE '%".$query."%'";
|
|
} elseif ($type == 'ignored') {
|
|
$sql = "`ignore`='1' AND `disabled`='0'";
|
|
} elseif ($type == 'up') {
|
|
$sql = "`status`='1' AND `ignore`='0' AND `disabled`='0'";
|
|
} elseif ($type == 'down') {
|
|
$sql = "`status`='0' AND `ignore`='0' AND `disabled`='0'";
|
|
} elseif ($type == 'disabled') {
|
|
$sql = "`disabled`='1'";
|
|
} elseif ($type == 'os') {
|
|
$sql = "`os`=?";
|
|
$param[] = $query;
|
|
} elseif ($type == 'mac') {
|
|
$join = " LEFT JOIN `ports` ON `devices`.`device_id`=`ports`.`device_id` LEFT JOIN `ipv4_mac` ON `ports`.`port_id`=`ipv4_mac`.`port_id` ";
|
|
$sql = "`ipv4_mac`.`mac_address`=?";
|
|
$param[] = $query;
|
|
} elseif ($type == 'ipv4') {
|
|
$join = " LEFT JOIN `ports` ON `devices`.`device_id`=`ports`.`device_id` LEFT JOIN `ipv4_addresses` ON `ports`.`port_id`=`ipv4_addresses`.`port_id` ";
|
|
$sql = "`ipv4_addresses`.`ipv4_address`=?";
|
|
$param[] = $query;
|
|
} elseif ($type == 'ipv6') {
|
|
$join = " LEFT JOIN `ports` ON `devices`.`device_id`=`ports`.`device_id` LEFT JOIN `ipv6_addresses` ON `ports`.`port_id`=`ipv6_addresses`.`port_id` ";
|
|
$sql = "`ipv6_addresses`.`ipv6_address`=? OR `ipv6_addresses`.`ipv6_compressed`=?";
|
|
$param = array($query,$query);
|
|
} else {
|
|
$sql = '1';
|
|
}
|
|
$devices = array();
|
|
foreach (dbFetchRows("SELECT * FROM `devices` $join WHERE $sql ORDER by $order", $param) as $device) {
|
|
$host_id = get_vm_parent_id($device);
|
|
$device['ip'] = inet6_ntop($device['ip']);
|
|
if (is_numeric($host_id)) {
|
|
$device['parent_id'] = $host_id;
|
|
}
|
|
$devices[] = $device;
|
|
}
|
|
|
|
$count = count($devices);
|
|
|
|
$output = array(
|
|
'status' => 'ok',
|
|
'count' => $count,
|
|
'devices' => $devices,
|
|
);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function add_device()
|
|
{
|
|
// This will add a device using the data passed encoded with json
|
|
// FIXME: Execution flow through this function could be improved
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$data = json_decode(file_get_contents('php://input'), true);
|
|
// Default status & code to error and change it if we need to.
|
|
$status = 'error';
|
|
$code = 500;
|
|
// keep scrutinizer from complaining about snmpver not being set for all execution paths
|
|
$snmpver = 'v2c';
|
|
if (empty($data)) {
|
|
$message = 'No information has been provided to add this new device';
|
|
} elseif (empty($data['hostname'])) {
|
|
$message = 'Missing the device hostname';
|
|
}
|
|
|
|
$hostname = $data['hostname'];
|
|
$port = $data['port'] ? mres($data['port']) : $config['snmp']['port'];
|
|
$transport = $data['transport'] ? mres($data['transport']) : 'udp';
|
|
$poller_group = $data['poller_group'] ? mres($data['poller_group']) : 0;
|
|
$force_add = $data['force_add'] ? true : false;
|
|
if ($data['version'] == 'v1' || $data['version'] == 'v2c') {
|
|
if ($data['community']) {
|
|
$config['snmp']['community'] = array($data['community']);
|
|
}
|
|
|
|
$snmpver = mres($data['version']);
|
|
} elseif ($data['version'] == 'v3') {
|
|
$v3 = array(
|
|
'authlevel' => mres($data['authlevel']),
|
|
'authname' => mres($data['authname']),
|
|
'authpass' => mres($data['authpass']),
|
|
'authalgo' => mres($data['authalgo']),
|
|
'cryptopass' => mres($data['cryptopass']),
|
|
'cryptoalgo' => mres($data['cryptoalgo']),
|
|
);
|
|
|
|
array_push($config['snmp']['v3'], $v3);
|
|
$snmpver = 'v3';
|
|
} else {
|
|
$code = 400;
|
|
$status = 'error';
|
|
$message = "You haven't specified an SNMP version to use";
|
|
}
|
|
if (empty($message)) {
|
|
try {
|
|
$device_id = addHost($hostname, $snmpver, $port, $transport, $poller_group, $force_add);
|
|
$code = 201;
|
|
$status = 'ok';
|
|
$message = "Device $hostname ($device_id) has been added successfully";
|
|
} catch (Exception $e) {
|
|
$message = $e->getMessage();
|
|
}
|
|
}
|
|
|
|
$app->response->setStatus($code);
|
|
$output = array(
|
|
'status' => $status,
|
|
'message' => $message,
|
|
);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function del_device()
|
|
{
|
|
// This will add a device using the data passed encoded with json
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$hostname = $router['hostname'];
|
|
// Default status to error and change it if we need to.
|
|
$status = 'error';
|
|
$code = 500;
|
|
if (empty($hostname) || $config['api_demo'] == 1) {
|
|
$message = 'No hostname has been provided to delete';
|
|
if ($config['api_demo'] == 1) {
|
|
$message = "This feature isn\'t available in the demo";
|
|
}
|
|
|
|
$output = array(
|
|
'status' => $status,
|
|
'message' => $message,
|
|
);
|
|
} else {
|
|
// allow deleting by device_id or hostname
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$device = null;
|
|
if ($device_id) {
|
|
// save the current details for returning to the client on successful delete
|
|
$device = device_by_id_cache($device_id);
|
|
}
|
|
|
|
if ($device) {
|
|
$response = delete_device($device_id);
|
|
if (empty($response)) {
|
|
// FIXME: Need to provide better diagnostics out of delete_device
|
|
$output = array(
|
|
'status' => $status,
|
|
'message' => 'Device deletion failed',
|
|
);
|
|
} else {
|
|
// deletion succeeded - include old device details in response
|
|
$code = 200;
|
|
$status = 'ok';
|
|
$output = array(
|
|
'status' => $status,
|
|
'message' => $response,
|
|
'devices' => array($device),
|
|
);
|
|
}
|
|
} else {
|
|
// no device matching the name
|
|
$code = 404;
|
|
$output = array(
|
|
'status' => $status,
|
|
'message' => "Device $hostname not found",
|
|
);
|
|
}
|
|
}
|
|
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function get_vlans()
|
|
{
|
|
// This will list all vlans for a given device
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$hostname = $router['hostname'];
|
|
$code = 500;
|
|
if (empty($hostname)) {
|
|
$output = $output = array(
|
|
'status' => 'error',
|
|
'message' => 'No hostname has been provided',
|
|
);
|
|
} else {
|
|
include_once '../includes/functions.php';
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$device = null;
|
|
if ($device_id) {
|
|
// save the current details for returning to the client on successful delete
|
|
$device = device_by_id_cache($device_id);
|
|
}
|
|
|
|
if ($device) {
|
|
$vlans = dbFetchRows('SELECT vlan_vlan,vlan_domain,vlan_name,vlan_type,vlan_mtu FROM vlans WHERE `device_id` = ?', array($device_id));
|
|
$total_vlans = count($vlans);
|
|
$code = 200;
|
|
$output = array(
|
|
'status' => 'ok',
|
|
'count' => $total_vlans,
|
|
'vlans' => $vlans,
|
|
);
|
|
} else {
|
|
$code = 404;
|
|
$output = array(
|
|
'status' => 'error', "Device $hostname not found"
|
|
);
|
|
}
|
|
}
|
|
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function show_endpoints()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$routes = $app->router()->getNamedRoutes();
|
|
$output = array();
|
|
foreach ($routes as $route) {
|
|
$output[$route->getName()] = $config['base_url'].$route->getPattern();
|
|
}
|
|
|
|
$app->response->setStatus('200');
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function list_bgp()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$code = 500;
|
|
$status = 'error';
|
|
$message = 'Error retrieving bgpPeers';
|
|
$sql = '';
|
|
$sql_params = array();
|
|
$hostname = $_GET['hostname'] ?: '';
|
|
$asn = $_GET['asn'] ?: '';
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
if (is_numeric($device_id)) {
|
|
$sql = ' AND `devices`.`device_id` = ?';
|
|
$sql_params[] = $device_id;
|
|
}
|
|
if (!empty($asn)) {
|
|
$sql = ' AND `devices`.`bgpLocalAs` = ?';
|
|
$sql_params[] = $asn;
|
|
}
|
|
|
|
$bgp_sessions = dbFetchRows("SELECT `bgpPeers`.* FROM `bgpPeers` LEFT JOIN `devices` ON `bgpPeers`.`device_id` = `devices`.`device_id` WHERE `bgpPeerState` IS NOT NULL AND `bgpPeerState` != '' $sql", $sql_params);
|
|
$total_bgp_sessions = count($bgp_sessions);
|
|
if (is_numeric($total_bgp_sessions)) {
|
|
$code = 200;
|
|
$status = 'ok';
|
|
$message = '';
|
|
}
|
|
|
|
$output = array(
|
|
'status' => "$status",
|
|
'err-msg' => $message,
|
|
'count' => $total_bgp_sessions,
|
|
'bgp_sessions' => $bgp_sessions,
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function get_graph_by_portgroup()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$group = $router['group'] ?: '';
|
|
$id = $router['id'] ?: '';
|
|
$vars = array();
|
|
if (!empty($_GET['from'])) {
|
|
$vars['from'] = $_GET['from'];
|
|
}
|
|
|
|
if (!empty($_GET['to'])) {
|
|
$vars['to'] = $_GET['to'];
|
|
}
|
|
|
|
$vars['width'] = $_GET['width'] ?: 1075;
|
|
$vars['height'] = $_GET['height'] ?: 300;
|
|
$auth = '1';
|
|
$if_list = '';
|
|
$ports = array();
|
|
|
|
if (!empty($id)) {
|
|
$if_list = $id;
|
|
} else {
|
|
$ports = get_ports_from_type(explode(',', $group));
|
|
}
|
|
if (empty($if_list)) {
|
|
$seperator = '';
|
|
foreach ($ports as $port) {
|
|
$if_list .= $seperator.$port['port_id'];
|
|
$seperator = ',';
|
|
}
|
|
}
|
|
|
|
unset($seperator);
|
|
$vars['type'] = 'multiport_bits_separate';
|
|
$vars['id'] = $if_list;
|
|
$app->response->headers->set('Content-Type', get_image_type());
|
|
rrdtool_initialize(false);
|
|
include 'includes/graphs/graph.inc.php';
|
|
rrdtool_close();
|
|
}
|
|
|
|
|
|
function get_components()
|
|
{
|
|
global $config;
|
|
$code = 200;
|
|
$status = 'ok';
|
|
$message = '';
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$hostname = $router['hostname'];
|
|
|
|
// Do some filtering if the user requests.
|
|
$options = array();
|
|
// We need to specify the label as this is a LIKE query
|
|
if (isset($_GET['label'])) {
|
|
// set a label like filter
|
|
$options['filter']['label'] = array('LIKE',$_GET['label']);
|
|
unset($_GET['label']);
|
|
}
|
|
// Add the rest of the options with an equals query
|
|
foreach ($_GET as $k => $v) {
|
|
$options['filter'][$k] = array('=',$v);
|
|
}
|
|
|
|
// use hostname as device_id if it's all digits
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$COMPONENT = new LibreNMS\Component();
|
|
$components = $COMPONENT->getComponents($device_id, $options);
|
|
|
|
$output = array(
|
|
'status' => "$status",
|
|
'err-msg' => $message,
|
|
'count' => count($components[$device_id]),
|
|
'components' => $components[$device_id],
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function add_components()
|
|
{
|
|
global $config;
|
|
$code = 200;
|
|
$status = 'ok';
|
|
$message = '';
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$hostname = $router['hostname'];
|
|
$ctype = $router['type'];
|
|
|
|
// use hostname as device_id if it's all digits
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$COMPONENT = new LibreNMS\Component();
|
|
$component = $COMPONENT->createComponent($device_id, $ctype);
|
|
|
|
$output = array(
|
|
'status' => "$status",
|
|
'err-msg' => $message,
|
|
'count' => count($component),
|
|
'components' => $component,
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function edit_components()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$hostname = $router['hostname'];
|
|
$data = json_decode(file_get_contents('php://input'), true);
|
|
|
|
// use hostname as device_id if it's all digits
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$COMPONENT = new LibreNMS\Component();
|
|
|
|
if ($COMPONENT->setComponentPrefs($device_id, $data)) {
|
|
// Edit Success.
|
|
$code = 200;
|
|
$status = 'ok';
|
|
$message = '';
|
|
} else {
|
|
// Edit Failure.
|
|
$code = 500;
|
|
$status = 'error';
|
|
$message = 'Components could not be edited.';
|
|
}
|
|
|
|
$output = array(
|
|
'status' => "$status",
|
|
'err-msg' => $message,
|
|
'count' => count($data),
|
|
);
|
|
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function delete_components()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$cid = $router['component'];
|
|
|
|
$COMPONENT = new LibreNMS\Component();
|
|
if ($COMPONENT->deleteComponent($cid)) {
|
|
// Edit Success.
|
|
$code = 200;
|
|
$status = 'ok';
|
|
$message = '';
|
|
} else {
|
|
// Edit Failure.
|
|
$code = 500;
|
|
$status = 'error';
|
|
$message = 'Components could not be deleted.';
|
|
}
|
|
|
|
$output = array(
|
|
'status' => "$status",
|
|
'err-msg' => $message,
|
|
);
|
|
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function get_graphs()
|
|
{
|
|
global $config;
|
|
$code = 200;
|
|
$status = 'ok';
|
|
$message = '';
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$hostname = $router['hostname'];
|
|
|
|
// FIXME: this has some overlap with html/pages/device/graphs.inc.php
|
|
// use hostname as device_id if it's all digits
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$graphs = array();
|
|
$graphs[] = array(
|
|
'desc' => 'Poller Time',
|
|
'name' => 'device_poller_perf',
|
|
);
|
|
$graphs[] = array(
|
|
'desc' => 'Ping Response',
|
|
'name' => 'device_ping_perf',
|
|
);
|
|
foreach (dbFetchRows('SELECT * FROM device_graphs WHERE device_id = ? ORDER BY graph', array($device_id)) as $graph) {
|
|
$desc = $config['graph_types']['device'][$graph['graph']]['descr'];
|
|
$graphs[] = array(
|
|
'desc' => $desc,
|
|
'name' => 'device_'.$graph['graph'],
|
|
);
|
|
}
|
|
|
|
$total_graphs = count($graphs);
|
|
$output = array(
|
|
'status' => "$status",
|
|
'err-msg' => $message,
|
|
'count' => $total_graphs,
|
|
'graphs' => $graphs,
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function list_available_health_graphs()
|
|
{
|
|
global $config;
|
|
$code = 200;
|
|
$status = 'ok';
|
|
$message = '';
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$hostname = $router['hostname'];
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
if (isset($router['type'])) {
|
|
list($dump, $type) = explode('_', $router['type']);
|
|
}
|
|
$sensor_id = $router['sensor_id'] ?: null;
|
|
$graphs = array();
|
|
|
|
if (isset($type)) {
|
|
if (isset($sensor_id)) {
|
|
$graphs = dbFetchRows('SELECT * FROM `sensors` WHERE `sensor_id` = ?', array($sensor_id));
|
|
} else {
|
|
foreach (dbFetchRows('SELECT `sensor_id`, `sensor_descr` FROM `sensors` WHERE `device_id` = ? AND `sensor_class` = ? AND `sensor_deleted` = 0', array($device_id, $type)) as $graph) {
|
|
$graphs[] = array(
|
|
'sensor_id' => $graph['sensor_id'],
|
|
'desc' => $graph['sensor_descr'],
|
|
);
|
|
}
|
|
}
|
|
} else {
|
|
foreach (dbFetchRows('SELECT `sensor_class` FROM `sensors` WHERE `device_id` = ? AND `sensor_deleted` = 0 GROUP BY `sensor_class`', array($device_id)) as $graph) {
|
|
$graphs[] = array(
|
|
'desc' => ucfirst($graph['sensor_class']),
|
|
'name' => 'device_'.$graph['sensor_class'],
|
|
);
|
|
}
|
|
}
|
|
|
|
$total_graphs = count($graphs);
|
|
$output = array(
|
|
'status' => "$status",
|
|
'err-msg' => $message,
|
|
'count' => $total_graphs,
|
|
'graphs' => $graphs,
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function get_port_graphs()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$hostname = $router['hostname'];
|
|
if (isset($_GET['columns'])) {
|
|
$columns = $_GET['columns'];
|
|
} else {
|
|
$columns = 'ifName';
|
|
}
|
|
|
|
// use hostname as device_id if it's all digits
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$ports = dbFetchRows("SELECT $columns FROM `ports` WHERE `device_id` = ? AND `deleted` = '0' ORDER BY `ifIndex` ASC", array($device_id));
|
|
$total_ports = count($ports);
|
|
$output = array(
|
|
'status' => 'ok',
|
|
'err-msg' => '',
|
|
'count' => $total_ports,
|
|
'ports' => $ports,
|
|
);
|
|
$app->response->setStatus('200');
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function get_ip_addresses()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
if (isset($router['hostname'])) {
|
|
$hostname = $router['hostname'];
|
|
// use hostname as device_id if it's all digits
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$ipv4 = dbFetchRows("SELECT `ipv4_addresses`.* FROM `ipv4_addresses` JOIN `ports` ON `ports`.`port_id`=`ipv4_addresses`.`port_id` WHERE `ports`.`device_id` = ? AND `deleted` = 0", array($device_id));
|
|
$ipv6 = dbFetchRows("SELECT `ipv6_addresses`.* FROM `ipv6_addresses` JOIN `ports` ON `ports`.`port_id`=`ipv6_addresses`.`port_id` WHERE `ports`.`device_id` = ? AND `deleted` = 0", array($device_id));
|
|
} elseif (isset($router['portid'])) {
|
|
$port_id = urldecode($router['portid']);
|
|
$ipv4 = dbFetchRows("SELECT * FROM `ipv4_addresses` WHERE `port_id` = ?", array($port_id));
|
|
$ipv6 = dbFetchRows("SELECT * FROM `ipv6_addresses` WHERE `port_id` = ?", array($port_id));
|
|
}
|
|
|
|
$output = array(
|
|
'status' => 'ok',
|
|
'err-msg' => '',
|
|
'addresses' => array_merge($ipv4, $ipv6),
|
|
);
|
|
|
|
$app->response->setStatus('200');
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function get_port_info()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$port_id = urldecode($router['portid']);
|
|
|
|
// use hostname as device_id if it's all digits
|
|
$port = dbFetchRows("SELECT * FROM `ports` WHERE `port_id` = ? AND `deleted` = 0", array($port_id));
|
|
$output = array(
|
|
'status' => 'ok',
|
|
'err-msg' => '',
|
|
'port' => $port,
|
|
);
|
|
$app->response->setStatus('200');
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function get_all_ports()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
if (isset($_GET['columns'])) {
|
|
$columns = $_GET['columns'];
|
|
} else {
|
|
$columns = 'ifName';
|
|
}
|
|
$ports = dbFetchRows("SELECT $columns FROM `ports` WHERE `deleted` = 0");
|
|
|
|
$output = array(
|
|
'status' => 'ok',
|
|
'err-msg' => '',
|
|
'ports' => $ports,
|
|
);
|
|
$app->response->setStatus('200');
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function get_port_stack()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$hostname = $router['hostname'];
|
|
// use hostname as device_id if it's all digits
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
|
|
if (isset($_GET['valid_mappings'])) {
|
|
$mappings = dbFetchRows("SELECT * FROM `ports_stack` WHERE (`device_id` = ? AND `ifStackStatus` = 'active' AND (`port_id_high` != '0' AND `port_id_low` != '0')) ORDER BY `port_id_high` ASC", array($device_id));
|
|
} else {
|
|
$mappings = dbFetchRows("SELECT * FROM `ports_stack` WHERE `device_id` = ? AND `ifStackStatus` = 'active' ORDER BY `port_id_high` ASC", array($device_id));
|
|
}
|
|
|
|
$total_mappings = count($mappings);
|
|
$output = array(
|
|
'status' => 'ok',
|
|
'err-msg' => '',
|
|
'count' => $total_mappings,
|
|
'mappings' => $mappings,
|
|
);
|
|
$app->response->setStatus('200');
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function list_alert_rules()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$sql = '';
|
|
$param = array();
|
|
if (isset($router['id']) && $router['id'] > 0) {
|
|
$rule_id = mres($router['id']);
|
|
$sql = 'WHERE id=?';
|
|
$param = array($rule_id);
|
|
}
|
|
|
|
$rules = dbFetchRows("SELECT * FROM `alert_rules` $sql", $param);
|
|
$total_rules = count($rules);
|
|
$output = array(
|
|
'status' => 'ok',
|
|
'err-msg' => '',
|
|
'count' => $total_rules,
|
|
'rules' => $rules,
|
|
);
|
|
$app->response->setStatus('200');
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function list_alerts()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
if (isset($_GET['state'])) {
|
|
$param = array(mres($_GET['state']));
|
|
} else {
|
|
$param = array('1');
|
|
}
|
|
|
|
$sql = '';
|
|
if (isset($router['id']) && $router['id'] > 0) {
|
|
$alert_id = mres($router['id']);
|
|
$sql = 'AND id=?';
|
|
array_push($param, $alert_id);
|
|
}
|
|
|
|
$alerts = dbFetchRows("SELECT `D`.`hostname`, `A`.*, `R`.`severity` FROM `alerts` AS `A`, `devices` AS `D`, `alert_rules` AS `R` WHERE `D`.`device_id` = `A`.`device_id` AND `A`.`rule_id` = `R`.`id` AND `A`.`state` IN (?) $sql", $param);
|
|
$total_alerts = count($alerts);
|
|
$output = array(
|
|
'status' => 'ok',
|
|
'err-msg' => '',
|
|
'count' => $total_alerts,
|
|
'alerts' => $alerts,
|
|
);
|
|
$app->response->setStatus('200');
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function add_edit_rule()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$data = json_decode(file_get_contents('php://input'), true);
|
|
|
|
$status = 'error';
|
|
$message = '';
|
|
$code = 500;
|
|
|
|
$rule_id = mres($data['rule_id']);
|
|
|
|
$device_id = mres($data['device_id']);
|
|
if (empty($device_id) && !isset($rule_id)) {
|
|
$message = 'Missing the device id or global device id (-1)';
|
|
} elseif ($device_id == 0) {
|
|
$device_id = '-1';
|
|
}
|
|
|
|
$rule = $data['rule'];
|
|
if (empty($rule)) {
|
|
$message = 'Missing the alert rule';
|
|
}
|
|
|
|
$name = mres($data['name']);
|
|
if (empty($name)) {
|
|
$message = 'Missing the alert rule name';
|
|
}
|
|
|
|
$severity = mres($data['severity']);
|
|
$sevs = array(
|
|
'ok',
|
|
'warning',
|
|
'critical',
|
|
);
|
|
if (!in_array($severity, $sevs)) {
|
|
$message = 'Missing the severity';
|
|
}
|
|
|
|
$disabled = mres($data['disabled']);
|
|
if ($disabled != '0' && $disabled != '1') {
|
|
$disabled = 0;
|
|
}
|
|
|
|
$count = mres($data['count']);
|
|
$mute = mres($data['mute']);
|
|
$delay = mres($data['delay']);
|
|
$delay_sec = convert_delay($delay);
|
|
if ($mute == 1) {
|
|
$mute = true;
|
|
} else {
|
|
$mute = false;
|
|
}
|
|
|
|
$extra = array(
|
|
'mute' => $mute,
|
|
'count' => $count,
|
|
'delay' => $delay_sec,
|
|
);
|
|
$extra_json = json_encode($extra);
|
|
|
|
if (!isset($rule_id)) {
|
|
if (dbFetchCell('SELECT `name` FROM `alert_rules` WHERE `name`=?', array($name)) == $name) {
|
|
$message = 'Addition failed : Name has already been used';
|
|
}
|
|
} else {
|
|
if (dbFetchCell("SELECT name FROM alert_rules WHERE name=? AND id !=? ", array($name, $rule_id)) == $name) {
|
|
$message = 'Edition failed : Name has already been used';
|
|
}
|
|
}
|
|
|
|
if (empty($message)) {
|
|
if (is_numeric($rule_id)) {
|
|
if (dbUpdate(array('name' => $name, 'rule' => $rule, 'severity' => $severity, 'disabled' => $disabled, 'extra' => $extra_json), 'alert_rules', 'id=?', array($rule_id)) >= 0) {
|
|
$status = 'ok';
|
|
$code = 200;
|
|
} else {
|
|
$message = 'Failed to update existing alert rule';
|
|
}
|
|
} elseif (dbInsert(array('name' => $name, 'device_id' => $device_id, 'rule' => $rule, 'severity' => $severity, 'disabled' => $disabled, 'extra' => $extra_json), 'alert_rules')) {
|
|
$status = 'ok';
|
|
$code = 200;
|
|
} else {
|
|
$message = 'Failed to create new alert rule';
|
|
}
|
|
}
|
|
|
|
$output = array(
|
|
'status' => $status,
|
|
'err-msg' => $message,
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function delete_rule()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$rule_id = mres($router['id']);
|
|
$status = 'error';
|
|
$err_msg = '';
|
|
$message = '';
|
|
$code = 500;
|
|
if (is_numeric($rule_id)) {
|
|
$status = 'ok';
|
|
$code = 200;
|
|
if (dbDelete('alert_rules', '`id` = ? LIMIT 1', array($rule_id))) {
|
|
$message = 'Alert rule has been removed';
|
|
} else {
|
|
$message = 'No alert rule by that ID';
|
|
}
|
|
} else {
|
|
$err_msg = 'Invalid rule id has been provided';
|
|
}
|
|
|
|
$output = array(
|
|
'status' => $status,
|
|
'err-msg' => $err_msg,
|
|
'message' => $message,
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function ack_alert()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$alert_id = mres($router['id']);
|
|
$status = 'error';
|
|
$err_msg = '';
|
|
$message = '';
|
|
$code = 500;
|
|
if (is_numeric($alert_id)) {
|
|
$status = 'ok';
|
|
$code = 200;
|
|
if (dbUpdate(array('state' => 2), 'alerts', '`id` = ? LIMIT 1', array($alert_id))) {
|
|
$message = 'Alert has been acknowledged';
|
|
} else {
|
|
$message = 'No alert by that ID';
|
|
}
|
|
} else {
|
|
$err_msg = 'Invalid alert has been provided';
|
|
}
|
|
|
|
$output = array(
|
|
'status' => $status,
|
|
'err-msg' => $err_msg,
|
|
'message' => $message,
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function unmute_alert()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$alert_id = mres($router['id']);
|
|
$status = 'error';
|
|
$err_msg = '';
|
|
$message = '';
|
|
$code = 500;
|
|
if (is_numeric($alert_id)) {
|
|
$status = 'ok';
|
|
$code = 200;
|
|
if (dbUpdate(array('state' => 1), 'alerts', '`id` = ? LIMIT 1', array($alert_id))) {
|
|
$message = 'Alert has been unmuted';
|
|
} else {
|
|
$message = 'No alert by that ID';
|
|
}
|
|
} else {
|
|
$err_msg = 'Invalid alert has been provided';
|
|
}
|
|
|
|
$output = array(
|
|
'status' => $status,
|
|
'err-msg' => $err_msg,
|
|
'message' => $message,
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function get_inventory()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$status = 'error';
|
|
$err_msg = '';
|
|
$code = 500;
|
|
$hostname = $router['hostname'];
|
|
// use hostname as device_id if it's all digits
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$sql = '';
|
|
$params = array();
|
|
if (isset($_GET['entPhysicalClass']) && !empty($_GET['entPhysicalClass'])) {
|
|
$sql .= ' AND entPhysicalClass=?';
|
|
$params[] = mres($_GET['entPhysicalClass']);
|
|
}
|
|
|
|
if (isset($_GET['entPhysicalContainedIn']) && !empty($_GET['entPhysicalContainedIn'])) {
|
|
$sql .= ' AND entPhysicalContainedIn=?';
|
|
$params[] = mres($_GET['entPhysicalContainedIn']);
|
|
} else {
|
|
$sql .= ' AND entPhysicalContainedIn="0"';
|
|
}
|
|
|
|
if (!is_numeric($device_id)) {
|
|
$err_msg = 'Invalid device provided';
|
|
$total_inv = 0;
|
|
$inventory = array();
|
|
} else {
|
|
$sql .= ' AND `device_id`=?';
|
|
$params[] = $device_id;
|
|
$inventory = dbFetchRows("SELECT * FROM `entPhysical` WHERE 1 $sql", $params);
|
|
$code = 200;
|
|
$status = 'ok';
|
|
$total_inv = count($inventory);
|
|
}
|
|
|
|
$output = array(
|
|
'status' => $status,
|
|
'err-msg' => $err_msg,
|
|
'count' => $total_inv,
|
|
'inventory' => $inventory,
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
|
|
function list_oxidized()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
|
|
$devices = array();
|
|
$device_types = "'".implode("','", $config['oxidized']['ignore_types'])."'";
|
|
$device_os = "'".implode("','", $config['oxidized']['ignore_os'])."'";
|
|
foreach (dbFetchRows("SELECT hostname,os,location FROM `devices` LEFT JOIN devices_attribs AS `DA` ON devices.device_id = DA.device_id AND `DA`.attrib_type='override_Oxidized_disable' WHERE `disabled`='0' AND `ignore` = 0 AND (DA.attrib_value = 'false' OR DA.attrib_value IS NULL) AND (`type` NOT IN ($device_types) AND `os` NOT IN ($device_os))") as $device) {
|
|
if ($config['oxidized']['group_support'] == "true") {
|
|
foreach ($config['oxidized']['group']['hostname'] as $host_group) {
|
|
if (preg_match($host_group['regex'].'i', $device['hostname'])) {
|
|
$device['group'] = $host_group['group'];
|
|
break;
|
|
}
|
|
}
|
|
if (empty($device['group'])) {
|
|
foreach ($config['oxidized']['group']['os'] as $host_group) {
|
|
if ($host_group['match'] === $device['os']) {
|
|
$device['group'] = $host_group['group'];
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
if (empty($device['group'])) {
|
|
foreach ($config['oxidized']['group']['location'] as $host_group) {
|
|
if (preg_match($host_group['regex'].'i', $device['location'])) {
|
|
$device['group'] = $host_group['group'];
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
if (empty($device['group']) && !empty($config['oxidized']['default_group'])) {
|
|
$device['group'] = $config['oxidized']['default_group'];
|
|
}
|
|
}
|
|
unset($device['location']);
|
|
$devices[] = $device;
|
|
}
|
|
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($devices);
|
|
}
|
|
|
|
function list_bills()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$status = 'ok';
|
|
$err_msg = '';
|
|
$message = '';
|
|
$code = 200;
|
|
$bills = array();
|
|
$bill_id = mres($router['bill_id']);
|
|
$bill_ref = mres($_GET['ref']);
|
|
$bill_custid = mres($_GET['custid']);
|
|
if (!empty($bill_custid)) {
|
|
$sql = '`bill_custid` = ?';
|
|
$param = array($bill_custid);
|
|
} elseif (!empty($bill_ref)) {
|
|
$sql = '`bill_ref` = ?';
|
|
$param = array($bill_ref);
|
|
} elseif (is_numeric($bill_id)) {
|
|
$sql = '`bills`.`bill_id` = ?';
|
|
$param = array($bill_id);
|
|
} else {
|
|
$sql = '';
|
|
$param = array();
|
|
}
|
|
|
|
if (count($param) >= 1) {
|
|
$sql = "WHERE $sql";
|
|
}
|
|
|
|
foreach (dbFetchRows("SELECT `bills`.*,COUNT(port_id) AS `ports_total` FROM `bills` LEFT JOIN `bill_ports` ON `bill_ports`.`bill_id`=`bills`.`bill_id` $sql GROUP BY `bill_name`,`bill_ref` ORDER BY `bill_name`", $param) as $bill) {
|
|
$rate_data = $bill;
|
|
$allowed = '';
|
|
$used = '';
|
|
$percent = '';
|
|
$overuse = '';
|
|
|
|
if ($bill['bill_type'] == "cdr") {
|
|
$allowed = format_si($bill['bill_cdr'])."bps";
|
|
$used = format_si($rate_data['rate_95th'])."bps";
|
|
$percent = round(($rate_data['rate_95th'] / $bill['bill_cdr']) * 100, 2);
|
|
$overuse = $rate_data['rate_95th'] - $bill['bill_cdr'];
|
|
$overuse = (($overuse <= 0) ? "-" : format_si($overuse));
|
|
} elseif ($bill['bill_type'] == "quota") {
|
|
$allowed = format_bytes_billing($bill['bill_quota']);
|
|
$used = format_bytes_billing($rate_data['total_data']);
|
|
$percent = round(($rate_data['total_data'] / ($bill['bill_quota'])) * 100, 2);
|
|
$overuse = $rate_data['total_data'] - $bill['bill_quota'];
|
|
$overuse = (($overuse <= 0) ? "-" : format_bytes_billing($overuse));
|
|
}
|
|
$bill['allowed'] = $allowed;
|
|
$bill['used'] = $used;
|
|
$bill['percent'] = $percent;
|
|
$bill['overuse'] = $overuse;
|
|
|
|
$bill['ports'] = dbFetchRows("SELECT `D`.`device_id`,`P`.`port_id`,`P`.`ifName` FROM `bill_ports` AS `B`, `ports` AS `P`, `devices` AS `D` WHERE `B`.`bill_id` = ? AND `P`.`port_id` = `B`.`port_id` AND `D`.`device_id` = `P`.`device_id`", array($bill["bill_id"]));
|
|
|
|
$bills[] = $bill;
|
|
}
|
|
$count = count($bills);
|
|
$output = array(
|
|
'status' => $status,
|
|
'message' => $message,
|
|
'err-msg' => $err_msg,
|
|
'count' => $count,
|
|
'bills' => $bills
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function update_device()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$status = 'error';
|
|
$code = 500;
|
|
$hostname = $router['hostname'];
|
|
// use hostname as device_id if it's all digits
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$data = json_decode(file_get_contents('php://input'), true);
|
|
$bad_fields = array('device_id','hostname');
|
|
if (empty($data['field'])) {
|
|
$message = 'Device field to patch has not been supplied';
|
|
} elseif (in_array($data['field'], $bad_fields)) {
|
|
$message = 'Device field is not allowed to be updated';
|
|
} else {
|
|
if (is_array($data['field']) && is_array($data['data'])) {
|
|
foreach ($data['field'] as $tmp_field) {
|
|
if (in_array($tmp_field, $bad_fields)) {
|
|
$message = 'Device field is not allowed to be updated';
|
|
}
|
|
}
|
|
if ($message == '' && count($data['field']) == count($data['data'])) {
|
|
for ($x=0; $x<count($data['field']); $x++) {
|
|
$update[mres($data['field'][$x])] = mres($data['data'][$x]);
|
|
}
|
|
if (dbUpdate($update, 'devices', '`device_id`=?', array($device_id)) >= 0) {
|
|
$status = 'ok';
|
|
$code = 200;
|
|
$message = 'Device fields have been updated';
|
|
} else {
|
|
$message = 'Device fields failed to be updated';
|
|
}
|
|
} elseif ($message == '') {
|
|
$message = 'Device fields failed to be updated as the number of fields ('.count($data['field']).') does not match the supplied data ('.count($data['data']).')';
|
|
}
|
|
} elseif (dbUpdate(array(mres($data['field']) => mres($data['data'])), 'devices', '`device_id`=?', array($device_id)) >= 0) {
|
|
$status = 'ok';
|
|
$message = 'Device ' . mres($data['field']) . ' field has been updated';
|
|
$code = 200;
|
|
} else {
|
|
$message = 'Device ' . mres($data['field']) . ' field failed to be updated';
|
|
}
|
|
}
|
|
$output = array(
|
|
'status' => $status,
|
|
'message' => $message,
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function get_device_groups()
|
|
{
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$status = 'error';
|
|
$code = 404;
|
|
$hostname = $router['hostname'];
|
|
// use hostname as device_id if it's all digits
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
if (is_numeric($device_id)) {
|
|
$groups = GetGroupsFromDevice($device_id, 1);
|
|
} else {
|
|
$groups = GetDeviceGroups();
|
|
}
|
|
if (empty($groups)) {
|
|
$message = 'No device groups found';
|
|
} else {
|
|
$status = 'ok';
|
|
$code = 200;
|
|
$message = 'Found ' . count($groups) . ' device groups';
|
|
}
|
|
|
|
$output = array(
|
|
'status' => $status,
|
|
'message' => $message,
|
|
'count' => count($groups),
|
|
'groups' => $groups,
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function get_devices_by_group()
|
|
{
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$status = 'error';
|
|
$code = 404;
|
|
$count = 0;
|
|
$name = urldecode($router['name']);
|
|
$devices = array();
|
|
$full = $_GET['full'];
|
|
if (empty($name)) {
|
|
$message = 'No device group name provided';
|
|
} else {
|
|
$group_id = dbFetchCell("SELECT `id` FROM `device_groups` WHERE `name`=?", array($name));
|
|
$devices = GetDevicesFromGroup($group_id, true, $full);
|
|
$count = count($devices);
|
|
if (empty($devices)) {
|
|
$message = 'No devices found in group ' . $name;
|
|
} else {
|
|
$message = "Found $count in group $name";
|
|
$status = 'ok';
|
|
$code = 200;
|
|
}
|
|
}
|
|
$output = array(
|
|
'status' => $status,
|
|
'message' => $message,
|
|
'count' => $count,
|
|
'devices' => $devices,
|
|
);
|
|
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function list_ipsec()
|
|
{
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$status = 'error';
|
|
$code = 404;
|
|
$message = '';
|
|
$hostname = $router['hostname'];
|
|
$total = 0;
|
|
// use hostname as device_id if it's all digits
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
if (!is_numeric($device_id)) {
|
|
$message = "No valid hostname or device ID provided";
|
|
} else {
|
|
$ipsec = dbFetchRows("SELECT `D`.`hostname`, `I`.* FROM `ipsec_tunnels` AS `I`, `devices` AS `D` WHERE `I`.`device_id`=? AND `D`.`device_id` = `I`.`device_id`", array($device_id));
|
|
$total = count($ipsec);
|
|
$status = 'ok';
|
|
$code = 200;
|
|
}
|
|
|
|
$output = array(
|
|
'status' => $status,
|
|
'err-msg' => $message,
|
|
'count' => $total,
|
|
'ipsec' => $ipsec,
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function list_arp()
|
|
{
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$status = 'error';
|
|
$code = 404;
|
|
$message = '';
|
|
$ip = $router['ip'];
|
|
$hostname = mres($_GET['device']);
|
|
$total = 0;
|
|
if (empty($ip)) {
|
|
$message = "No valid IP provided";
|
|
} elseif ($ip === "all" && empty($hostname)) {
|
|
$message = "Device argument is required when requesting all entries";
|
|
} else {
|
|
$code = 200;
|
|
$status = 'ok';
|
|
if ($ip === "all") {
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$arp = dbFetchRows("SELECT `ipv4_mac`.* FROM `ipv4_mac` LEFT JOIN `ports` ON `ipv4_mac`.`port_id` = `ports`.`port_id` WHERE `ports`.`device_id` = ?", array($device_id));
|
|
} elseif (str_contains($ip, '/')) {
|
|
list($net, $cidr) = explode('/', $ip, 2);
|
|
$arp = dbFetchRows(
|
|
'SELECT * FROM `ipv4_mac` WHERE (inet_aton(`ipv4_address`) & ?) = ?',
|
|
array(cidr2long($cidr), ip2long($net))
|
|
);
|
|
} else {
|
|
$arp = dbFetchRows("SELECT * FROM `ipv4_mac` WHERE `ipv4_address`=?", array($ip));
|
|
}
|
|
$total = count($arp);
|
|
}
|
|
$output = array(
|
|
'status' => $status,
|
|
'err-msg' => $message,
|
|
'count' => $total,
|
|
'arp' => $arp,
|
|
);
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function list_services()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$status = 'ok';
|
|
$code = 200;
|
|
$message = '';
|
|
$services = array();
|
|
$where = array();
|
|
$params = array();
|
|
|
|
// Filter by State
|
|
if (isset($_GET['state'])) {
|
|
$where[] = '`service_status`=?';
|
|
$params[] = $_GET['state'];
|
|
$where[] = "`service_disabled`='0'";
|
|
$where[] = "`service_ignore`='0'";
|
|
|
|
if (!is_numeric($_GET['state'])) {
|
|
$status = 'error';
|
|
$message = "No valid service state provided, valid option is 0=Ok, 1=Warning, 2=Critical";
|
|
}
|
|
}
|
|
|
|
//Filter by Type
|
|
if (isset($_GET['type'])) {
|
|
$where[] = '`service_type` LIKE ?';
|
|
$params[] = $_GET['type'];
|
|
}
|
|
|
|
//GET by Host
|
|
if (isset($router['hostname'])) {
|
|
$hostname = $router['hostname'];
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
$where[] = '`device_id` = ?';
|
|
$params[] = $device_id;
|
|
|
|
if (!is_numeric($device_id)) {
|
|
$status = 'error';
|
|
$message = "No valid hostname or device id provided";
|
|
}
|
|
}
|
|
|
|
$query = 'SELECT * FROM `services`';
|
|
|
|
if (!empty($where)) {
|
|
$query .= ' WHERE ' . implode(' AND ', $where);
|
|
}
|
|
$query .= ' ORDER BY `service_ip`';
|
|
$services = array(dbFetchRows($query, $params)); // double array for backwards compat :(
|
|
|
|
$count = count($services);
|
|
$output = array(
|
|
'status' => $status,
|
|
'err-msg' => $message,
|
|
'count' => $count,
|
|
'services' => $services,
|
|
);
|
|
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|
|
|
|
function list_logs()
|
|
{
|
|
global $config;
|
|
$app = \Slim\Slim::getInstance();
|
|
$router = $app->router()->getCurrentRoute()->getParams();
|
|
$type = $app->router()->getCurrentRoute()->getName();
|
|
$hostname = $router['hostname'];
|
|
$device_id = ctype_digit($hostname) ? $hostname : getidbyname($hostname);
|
|
if ($type === 'list_eventlog') {
|
|
$table = 'eventlog';
|
|
$timestamp = 'datetime';
|
|
} elseif ($type === 'list_syslog') {
|
|
$table = 'syslog';
|
|
$timestamp = 'timestamp';
|
|
} elseif ($type === 'list_alertlog') {
|
|
$table = 'alert_log';
|
|
$timestamp = 'time_logged';
|
|
} elseif ($type === 'list_authlog') {
|
|
$table = 'authlog';
|
|
$timestamp = 'datetime';
|
|
} else {
|
|
$table = 'eventlog';
|
|
$timestamp = 'datetime';
|
|
}
|
|
|
|
$message = '';
|
|
$status = 'ok';
|
|
$code = 200;
|
|
$start = mres($_GET['start']) ?: 1;
|
|
$limit = mres($_GET['limit']) ?: 50;
|
|
$from = mres($_GET['from']);
|
|
$to = mres($_GET['to']);
|
|
|
|
$count_query = 'SELECT COUNT(*)';
|
|
$full_query = "SELECT `devices`.`hostname`, `devices`.`sysName`, `$table`.*";
|
|
|
|
$param = array();
|
|
$query = " FROM $table LEFT JOIN `devices` ON `$table`.`device_id`=`devices`.`device_id` WHERE 1";
|
|
|
|
if (is_numeric($device_id)) {
|
|
$query .= " AND `devices`.`device_id` = ?";
|
|
$param[] = $device_id;
|
|
}
|
|
|
|
if ($from) {
|
|
$query .= " AND $timestamp >= ?";
|
|
$param[] = $from;
|
|
}
|
|
|
|
if ($to) {
|
|
$query .= " AND $timestamp <= ?";
|
|
$param[] = $to;
|
|
}
|
|
|
|
$count_query = $count_query . $query;
|
|
$count = dbFetchCell($count_query, $param);
|
|
$full_query = $full_query . $query . " ORDER BY $timestamp ASC LIMIT $start,$limit";
|
|
$logs = dbFetchRows($full_query, $param);
|
|
|
|
$limited_count = count($logs);
|
|
$output = array(
|
|
'status' => $status,
|
|
'err-msg' => $message,
|
|
'count' => $limited_count,
|
|
'total' => $count,
|
|
'logs' => $logs,
|
|
);
|
|
|
|
$app->response->setStatus($code);
|
|
$app->response->headers->set('Content-Type', 'application/json');
|
|
echo _json_encode($output);
|
|
}
|