librenms-librenms/discover-cdp.php

#!/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 `device_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");
  }
}

?>