lib/APKPM/Davolink.pm

   1 package APKPM::Davolink;
   2
   3 use base qw(Gearman::Driver::Worker);
   4 use Moose;
   5 use Time::HiRes;
   6 use Data::Dump qw(dump);
   7
   8 with 'APKPM::Config';
   9 with 'APKPM::Gearman::Client';
  10 with 'APKPM::Gearman';
  11
  12 use lib '/opt/managment_tools/lib';
  13 use H1::Davolink;
  14
  15 sub prefix { 'Davolink_' }
  16
  17 sub info : Job : MinProcesses(1) : MaxProcesses(5) : Decode(d_array) : Encode(e_json) {
  18         my ( $self, $job, $workload ) = @_;
  19         warn "# workload = ", dump $workload;
  20         my $cpeip = shift @$workload;
  21         my $cpeconnect=H1::Davolink->new($cpeip,$self->config('iadusername'),$self->config('iadpasswd'));
  22         $cpeconnect->connect();
  23         my $ret = { ip => $cpeip };
  24         foreach my $param ( @$workload ) {
  25                 if ( $param =~ m/uptime/i ) {
  26                         $ret->{UPTIME} = $cpeconnect->custom("cat /proc/uptime");
  27                 } elsif ( $param =~ m/adsl/i ) {
  28                         $ret->{ADSL} = { $cpeconnect->adsl_info };
  29                         $self->do_background_json( 'Store_ADSL', $ret );
  30                 } elsif ( $param =~ m/wan/i ) {
  31                         $ret->{WAN} = [ $cpeconnect->wan_info ];
  32                 } elsif ( $param =~ m/route/i ) {
  33                         $ret->{ROUTES} = [ $cpeconnect->route_info ];
  34                 } else {
  35                         die "unknown param $param";
  36                 }
  37         };
  38         return $ret;
  39 }
  40
  41 1;