r218@brr: dpavlin | 2007-11-14 22:54:48 +0100

[perl-cwmp.git] / lib / CWMP / Vendor.pm

diff --git a/lib/CWMP/Vendor.pm b/lib/CWMP/Vendor.pm
new file mode 100644 (file)
index 0000000..2cf6a01
--- /dev/null
+++ b/lib/CWMP/Vendor.pm
@@ -0,0 +1,123 @@
+package CWMP::Vendor;
+
+use strict;
+use warnings;
+
+
+use base qw/Class::Accessor/;
+__PACKAGE__->mk_accessors( qw/
+debug
+/ );
+
+#use Carp qw/confess/;
+use Data::Dump qw/dump/;
+
+=head1 NAME
+
+CWMP::Vendor - implement vendor specific logic into ACS server
+
+=head1 METHODS
+
+=head2 new
+
+  my $obj = CWMP::Vendor->new({
+       debug => 1
+  });
+
+=cut
+
+my $debug = 0;
+
+sub new {
+       my $class = shift;
+       my $self = $class->SUPER::new( @_ );
+
+       warn "created ", __PACKAGE__, "(", dump( @_ ), ") object\n" if $self->debug;
+
+       $debug = $self->debug;
+
+       return $self;
+}
+
+my $cpe_faulty;
+
+my $serial2ip = {
+       'CP0636JT3SH' => '192.168.1.242',
+       'CP0644JTHJ4' => '192.168.1.253',
+};
+
+my ( $last_ip, $last_serial );
+
+sub state2serial {
+       my $state = shift;
+
+       my $serial = $state->{DeviceID}->{SerialNumber} || die "no serial?";
+       my $ip = $state->{Parameter}->{'.ExternalIPAddress'} || die "no ip?";
+
+       warn "## state2serial $serial $ip\n";
+
+       ( $last_ip, $last_serial ) = ( $ip, $serial );
+
+       return ( $serial, $ip );
+}
+
+sub add_triggers {
+
+       warn __PACKAGE__, "->add_triggers\n";
+
+CWMP::Request->add_trigger( name => 'Fault', callback => sub {
+       my ( $self, $state ) = @_;
+       warn "## Fault trigger state = ",dump( $self, $state );
+       die "can't map fault to serial!" unless $last_serial;
+       warn "ERROR: got Fault and ingoring $last_ip $last_serial\n";
+       $cpe_faulty->{$last_serial}++;
+});
+
+CWMP::Request->add_trigger( name => 'Inform', callback => sub {
+       my ( $self, $state ) = @_;
+
+       my ( $serial, $ip ) = state2serial( $state );
+
+       if ( $cpe_faulty->{$serial} ) {
+               warn "## Inform trigger from $ip $serial -- IGNORED\n"; # if $debug;
+               return;
+       }
+
+       warn "## Inform trigger from $ip $serial\n"; # if $debug;
+
+       my $found = 0;
+
+       warn "### serial2ip = ",dump( $serial2ip );
+
+       foreach my $target_serial ( keys %$serial2ip ) {
+
+               next unless $target_serial eq $serial;
+
+               $found++;
+
+               my $target_ip = $serial2ip->{$target_serial};
+
+               if ( $ip ne $target_ip ) {
+
+                       warn "CHANGE IP $ip to $target_ip for $serial\n";
+
+                       return; # FIXME
+
+                       my $q = CWMP::Queue->new({ id => $serial, debug => $debug }) || die "no queue?";
+
+                       $q->enqueue( 'SetParameterValues', {
+                               'InternetGatewayDevice.LANDevice.1.LANHostConfigManagement.IPInterface.1.IPInterfaceIPAddress' => $target_ip,
+                       });
+
+               } else {
+                       warn "IP $ip of $serial ok\n";
+               }
+       }
+
+       warn "UNKNOWN CPE $ip $serial\nadd\t'$serial' => '$ip',\n" unless $found;
+
+});
+
+}#add_triggers
+
+1;