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 my $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 serial?";
  62         my $ip = $state->{Parameter}->{'.ExternalIPAddress'} || die "no ip?";
  63
  64         warn "## state2serial $serial $ip\n" if $debug;
  65
  66         ( $last_ip, $last_serial ) = ( $ip, $serial );
  67
  68         return ( $serial, $ip );
  69 }
  70
  71 =head2 add_triggers
  72
  73 Install all custom triggers
  74
  75   CWMP::Vendor->add_triggers;
  76
  77 =cut
  78
  79 sub add_triggers {
  80
  81         warn __PACKAGE__, "->add_triggers\n" if $debug;
  82
  83 CWMP::Request->add_trigger( name => 'Fault', callback => sub {
  84         my ( $self, $state ) = @_;
  85         warn "## Fault trigger state = ",dump( $self, $state ) if $debug;
  86         die "can't map fault to serial!" unless $last_serial;
  87         warn "ERROR: got Fault and ingoring $last_ip $last_serial\n";
  88         $cpe_faulty->{$last_serial}++;
  89 });
  90
  91 CWMP::Request->add_trigger( name => 'Inform', callback => sub {
  92         my ( $self, $state ) = @_;
  93
  94         my ( $serial, $ip ) = state2serial( $state );
  95
  96         if ( $cpe_faulty->{$serial} ) {
  97                 warn "## Inform trigger from $ip $serial -- IGNORED\n" if $debug;
  98                 return;
  99         }
 100
 101         warn "## Inform trigger from $ip $serial\n" if $debug;
 102
 103         my $found = 0;
 104
 105         warn "### serial2ip = ",dump( $serial2ip ) if $debug;
 106
 107         foreach my $target_serial ( keys %$serial2ip ) {
 108
 109                 next unless $target_serial eq $serial;
 110
 111                 $found++;
 112
 113                 my $target_ip = $serial2ip->{$target_serial};
 114
 115                 if ( $ip ne $target_ip ) {
 116
 117                         warn "CHANGE IP $ip to $target_ip for $serial\n";
 118
 119                         return; # FIXME
 120
 121                         my $q = CWMP::Queue->new({ id => $serial, debug => $debug }) || die "no queue?";
 122
 123                         $q->enqueue( 'SetParameterValues', {
 124                                 'InternetGatewayDevice.LANDevice.1.LANHostConfigManagement.IPInterface.1.IPInterfaceIPAddress' => $target_ip,
 125                         });
 126
 127                 } else {
 128                         warn "IP $ip of $serial ok\n";
 129                 }
 130         }
 131
 132         warn "UNKNOWN CPE $ip $serial\nadd\t'$serial' => '$ip',\n" unless $found;
 133
 134 });
 135
 136 }#add_triggers
 137
 138 1;