File Coverage

blib/lib/SNMP/BridgeQuery.pm

Criterion	Covered	Total	%
statement	9	84	10.7
branch	0	20	0.0
condition			n/a
subroutine	3	8	37.5
pod	0	5	0.0
total	12	117	10.2

package SNMP::BridgeQuery;

use strict;
use vars qw($VERSION @ISA @EXPORT @EXPORT_OK);

require Exporter;

@ISA 		= qw(Exporter);
@EXPORT 	= qw(queryfdb);
@EXPORT_OK	= qw(querymacs queryports queryat);
$VERSION	= 0.61;

use Net::SNMP;

my ($session);

sub connect {
   my %cla = @_;
   $cla{comm} = "public" unless exists $cla{comm};
   $session = Net::SNMP->session(-hostname  => $cla{host},
                                 -community => $cla{comm},
                                 -translate => [-octetstring => 0x0],
                                 );
}

sub queryat {
   my ($key, $newkey, %final);
   &connect(@_);

   my $ifoid = '1.3.6.1.2.1.3.1.1.1';
   my $ifref = $session->get_table($ifoid);

   if ($session->error) {
      return {error => "true"};
      exit 1;
   }

   my $physoid = '1.3.6.1.2.1.3.1.1.2';
   my $physref = $session->get_table($physoid);

   if ($session->error) {
      return {error => "true"};
      exit 1;
   }

   my $addroid = '1.3.6.1.2.1.3.1.1.3';
   my $addrref = $session->get_table($addroid);

   if ($session->error) {
      return {error => "true"};
      exit 1;
   }

   foreach $key (keys %{$physref}) {
      $physref->{$key} = unpack('H12', $physref->{$key});
      next if (length($physref->{$key}) < 12);
      ($newkey = $key) =~ s/$physoid//;
      $final{$physref->{$key}} =
         $addrref->{$addroid . $newkey} . "|" .
         $ifref->{$ifoid . $newkey};
   }

   return \%final;
}

sub queryfdb {
   my ($key, $newkey, %port, %final);
   &connect(@_);

   my $macoid = '1.3.6.1.2.1.17.4.3.1.1';
   my $macref = $session->get_table($macoid);

   if ($session->error) {
      return {error => "true"};
      exit 1;
   }

   my $portoid = '1.3.6.1.2.1.17.4.3.1.2';
   my $portref = $session->get_table($portoid);

   if ($session->error) {
      return {error => "true"};
      exit 1;
   }

   foreach $key (keys %{$portref}) {
      ($newkey = $key) =~ s/$portoid\.//;
      $port{$newkey} = $portref->{$key};
   }

   foreach $key (keys %{$macref}) {
      $macref->{$key} = unpack('H12', $macref->{$key});
      next if (length($macref->{$key}) < 12);
      ($newkey = $key) =~ s/$macoid\.//;
      $final{$macref->{$key}} = $port{$newkey}
   }

   return \%final;
}

sub querymacs {
   my ($key, $newkey, %mac);
   &connect(@_);

   my $macoid = '1.3.6.1.2.1.17.4.3.1.1';
   my $macref = $session->get_table($macoid);

   if ($session->error) {
      return {error => "true"};
      exit 1;
   }

   foreach $key (keys %{$macref}) {
      ($newkey = $key ) =~ s/$macoid\.//;
      $macref->{$key} = unpack('H12', $macref->{$key});
      $mac{$newkey} = sprintf("%12s", $macref->{$key});
   }

   return \%mac;
}

sub queryports {
   my ($key, $newkey, %port);
   &connect(@_);

   my $portoid = '1.3.6.1.2.1.17.4.3.1.2';
   my $portref = $session->get_table($portoid);

   if ($session->error) {
      return {error => "true"};
      exit 1;
   }

   foreach $key (keys %{$portref}) {
      ($newkey = $key ) =~ s/$portoid\.//;
      $port{$newkey} = $portref->{$key};
   }

   return \%port;
}

1;

__END__