librenms/includes/discovery/vrf.inc.php
Vitali Kari b55938f031 Nokia vrf bgp (#9622)
* first commit

* clean code

* add snmpsim data for bgp

* renumber sql patch

* clear public ip

* update  misc/db_schema.yaml

* add test data and renumber sql-schema

* sql-schema

* sql-schema

* Update module_tables.yaml

* Update module_tables.yaml

* Update timos.json

* Update timos.snmprec

* Rename 281.sql to 282.sql

* update test data

* db migration

* Update 2019_01_16_195644_add_vrf_id_and_bgpLocalAs.php

* update db schema

* Update 2019_01_16_195644_add_vrf_id_and_bgpLocalAs.php

* Update 2019_01_16_195644_add_vrf_id_and_bgpLocalAs.php

* Update db_schema.yaml

* update schema
2019-01-19 11:44:32 -06:00

240 lines
11 KiB
PHP

<?php
use LibreNMS\Config;
if (Config::get('enable_vrfs')) {
if (in_array($device['os_group'], ['vrp', 'cisco']) ||
in_array($device['os'], ['junos', 'ironware'])) {
unset($vrf_count);
/*
There are 2 MIBs for VPNs : MPLS-VPN-MIB (oldest) and MPLS-L3VPN-STD-MIB (newest)
Unfortunately, there is no simple way to find out which one to use, unless we reference
all the possible devices and check what they support.
Therefore we start testing the MPLS-L3VPN-STD-MIB that is prefered if available.
*/
// Grab all the info first, then use it in the code.
// It removes load on the device and makes things much faster
$rds = snmp_walk($device, 'mplsL3VpnVrfRD', '-Osqn', 'MPLS-L3VPN-STD-MIB', null);
if (empty($rds)) {
$rds = snmp_walk($device, 'mplsVpnVrfRouteDistinguisher', '-Osqn', 'MPLS-VPN-MIB', null);
if (empty($rds) && $device['os_group'] == 'cisco') {
// Use CISCO-VRF-MIB if others don't work
$rds = snmp_walk($device, 'cvVrfName', '-Osqn', 'CISCO-VRF-MIB', null);
$rds = str_replace('.1.3.6.1.4.1.9.9.711.1.1.1.1.2.', '', $rds);
$vpnmib = 'CISCO-VRF-MIB';
// No descr_oid given, does not exist for CISCO-VRF-MIB
$descr_oid = null;
$ports_oid = '.1.3.6.1.4.1.9.9.711.1.2.1.1.2';
} else {
$vpnmib = 'MPLS-VPN-MIB';
$rds = str_replace('.1.3.6.1.3.118.1.2.2.1.3.', '', $rds);
$descr_oid = '.1.3.6.1.3.118.1.2.2.1.2';
$ports_oid = '.1.3.6.1.3.118.1.2.1.1.2';
}
} else {
$vpnmib = 'MPLS-L3VPN-STD-MIB';
$rds = str_replace('.1.3.6.1.2.1.10.166.11.1.2.2.1.4.', '', $rds);
$descr_oid = '.1.3.6.1.2.1.10.166.11.1.2.2.1.3';
$ports_oid = '.1.3.6.1.2.1.10.166.11.1.2.1.1.2';
}
d_echo("\n[DEBUG]\nUsing $vpnmib\n[/DEBUG]\n");
d_echo("\n[DEBUG OIDS]\n$rds\n[/DEBUG]\n");
$rds = trim($rds);
if ($descr_oid) {
$descrs = snmp_walk($device, $descr_oid, '-Osqn', $vpnmib, null);
$descrs = trim(str_replace("$descr_oid.", '', $descrs));
$descr_table = [];
foreach (explode("\n", $descrs) as $descr) {
$t = explode(' ', $descr, 2);
$descr_table[$t[0]] = $t[1];
}
}
$ports = snmp_walk($device, $ports_oid, '-Osqn', $vpnmib, null);
$ports = trim(str_replace("$ports_oid.", '', $ports));
$port_table = [];
foreach (explode("\n", $ports) as $port) {
$t = explode(' ', $port);
$dotpos = strrpos($t[0], '.');
$vrf_oid = substr($t[0], 0, $dotpos);
$port_id = substr($t[0], ($dotpos + 1));
if (empty($port_table[$vrf_oid])) {
$port_table[$vrf_oid][0] = $port_id;
} else {
array_push($port_table[$vrf_oid], $port_id);
}
}
foreach (explode("\n", $rds) as $oid) {
if (empty($descr_oid) && strpos($oid, 'Platform_iVRF')) {
// Skip since it is an internal service and not a VRF
continue;
}
echo "\n";
if ($oid) {
// 8.49.53.48.56.58.49.48.48 "1508:100"
// First digit gives number of chars in VRF Name, then it's ASCII
list($vrf_oid, $vrf_rd) = explode(' ', $oid);
$oid_values = explode('.', $vrf_oid);
$vrf_name = '';
for ($i = 1; $i <= $oid_values[0]; $i++) {
$vrf_name .= chr($oid_values[$i]);
}
// Some VRP versions output VRF RD values as Null terminated Hex-STRING rather than string.
// This has to be converted to decimal
if ($device['os'] == 'vrp' && preg_match('/^([^ ]+) +(([^ ]+) +.*) 00/', $oid, $matches)) {
//.1.3.6.1.2.1.10.166.11.1.2.2.1.4.5.116.101.115.116.49 36 35 33 30 31 3A 31 00
// regexp result => 5.116.101.115.116.49 -- 36 35 33 30 31 3A 31 -- 00
d_echo(" [DEBUG] VRP: RD HexString handling: $matches[2]");
$hex_vrf_rd = str_replace(' ', '', $matches[2]);
$vrf_rd = hex2str($hex_vrf_rd);
d_echo("\n [DEBUG] VRP: RD : $hex_vrf_rd -> $vrf_rd");
}
// Brocade Ironware outputs VRF RD values as Hex-STRING rather than string. This has to be converted to decimal
if ($device['os'] == 'ironware') {
$vrf_rd = substr($oid, -24); // Grab last 24 characters from $oid, which is the RD hex value
$vrf_rd = str_replace(' ', '', $vrf_rd); // Remove whitespace
$vrf_rd = str_split($vrf_rd, 8); // Split it into an array, with an object for each half of the RD
$vrf_rd[0] = hexdec($vrf_rd[0]); // Convert first object to decimal
$vrf_rd[1] = hexdec($vrf_rd[1]); // Convert second object to deciamal
$vrf_rd = implode(':', $vrf_rd); // Combine back into string, delimiter by colon
} elseif (empty($descr_oid)) {
// Move rd to vrf_name and remove rd (no way to grab these values with CISCO-VRF-MIB)
$vrf_name = $vrf_rd;
unset($vrf_rd);
}
echo "\n [VRF $vrf_name] OID - $vrf_oid";
echo "\n [VRF $vrf_name] RD - $vrf_rd";
echo "\n [VRF $vrf_name] DESC - ".$descr_table[$vrf_oid];
if (dbFetchCell('SELECT COUNT(*) FROM vrfs WHERE device_id = ? AND `vrf_oid`=?', [$device['device_id'], $vrf_oid])) {
dbUpdate(['mplsVpnVrfDescription' => $descr_table[$vrf_oid], 'mplsVpnVrfRouteDistinguisher' => $vrf_rd], 'vrfs', 'device_id=? AND vrf_oid=?', [$device['device_id'], $vrf_oid]);
} else {
dbInsert(['vrf_oid' => $vrf_oid, 'vrf_name' => $vrf_name, 'mplsVpnVrfRouteDistinguisher' => $vrf_rd, 'mplsVpnVrfDescription' => $descr_table[$vrf_oid], 'device_id' => $device['device_id']], 'vrfs');
}
$vrf_id = dbFetchCell('SELECT vrf_id FROM vrfs WHERE device_id = ? AND `vrf_oid`=?', [$device['device_id'], $vrf_oid]);
$valid_vrf[$vrf_id] = 1;
echo "\n [VRF $vrf_name] PORTS - ";
foreach ($port_table[$vrf_oid] as $if_id) {
$interface = dbFetchRow('SELECT * FROM `ports` WHERE `device_id` = ? AND `ifIndex` = ?', [$device['device_id'], $if_id]);
echo makeshortif($interface['ifDescr']).' ';
dbUpdate(['ifVrf' => $vrf_id], 'ports', 'port_id=?', [$interface['port_id']]);
$if = $interface['port_id'];
$valid_vrf_if[$vrf_id][$if] = 1;
}
}//end if
}//end foreach
} else if ($device['os_group'] == 'nokia') {
unset($vrf_count);
$vrtr = snmpwalk_cache_oid($device, 'vRtrConfTable', [], 'TIMETRA-VRTR-MIB');
$port_table = snmpwalk_cache_twopart_oid($device, 'vRtrIfName', [], 'TIMETRA-VRTR-MIB');
foreach ($vrtr as $vrf_oid => $vr) {
$vrf_name = $vr['vRtrName'];
$vrf_desc = $vr['vRtrName'];
$vrf_as = $vr['vRtrAS4Byte'];
$vrf_rd = $vr['vRtrRouteDistinguisher'];
// Nokia, The VPRN route distinguisher is a 8-octet object.
// It contains a 2-octet type field followed by a 6-octet value field. The type field specify how to interpret the value field.
// Type 0 specifies two subfields as a 2-octet administrative field and a 4-octet assigned number subfield.
// Type 1 specifies two subfields as a 4-octet administrative field which must contain an IP address and a 2-octet assigned number subfield.
// Type 2 specifies two subfields as a 4-octet administrative field which contains a 4-octet AS number and a 2-octet assigned number subfield.
// FIXME Hardcoded to Type 0
$vrf_rd = str_replace(' ', '', $vrf_rd);
if ($vrf_rd <> "000000000000") {
$vrf_rd_1 = substr($vrf_rd, 4, 4);
$vrf_rd_2 = substr($vrf_rd, 8);
$vrf_rd = hexdec($vrf_rd_1) . ":" . hexdec($vrf_rd_2);
} else {
$vrf_rd = null;
}
echo "\n [VRF $vrf_name] OID - $vrf_oid";
echo "\n [VRF $vrf_name] RD - $vrf_rd";
echo "\n [VRF $vrf_name] DESC - $vrf_desc";
$vrfs = [
'vrf_oid' => $vrf_oid,
'vrf_name' => $vrf_name,
'bgpLocalAs' => $vrf_as,
'mplsVpnVrfRouteDistinguisher' => $vrf_rd,
'mplsVpnVrfDescription' => $$vrf_desc,
'device_id' => $device['device_id'],
];
if (dbFetchCell('SELECT COUNT(*) FROM vrfs WHERE device_id = ? AND `vrf_oid`=?', [$device['device_id'], $vrf_oid])) {
dbUpdate(['vrf_name' => $vrf_name, 'bgpLocalAs' => $vrf_as, 'mplsVpnVrfRouteDistinguisher' => $vrf_rd, 'mplsVpnVrfDescription' => $vrf_desc], 'vrfs', 'device_id=? AND vrf_oid=?', [$device['device_id'], $vrf_oid]);
} else {
dbInsert($vrfs, 'vrfs');
}
$vrf_id = dbFetchCell('SELECT vrf_id FROM vrfs WHERE device_id = ? AND `vrf_oid`=?', [$device['device_id'], $vrf_oid]);
$valid_vrf[$vrf_id] = 1;
echo "\n [VRF $vrf_name] PORTS - ";
foreach ($port_table[$vrf_oid] as $if_index => $if_name) {
$interface = dbFetchRow('SELECT * FROM `ports` WHERE `device_id` = ? AND `ifIndex` = ?', [$device['device_id'], $if_index]);
echo makeshortif($interface['ifDescr']).' ';
dbUpdate(['ifVrf' => $vrf_id], 'ports', 'port_id=?', [$interface['port_id']]);
$if = $interface['port_id'];
$valid_vrf_if[$vrf_id][$if] = 1;
}
} //end foreach
} //end if
unset(
$descr_table,
$port_table
);
echo "\n";
$sql = "SELECT * FROM ports WHERE device_id = '".$device['device_id']."'";
foreach (dbFetchRows($sql) as $row) {
$if = $row['port_id'];
$vrf_id = $row['ifVrf'];
if ($row['ifVrf']) {
if (!$valid_vrf_if[$vrf_id][$if]) {
echo '-';
dbUpdate(['ifVrf' => 'NULL'], 'ports', 'port_id=?', [$if]);
} else {
echo '.';
}
}
}
$sql = "SELECT * FROM vrfs WHERE device_id = '".$device['device_id']."'";
foreach (dbFetchRows($sql) as $row) {
$vrf_id = $row['vrf_id'];
if (!$valid_vrf[$vrf_id]) {
echo '-';
dbDelete('vrfs', '`vrf_id` = ?', [$vrf_id]);
} else {
echo '.';
}
}
unset(
$valid_vrf_if,
$valid_vrf,
$row,
$sql
);
echo "\n";
} //end if