generate JSON output
[snmp-json.git] / printer-multi.pl
1 #!/usr/bin/perl
2 use warnings;
3 use strict;
4
5 use SNMP::Multi;
6 use Data::Dump qw(dump);
7
8 use JSON;
9 my $json;
10
11 my $debug = $ENV{DEBUG} || 0; 
12
13 my $community = 'public';
14 my @printers = qw(
15 10.60.3.15
16 10.60.3.17
17
18 10.60.3.19
19 10.60.3.21
20
21 10.60.3.23
22 10.60.3.25
23
24 10.60.3.27
25 10.60.3.29
26
27 10.60.3.31
28 10.60.3.33
29
30 10.60.3.35
31 10.60.3.37
32 );
33
34 @printers = @ARGV if @ARGV;
35
36 # remove final .1 since we are using bulkwalk to get values!
37 my %vars = qw[
38 info                            iso.3.6.1.2.1.1.1.0
39 name                            iso.3.6.1.2.1.43.5.1.1.16.1
40 serial                          iso.3.6.1.2.1.43.5.1.1.17.1
41 pages                           iso.3.6.1.2.1.43.10.2.1.4.1
42 @message                        iso.3.6.1.2.1.43.18.1.1.8
43 @consumable_name        iso.3.6.1.2.1.43.11.1.1.6.1
44 @consumable_max         iso.3.6.1.2.1.43.11.1.1.8.1
45 @consumable_curr        iso.3.6.1.2.1.43.11.1.1.9.1
46 @tray_max                       iso.3.6.1.2.1.43.8.2.1.9.1
47 @tray_capacity          iso.3.6.1.2.1.43.8.2.1.10.1
48 @tray_name                      iso.3.6.1.2.1.43.8.2.1.13.1
49 @tray_dim_x                     iso.3.6.1.2.1.43.8.2.1.4.1
50 @tray_dim_y                     iso.3.6.1.2.1.43.8.2.1.5.1
51 ];
52
53 my $oid2name;
54 my @vars;
55 while ( my ($name,$oid) = each %vars ) {
56         $oid =~ s/\.[0-1]$// if $name !~ /^\@/;
57         push @vars, [ $oid ];
58         $oid2name->{$oid} = $name;
59 }
60 my @oids = sort { length $a <=> length $b } keys %$oid2name;
61 warn "# vars = ",dump(@vars) if $debug;
62
63 my $sm = SNMP::Multi->new(
64         Method    => 'bulkwalk',
65         Community => $community,
66         Requests  => SNMP::Multi::VarReq->new(
67                 hosts => [ @printers ],
68                 vars  => [ @vars ],
69     ),
70         Timeout     => 1,
71         Retries     => 0,
72 ) or die $SNMP::Multi::error;
73
74 warn "# working on: ", join(' ', @printers),$/;
75
76 my $resp = $sm->execute() or die $sm->error();
77
78 my $collected;
79
80 foreach my $host ( $resp->hosts ) {
81         my $status;
82
83         foreach my $result ( $host->results ) {
84                 if ( $result->error ) {
85                         warn "ERROR: $host ", $result->error;
86                         next;
87                 }
88
89                 warn "## result = ", dump($result) if $debug;
90
91                 foreach my $v ( $result->varlists ) {
92                         foreach my $i ( @$v ) {
93                                 my ( $oid, undef, $val, $fmt ) = @$i;
94                                 if ( my $name = $oid2name->{$oid} ) {
95                                         $status->{$name} = $val;
96                                 } else {
97                                         my $oid_base;
98                                         foreach ( @oids ) {
99                                                 my $oid_part = substr($oid,0,length($_));
100                                                 if ( $oid_part eq $_ ) {
101                                                         $oid_base = $oid_part;
102                                                         last;
103                                                 }
104                                         }
105
106                                         my $name = $oid2name->{$oid_base} || die "no name for $oid in ",dump( $oid2name );
107                                         if ( $name =~ s/^\@// ) {
108                                                 push @{ $status->{$name} }, $val;
109                                         } else {
110                                                 $status->{$name} = $val;
111                                         }
112                                 }
113                         }
114                 }
115
116         }
117
118         foreach my $group ( grep { /\w+_\w+/ } keys %$status ) {
119                 my ( $prefix,$name ) = split(/_/,$group,2);
120                 foreach my $i ( 0 .. $#{ $status->{$group} } ) {
121                         $status->{$prefix}->[$i]->{$name} = $status->{$group}->[$i];
122                 }
123                 delete $status->{$group};
124         }
125
126         print "$host = ",dump($status);
127         $collected->{$host} = $status;
128 }
129
130 # generate json
131 my $json;
132 foreach my $ip ( sort keys %$collected ) {
133         my $status = $collected->{$ip};
134         $status->{ip} = $ip;    
135         push @$json, $status;
136 }
137 open(my $fh, '>', 'printer.json');
138 print $fh encode_json $json;