lib/CWMP/Vendor.pm

   1 package CWMP::Vendor;
   2
   3 use strict;
   4 use warnings;
   5
   6
   7 use base qw/Class::Accessor/;
   8 __PACKAGE__->mk_accessors( qw/
   9 debug
  10 / );
  11
  12 #use Carp qw/confess/;
  13 use Data::Dump qw/dump/;
  14
  15 =head1 NAME
  16
  17 CWMP::Vendor - implement vendor specific logic into ACS server
  18
  19 =head1 METHODS
  20
  21 =head2 new
  22
  23   my $obj = CWMP::Vendor->new({
  24         debug => 1
  25   });
  26
  27 =cut
  28
  29 my $debug = 0;
  30
  31 sub new {
  32         my $class = shift;
  33         my $self = $class->SUPER::new( @_ );
  34
  35         warn "created ", __PACKAGE__, "(", dump( @_ ), ") object\n" if $self->debug;
  36
  37         $debug = $self->debug;
  38
  39         return $self;
  40 }
  41
  42 our $cpe_faulty;
  43
  44 my $serial2ip = {
  45         'CP0636JT3SH' => '10.0.0.1',
  46         'CP0644JTHJ4' => '10.0.0.2',
  47         'CP0624BH55U' => '10.0.0.3',
  48 };
  49
  50 my ( $last_ip, $last_serial );
  51
  52 =head2 state2serial
  53
  54   my $serial = state2serial( $state );
  55
  56 =cut
  57
  58 sub state2serial {
  59         my $state = shift;
  60
  61         my $serial = $state->{DeviceID}->{SerialNumber} || die "no DeviceID.SerialNumber in ",dump($state);
  62         chomp($serial);
  63         my $ip =
  64                 $state->{Parameter}->{'.ExternalIPAddress'} ||
  65                 $state->{Parameter}->{
  66                         # fix for firmware 5.3.3.4 which returns full path
  67                         ( grep { m/\.ExternalIPAddress/ } keys %{ $state->{Parameter} } )[0]
  68                 } ||
  69                 die "no .ExternalIPAddress in ",dump($state);
  70
  71         warn "## state2serial $serial $ip\n" if $debug;
  72
  73         ( $last_ip, $last_serial ) = ( $ip, $serial );
  74
  75         return ( $serial, $ip );
  76 }
  77
  78 =head2 add_triggers
  79
  80 Install all custom triggers
  81
  82   CWMP::Vendor->add_triggers;
  83
  84 =cut
  85
  86 sub add_triggers {
  87
  88         warn __PACKAGE__, "->add_triggers\n" if $debug;
  89
  90 CWMP::Request->add_trigger( name => 'Fault', callback => sub {
  91         my ( $self, $state ) = @_;
  92         warn "## Fault trigger state = ",dump( $self, $state ) if $debug;
  93         die "can't map fault to serial!" unless $last_serial;
  94         warn "ERROR: got Fault and ingoring $last_ip $last_serial\n";
  95         $cpe_faulty->{$last_serial}++;
  96 });
  97
  98 CWMP::Request->add_trigger( name => 'Inform', callback => sub {
  99         my ( $self, $state ) = @_;
 100
 101         my ( $serial, $ip ) = state2serial( $state );
 102
 103         if ( $cpe_faulty->{$serial} ) {
 104                 warn "## Inform trigger from $ip $serial -- IGNORED\n" if $debug;
 105                 return;
 106         }
 107
 108         warn "## Inform trigger from $ip $serial\n" if $debug;
 109
 110         my $found = 0;
 111
 112         warn "### serial2ip = ",dump( $serial2ip ) if $debug;
 113
 114         foreach my $target_serial ( keys %$serial2ip ) {
 115
 116                 next unless $target_serial eq $serial;
 117
 118                 $found++;
 119
 120                 my $target_ip = $serial2ip->{$target_serial};
 121
 122                 if ( $ip ne $target_ip ) {
 123
 124                         warn "CHANGE IP $ip to $target_ip for $serial\n";
 125
 126                         return; # FIXME
 127
 128                         my $q = CWMP::Queue->new({ id => $serial, debug => $debug }) || die "no queue?";
 129
 130                         $q->enqueue( 'SetParameterValues', {
 131                                 'InternetGatewayDevice.LANDevice.1.LANHostConfigManagement.IPInterface.1.IPInterfaceIPAddress' => $target_ip,
 132                         });
 133
 134                 } else {
 135                         warn "IP $ip of $serial ok\n";
 136                 }
 137         }
 138
 139         warn "UNKNOWN CPE $ip $serial\nadd\t'$serial' => '$ip',\n" unless $found;
 140
 141 });
 142
 143 }#add_triggers
 144
 145 1;