feature: fdb tables (#6616)

* feature: FDB TABLES for ios and timos * Fixed coding style issues * renamed fdb.sql to 191.sql * fixed travisCI issue * FDB table discovery working on IOS * Fixed bug: failing to insert fdb entries into database * Fix phpcbf issue * moved sql schema * rename sql schema * Add (tentative) FDB support for HP Comware switches * build schema * schema changes * run build schema....... * FBD Table discovery working on HP ComWare * FBD Table discovery working on HP ComWare * Add FDB support for HP Comware * Discovery regex fix, tested and works for cisco 3750, 2960, 6509 * Use vlan_id instead of raw vlan. Remove Nokia implementation as vlans are not being discovered for it at the moment. * Use vlan_id instead of vlan. * Add debug messages, comware support * Sorry.. phpunit isnt working for me * Use a file structure instead of if statement per OS * Make inserts to vlan table if entry does not exist. * Rename sql schema file * Use existing context name Improve output and database synchronization Remove chromephp and if ios rename sqlfile add comware back update schema * Delete TIMETRA-CHASSIS-MIB * Delete TIMETRA-FILTER-MIB * change index to bigint to be safe
2024-10-07 16:52:45 +00:00 · 2017-06-24 21:07:31 -06:00
parent 84814efc8b
commit 81ddab86af
15 changed files with 456 additions and 3 deletions
--- a/includes/discovery/fdb-table.inc.php
+++ b/includes/discovery/fdb-table.inc.php
@@ -0,0 +1,79 @@
+<?php
+
+$os_filename = 'includes/discovery/fdb-table/' . $device['os'] . '.inc.php';
+
+if (is_file($os_filename)) {
+    // Build ifIndex to port_id dictionary
+    $ifIndex_dict = array();
+    foreach (dbFetchRows("SELECT `ifIndex`,`port_id` FROM `ports` WHERE `device_id` = ?", array($device['device_id'])) as $port_entry) {
+        $ifIndex_dict[$port_entry['ifIndex']] = $port_entry['port_id'];
+    }
+
+    // Build dot1dBasePort to port_id dictionary
+    $portid_dict = array();
+
+    // Build a dictionary of vlans in database
+    $vlans_dict = array();
+    foreach (dbFetchRows("SELECT `vlan_id`, `vlan_vlan` from `vlans` WHERE `device_id` = ?", array($device['device_id'])) as $vlan_entry) {
+        $vlans_dict[$vlan_entry['vlan_vlan']] = $vlan_entry['vlan_id'];
+    }
+    $vlans_by_id = array_flip($vlans_dict);
+
+    // Build table of existing vlan/mac table
+    $existing_fdbs = array();
+    $sql_result = dbFetchRows("SELECT * FROM `ports_fdb` WHERE `device_id` = ?", array($device['device_id']));
+    foreach ($sql_result as $entry) {
+        $existing_fdbs[$entry['vlan_id']][$entry['mac_address']] = $entry;
+    }
+
+    // Include all fdb-table discovery modules
+    $insert = array();
+    include $os_filename;
+
+    $valid_fdb = array();
+
+    // synchronize with the database
+    foreach ($insert as $vlan_id => $mac_address_table) {
+        echo " {$vlans_by_id[$vlan_id]}: ";
+
+        foreach ($mac_address_table as $mac_address_entry => $entry) {
+            if ($existing_fdbs[$vlan_id][$mac_address_entry]) {
+                $new_port = $entry['port_id'];
+
+                if ($existing_fdbs[$vlan_id][$mac_address_entry]['port_id'] != $new_port) {
+                    $port_fdb_id = $existing_fdbs[$vlan_id][$mac_address_entry]['ports_fdb_id'];
+                    $valid_fdb[] = $port_fdb_id;
+
+                    dbUpdate(
+                        array('port_id' => $new_port),
+                        'ports_fdb',
+                        '`ports_fdb_id` = ?',
+                        array($port_fdb_id)
+                    );
+                    echo 'U';
+                } else {
+                    echo '.';
+                }
+                unset($existing_fdbs[$vlan_id][$mac_address_entry]);
+            } else {
+                $new_entry = array(
+                    'port_id' => $entry['port_id'],
+                    'mac_address' => $mac_address_entry,
+                    'vlan_id' => $vlan_id,
+                    'device_id' => $device['device_id'],
+                );
+
+                $valid_fdb = dbInsert($new_entry, 'ports_fdb');
+                echo '+';
+            }
+        }
+
+        foreach ($existing_fdbs[$vlan_id] as $entry) {
+            dbDelete('ports_fdb', '`ports_fdb_id` = ?', array($entry['ports_fdb_id']));
+            echo '-';
+        }
+        echo PHP_EOL;
+    }
+
+    unset($existing_fdbs, $ifIndex_dict, $portid_dict, $vlans_dict);
+}