From 06ed902f69802390e90c4672dbd21edd0a4d24dd Mon Sep 17 00:00:00 2001
From: Adam Amstrong <adama@localhost>
Date: Tue, 3 Apr 2007 16:18:19 +0000
Subject: [PATCH] Re-add discover-cdp.php

git-svn-id: http://www.observium.org/svn/observer/trunk@16 61d68cd4-352d-0410-923a-c4978735b2b8
---
 discover-cdp.php | 92 ++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 92 insertions(+)
 create mode 100755 discover-cdp.php

diff --git a/discover-cdp.php b/discover-cdp.php
new file mode 100755
index 000000000..b336435b9
--- /dev/null
+++ b/discover-cdp.php
@@ -0,0 +1,92 @@
+#!/usr/bin/php
+<?
+
+include("config.php");
+include("includes/functions.php");
+include("includes/cdp.php");
+
+$device_query = mysql_query("SELECT * FROM `devices` WHERE `status` = '1' AND `os` = 'IOS' ORDER BY `id` DESC");
+
+while ($device = mysql_fetch_array($device_query)) {
+
+  $hostname = $device['hostname'];
+  $community = $device['community'];
+  echo("Discovering $hostname \n");
+  $id = $device['id'];
+  $host = $id;
+
+  echo("Detecting CDP neighbours on $device[1]...\n");
+  $snmp = new snmpCDP($hostname, $community);
+  $ports = $snmp->getports();
+  $cdp = $snmp->explore_cdp($ports);
+
+  unset($cdp_links);
+
+  foreach (array_keys($cdp) as $key) {
+    $port = $ports[$key];
+    $link = $cdp[$key];
+    $cdp_links .= $hostname . "," . $port['desc'] . "," . $link['host'] . "," . $link['port'] . "\n";   
+  }
+        
+  $cdp_links = trim($cdp_links);
+  foreach ( explode("\n" ,$cdp_links) as $link ) {
+    if ($link == "") { break; }
+    list($src_host,$src_if, $dst_host, $dst_if) = explode(",", $link);
+    $dst_host = strtolower($dst_host);  
+    $dst_if = strtolower($dst_if);
+    $src_host = strtolower($src_host);
+    $src_if = strtolower($src_if);
+    if ( isDomainResolves($dst_host . "." . $mydomain) ) { 
+      $dst_host = $dst_host . "." . $mydomain; 
+    }
+    $ip = gethostbyname($dst_host);
+    if ( match_network($nets, $ip) ) {	   
+      if ( mysql_result(mysql_query("SELECT COUNT(*) FROM `devices` WHERE `hostname` = '$dst_host'"), 0) == '0' ) {
+        createHost ($dst_host);
+      } else { 
+        #echo("Already got host $dst_host\n"); 
+      }
+    } else { echo("Bad DNS for $dst_host\n"); }
+    if ( mysql_result(mysql_query("SELECT COUNT(*) FROM `devices` WHERE `hostname` = '$dst_host'"), 0) == '1' && 
+      mysql_result(mysql_query("SELECT COUNT(*) FROM `devices` WHERE `hostname` = '$src_host'"), 0) == '1' &&
+      mysql_result(mysql_query("SELECT COUNT(*) FROM `interfaces` AS I, `devices` AS D WHERE `if` = '$dst_if' AND hostname = '$dst_host' AND D.id = I.host"), 0) == '1' && 
+      mysql_result(mysql_query("SELECT COUNT(*) FROM `interfaces` AS I, `devices` AS D WHERE `if` = '$src_if' AND hostname = '$src_host' AND D.id = I.host"), 0) == '1')
+   {
+      $dst_if_id   = mysql_result(mysql_query("SELECT I.id FROM `interfaces` AS I, `devices` AS D WHERE `if` = '$dst_if' AND hostname = '$dst_host' AND D.id = I.host"), 0);
+      $src_if_id   = mysql_result(mysql_query("SELECT I.id FROM `interfaces` AS I, `devices` AS D WHERE `if` = '$src_if' AND hostname = '$src_host' AND D.id = I.host"), 0);
+      $linkalive[] = $src_if_id . "," . $dst_if_id;
+      if ( mysql_result(mysql_query("SELECT COUNT(*) FROM `links` WHERE `dst_if` = '$dst_if_id' AND `src_if` = '$src_if_id'"),0) == '0') 
+      { 
+        $sql = "INSERT INTO `links` (`src_if`, `dst_if`, `cdp`) VALUES ('$src_if_id', '$dst_if_id', '1')";
+        mysql_query($sql);
+        echo("Creating Link : $src_host $src_if -> $dst_host $dst_if\n");
+      } else { 
+        #echo("Link already exists : $src_host $src_if -> $dst_host $dst_if\n "); 
+      }
+    } 
+  }
+}
+
+echo(count($linkalive) . " Entries\n");
+
+$query = mysql_query("SELECT * FROM `links`");
+while($entry = mysql_fetch_array($query)) {
+  $i = 0;
+  unset($alive);
+  while ($i < count($linkalive) && !$alive) {
+    list($src_if_id,$dst_if_id) = explode(",", $linkalive[$i]);
+    $thislink = $entry['src_if'] . "," .  $entry['dst_if'];
+    if ($thislink == $linkalive[$i]) {
+      $alive = "yes";
+    }
+    $i++;
+  }
+  if (!$alive) { 
+    mysql_query("DELETE FROM `links` WHERE `src_if` = '$entry[src_if]' AND `dst_if` = '$entry[dst_if]'"); 
+    echo("$src_if_id -> $dst_if_id REMOVED \n");
+  } else {
+    echo("$src_if_id -> $dst_if_id VALID \n");
+  }
+}
+
+?>