8 # usage: NAME_MAC=/dev/shm/file-with-name-space-mac sbw-parse.pl [optional-switch-snmpbulkwalk-dump]
10 # cat /dev/shm/neighbors.tab | grep MikroTik | tee /dev/stderr | awk '{ print $7 "_" $8 " " $3 }' > /tmp/name-mac
11 # NAME_MAC=/tmp/name-mac ./sbw-parse.pl
13 use Data::Dump qw(dump);
17 my $debug = $ENV{DEBUG} || 0;
19 my @cols = qw( ifName ifHighSpeed ifAdminStatus ifOperStatus ifType dot1dStpPortPathCost ifAlias );
21 my @name_mac_files = ( qw( /dev/shm/sw-name-mac /dev/shm/wap-name-mac ), $ENV{NAME_MAC}, glob '/dev/shm/name-mac*' );
24 foreach my $name_mac ( @name_mac_files ) {
25 next unless -e $name_mac;
26 open(my $f, '<'. $name_mac);
30 #my ( $ip, $name, $mac ) = split(/ /,$_);
31 my ( $name, $mac ) = split(/ /,$_);
33 $mac2name->{$mac} = $name;
36 warn "## $name_mac $count";
40 my ( $mac, $name ) = @_;
44 if ( exists $mac2name->{$mac} ) {
45 my $mac_name = $mac2name->{$mac};
46 warn "ERROR: name different $name != $mac_name" if $name && $name ne $mac_name;
47 return ( $mac, $mac_name );
49 return ( $mac, $name );
52 warn "# mac2name = ",dump($mac2name) if $debug;
60 $mac =~ s/^([0-9a-f]):/0$1:/;
61 while ( $mac =~ s/:([0-9a-f]):/:0$1:/g ) {};
62 $mac =~ s/:([0-9a-f])$/:0$1/;
67 sub sw_name_mac_port {
68 my ( $name, $mac, $port ) = @_;
70 if ( exists $mac2name->{$mac} ) {
71 my $sw_name = $mac2name->{$mac};
72 $sw->{$name}->{port_for_switch}->{$port}->{ $sw_name }++;
73 #print "## $name $port $sw_name\n";
77 my $gv; # collect for graphviz
80 @files = glob('snmpbulkwalk/*') unless @files;
82 foreach my $file ( @files ) {
83 my ( undef, $name ) = split(/\//, $file);
84 print "# $name $file\n" if $debug;
86 if ( -s "/dev/shm/$file" ) {
87 if ( -M $file < -M "/dev/shm/$file" ) {
88 warn "UPDATE $file\n";
89 system "cp -pv /dev/shm/$file $file";
91 $file="/dev/shm/$file";
93 warn "WARNING: using old file $file\n";
96 open(my $f, '<', $file);
99 if ( m/::(sysName|sysLocation|ipDefaultTTL|dot1dStpPriority|dot1dStpTopChanges|dot1dStpDesignatedRoot|dot1dStpRootCost|dot1dStpRootPort|dot1qNumVlans)\./ ) {
100 my ( undef, $v ) = split(/ = \w+: /,$_,2);
101 $sw->{$name}->{$1} = $v;
102 } elsif ( m/::(ifMtu|ifHighSpeed|ifSpeed)\[(\d\d?)\] = (?:INTEGER|Gauge32): (\d+)/ ) {
103 $sw->{$name}->{$1}->[$2] = $3;
104 # Dell PowerConnect 5548 doeesn't have ifHighSpeed
105 if ( $1 eq 'ifSpeed' && ! exists $sw->{$name}->{'ifHighSpeed'}->[$2] ) {
106 $sw->{$name}->{'ifHighSpeed'}->[$2] = $3 / 1_000_000;
108 } elsif ( m/::(ifPhysAddress)\[(\d\d?)\] = STRING: ([0-9a-f:]+)/ ) {
109 $sw->{$name}->{$1}->[$2] = fix_mac($3);
110 } elsif ( m/::(ifDescr|ifName|ifAlias)\[(\d\d?)\] = STRING: (.+)/ ) {
111 $sw->{$name}->{$1}->[$2] = $3;
112 if ( $1 eq 'ifName' ) {
113 my ( $if_name, $port ) = ($3,$2);
114 $sw->{$name}->{port_name_to_number}->{$if_name} = $port;
116 if ( $1 eq 'ifDescr' ) { # some switches miss ifName
117 my ( $if_name, $port ) = ($3,$2);
118 $if_name =~ s/gigabitethernet/ge/;
119 $if_name =~ s/tengigabitethernet/te/;
120 $sw->{$name}->{'ifName'}->[$port] = $if_name
121 if ( ! exists $sw->{name}->{'ifName'} );
122 $sw->{$name}->{port_name_to_number}->{$if_name} = $port
123 if ( ! exists $sw->{$name}->{port_name_to_number}->{$if_name} );
125 } elsif ( m/::(ifAdminStatus|ifOperStatus|ifType|dot3StatsDuplexStatus)\[(\d\d?)\] = INTEGER: (\w+)\(/ ) {
126 $sw->{$name}->{$1}->[$2] = $3;
127 } elsif ( m/::(dot1dStpPortPathCost)\[(\d\d?)\] = INTEGER: (\d+)/ ) {
128 $sw->{$name}->{$1}->[$2] = $3;
129 } elsif ( m/::(dot1dTpFdbPort)\[STRING: ([0-9a-f:]+)\] = INTEGER: (\d+)/ ) {
130 $sw->{$name}->{$1}->{ fix_mac($2) } = $3;
131 sw_name_mac_port( $name, $2, $3 );
132 } elsif ( m/::(dot1qTpFdbPort)\[(\d+)\]\[STRING: ([0-9a-f:]+)\] = INTEGER: (\d+)/ ) {
133 $sw->{$name}->{$1}->{ fix_mac($3) } = [ $4, $2 ]; # port, vlan
134 sw_name_mac_port( $name, $3, $4 );
137 # dot1qVlanCurrentEgressPorts
138 # dot1qVlanCurrentUntaggedPorts
139 # dot1qVlanStaticName
140 # dot1qVlanStaticEgressPorts
141 # dot1qVlanStaticUntaggedPorts
149 warn "# sw $name = ",dump($sw->{$name}) if $debug;
151 foreach my $port ( 1 .. $#{ $sw->{$name}->{ifDescr} } ) {
153 foreach my $oid ( @cols ) {
154 if ( $oid eq 'ifAlias' ) {
155 if ( defined( $sw->{$name}->{$oid}->[$port] ) ) {
156 print " [",$sw->{$name}->{$oid}->[$port],"]";
158 } elsif ( defined $sw->{$name}->{$oid}->[$port] ) {
159 print " ", $sw->{$name}->{$oid}->[$port];
162 #warn "MISSING $name $oid $port\n";
166 if ( exists( $sw->{$name}->{port_for_switch}->{ $port } ) ) {
167 my @visible = sort keys %{ $sw->{$name}->{port_for_switch}->{ $port } };
168 print " ",join(',', @visible);
170 if ( scalar @visible == 1 ) {
171 $gv->{$name}->{$port}->{ $visible[0] }->{ 'no_port' } = [$port,0]; # no port
179 # read neighbour visibility from lldp
182 my ($name,$port) = @_;
184 return $port if $port =~ m/^\d+$/;
185 $port =~ s{bridge\d*/}{}; # remove mikrotik port prefix
186 $port =~ s{,bridge\d*$}{}; # remove mikrotik port suffix
187 $port =~ s{,bonding\d*$}{}; # remove mikrotik port suffix
189 if ( exists $sw->{$name}->{port_name_to_number}->{$port} ) {
190 return $sw->{$name}->{port_name_to_number}->{$port};
193 # gigabitethernet1/0/45 or gi1/0/45
194 if ( $port =~ m{(.+)1/0/(\d+)$} ) {
195 my ($type,$port) = ($1,$2);
196 if ( $type =~ m{gi}i ) {
198 } elsif ( $type =~ m{te}i ) {
199 return $port <= 4 ? $port + 10000 : $port;
201 die "unknown [$type]";
206 if ( $port =~ m{eth(\d+)} ) {
210 my @fuzzy = grep { m/^$port/ } keys %{ $sw->{$name}->{port_name_to_number} };
211 if ( scalar @fuzzy == 1 ) {
212 return $sw->{$name}->{port_name_to_number}->{$fuzzy[0]}
215 warn "ERROR [$_] can't find port $port for $name in ",dump( $sw->{$name}->{port_name_to_number} );
220 if ( $name eq 'rack3-lib' ) {
221 $name = 'sw-lib-srv';
227 open(my $n_fh, '<', '/dev/shm/neighbors.tab');
230 my ( $sw1, $port1, undef, $port2, $sw2, undef ) = split(/\t/, $_, 6 );
231 next if $port2 =~ m/:/; # skip mac in port number (wap lldp leek)
232 next unless $sw2 && $port2;
233 $sw1 = fix_sw_name($sw1);
234 my $port1_nr = port2number( $sw1, $port1 );
235 my $port2_nr = port2number( $sw2, $port2 );
237 if ( $sw->{$sw1}->{ifType}->[$port1_nr] ne 'ethernetCsmacd' ) {
238 warn "SKIP $sw1 $port1_nr $sw->{$sw1}->{ifType}->[$port1_nr]\n";
240 } elsif ( $port1 =~ m{bridge} ) { # skip mikrotik bridges
241 # warn "SKIP $sw1 $port1_nr $port1\n";
245 $gv->{$sw1}->{$port1_nr}->{$sw2}->{$port2_nr} = [ $port1, $port2 ];
246 delete $gv->{$sw1}->{$port1_nr}->{$sw2}->{'no_port'} if exists $gv->{$sw1}->{$port1_nr}->{$sw2}->{'no_port'};
249 # FIXME sw-b101 doesn't have lldp so we insert data here manually from pictures
251 my ($sw1, $p1, $sw2, $p2) = @_;
252 $gv->{$sw1}->{$p1}->{$sw2}->{$p2} = [ $p1, $p2 ];
253 $gv->{$sw2}->{$p2}->{$sw1}->{$p1} = [ $p2, $p1 ];
255 delete $gv->{'sw-b101'};
256 fake_gv( 'sw-b101' => 3, 'sw-b101' => 4 ); # vlan1-to-vlan2 / vlan2-to-vlan1
258 fake_gv( 'sw-b101' => 21, 'sw-rack2' => 50 );
259 fake_gv( 'sw-b101' => 23, 'sw-lib-srv' => 48 );
260 fake_gv( 'sw-b101' => 24, 'sw-rack1' => 48 );
262 #delete $gv->{'sw-ganeti'};
263 # spf-16 -> "sw-rack2" => { 2 => ["16-sfp-uplink-b101,bridge", "te1/0/2"] },
265 print "# gv = ",dump( $gv );
267 open(my $dot_fh, '>', '/dev/shm/network.dot');
270 graph [ rankdir = LR ]
271 node [ shape = record ]
272 edge [ color = "gray" ]
278 foreach my $sw1 ( sort keys %$gv ) {
279 foreach my $p1 ( sort { $a <=> $b } keys %{ $gv->{$sw1} } ) {
280 foreach my $sw2 ( sort keys %{ $gv->{$sw1}->{$p1} } ) {
281 if ( $sw1 eq $sw2 ) {
282 warn "SKIP same switch $sw1 == $sw2\n";
285 #push @{ $node->{$sw1} }, [ $p1, $sw2 ];
286 foreach my $p2 ( keys %{ $gv->{$sw1}->{$p1}->{$sw2} } ) {
287 push @edges, [ $sw1, $sw2, $p1, $p2 ];
288 ##push @{ $node->{$sw2} }, [ $p2, $sw1 ];
289 push @{ $node->{$sw1} }, [ $p1, $sw2, $p2 ];
295 foreach my $n ( sort keys %$node ) {
298 sort { join(' ',@$a) <=> join(' ',@$b) }
300 print $dot_fh qq!"$n" [ label="!.uc($n).'|' . join('|', map {
301 sprintf "<%d>%2d %s%s", $_->[0], $_->[0], $_->[1], $_->[2] eq 'no_port' ? '' : ' ' . $_->[2]
302 } @port_sw ) . qq!" ];\n!;
305 foreach my $e ( sort { join(' ',@$a) cmp join(' ', @$b) } @edges ) {
307 print $dot_fh sprintf qq{ "%s":%d -> "%s":%d\n}, $e->[0], $e->[2], $e->[1], $e->[3];
314 system "dot -Tsvg /dev/shm/network.dot > /var/www/network.svg";
315 system 'git -C /dev/shm commit -m $( date +%Y-%m-%d ) network.dot' if ! $debug;