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 JSON::XS;
   7 use Data::Dump qw(dump);
   8
   9 with 'APKPM::Config';
  10 with 'APKPM::Gearman::Client';
  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 : Encode {
  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 sub decode {
  42         my ( $self, $result ) = @_;
  43         warn "# decode ", dump($result);
  44         return [ split(/\s+/,$result) ];
  45 }
  46
  47 sub encode {
  48         my ( $self, $result ) = @_;
  49         warn "# encode ",dump $result;
  50         return JSON::XS::encode_json($result);
  51 }
  52
  53 1;