chomp serial number to remove LF which ZTE send
[perl-cwmp.git] / 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;