trunk/t/30-server.t

#!/usr/bin/perl
use strict;
use warnings;

my $debug = shift @ARGV;

use Test::More tests => 19;
use Data::Dump qw/dump/;
use Cwd qw/abs_path/;
use blib;

BEGIN {
        use_ok('Net::HTTP');
        use_ok('CWMP::Server');
        use_ok('CWMP::Store');
}

my $port = 4242;

eval {
        $SIG{ALRM} = sub { die; };
        alarm 30;
};

ok(my $abs_path = abs_path($0), "abs_path");
$abs_path =~ s!/[^/]*$!/!;      #!fix-vim

my $store_path = "$abs_path/var/";
#my $store_module = 'DBMDeep';
my $store_module = 'YAML';

ok( my $server = CWMP::Server->new({
        debug => $debug,
        port => $port,
        store => {
                module => $store_module,
                path => $store_path,
                clean => 1,
        },
}), 'new' );
isa_ok( $server, 'CWMP::Server' );

my $pid;

if ( $pid = fork ) {
        ok( $pid, 'fork ');
        diag "forked $pid";
} elsif (defined($pid)) {
        # child
        $server->run;
        exit;
} else {
        die "can't fork";
}

sleep 1;        # so server can start

ok( my $s = Net::HTTP->new(Host => "localhost:$port"), 'client' );
$s->keep_alive( 1 );

ok( $s->write_request(
        POST => '/',
        'Transfer-Encoding' => 'chunked',
        'SOAPAction' => '',
        'Content-Type' => 'text/xml',
), 'write_request' );

foreach my $chunk (qq{

<soapenv:Envelope soapenv:encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:soap="http://schemas.xmlsoap.org/soap/encoding/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:cwmp="urn:dslforum-org:cwmp-1-0">
 <soapenv:Header>
<cwmp:ID soapenv:mustUnderstand="1">1_THOM_TR69_ID</cwmp:ID>
 </soapenv:Header>
 <soapenv:Body>
<cwmp:Inform>
<DeviceId>
 <Manufacturer>THOMSON</Manufacturer>
 <OUI>00147F</OUI>
 <ProductClass>SpeedTouch 780</ProductClass>
 <SerialNumber>CP0644JTHJ4</SerialNumber>
</DeviceId>
<Event soap:arrayType="cwmp:EventStruct[03]">
<EventStruct>
 <EventCode>0 BOOTSTRAP</EventCode>
 <CommandKey></CommandKey>
</EventStruct>
<EventStruct>
 <Event},qq{Code>1 BOOT</EventCode>
 <CommandKey></CommandKey>
</EventStruct>
<EventStruct>
 <EventCode>4 VALUE CHANGE</EventCode>
 <CommandKey></CommandKey>
</EventStruct>
</Event>
<MaxEnvelopes>2</MaxEnvelopes>
<CurrentTime>1970-01-01T00:04:33Z</CurrentTime>
<RetryCount>01</RetryCount>},qq{
<ParameterList soap:arrayType="cwmp:ParameterValueStruct[12]">
<ParameterValueStruct>
 <Name>InternetGatewayDevice.DeviceSummary</Name>
 <Value xsi:type="xsd:string">InternetGatewayDevice:1.1[] (Baseline:1, EthernetLAN:1, ADSLWAN:1, Bridging:1, Time:1, WiFiLAN:1)</Value>
</ParameterValueStruct>
<ParameterValueStruct>
 <Name>}, qq{
InternetGatewayDevice.DeviceInfo.SpecVersion</Name>
 <Value xsi:type="xsd:string">1.1</Value>
</ParameterValueStruct>
<ParameterValueStruct>
 <Name>InternetGatewayDevice.DeviceInfo.HardwareVersion</Name>
 <Value xsi:type="xsd:string">BANT-R</Value>
</ParameterValueStruct>
<ParameterValueStruct>
 <Name>InternetGatewayDevice.DeviceInfo.SoftwareVersion</Name>
 <Value xsi:type="xsd:string">6.2.15.5</Value>
</ParameterValueStruct>
<ParameterValueStruct>
 <Name>InternetGatewayDevice.DeviceInfo.ProvisioningCode</Name>
 <Value xsi:type="xsd:string"></Value>
</ParameterValueStruct>
<ParameterValueStruct>
 <Name>InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Name</Name>
 <Value xsi:type="xsd:string">Routed PPPoE on 0/35 and 8/35</Value>
</ParameterValueStruct>
<ParameterValueStruct>
 <Name>InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Version</Name>
 <Value xsi:type="xsd:string"></Value>
</ParameterValueStruct>
<ParameterValueStruct>
 <Name>InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Date</Name>
 <Value xsi:type="xsd:dateTime">0000-00-00T00:00:00</Value>
</ParameterValueStruct>
<ParameterValueStruct>
 <Name>InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Description</Name>
 <Value xsi:type="xsd:string">Factory Defaults</Value>
</ParameterValueStruct>
<ParameterValueStruct>
 <Name>InternetGatewayDevice.ManagementServer.ConnectionRequestURL</Name>
 <Value}, qq{ xsi:type="xsd:string">http://192.168.1.254:51005/</Value>
</ParameterValueStruct>
<ParameterValueStruct>
 <Name>InternetGatewayDevice.ManagementServer.ParameterKey</Name>
 <Value xsi:type="xsd:string"></Value>
</ParameterValueStruct>
<ParameterValueStruct>
 <Name>.ExternalIPAddress</Name>
 <Value xsi:type="xsd:string">192.168.1.254</Value>
</ParameterValueStruct>
</ParameterList>
</cwmp:Inform>
 </soapenv:Body>
</soapenv:Envelope>
} ) {
        ok( $s->write_chunk( $chunk ), "chunk " . length($chunk) . " bytes" );
}
ok( $s->write_chunk_eof, 'write_chunk_eof' );

sleep 1;

ok( my $store = CWMP::Store->new({ module => $store_module, path => $store_path, debug => $debug }), 'another store' );

my $state = {
  CurrentTime    => "1970-01-01T00:04:33Z",
  DeviceID       => {
                      Manufacturer => "THOMSON",
                      OUI => "00147F",
                      ProductClass => "SpeedTouch 780",
                      SerialNumber => "CP0644JTHJ4",
                    },
  EventStruct    => ["0 BOOTSTRAP", "1 BOOT", "4 VALUE CHANGE"],
  ID             => "1_THOM_TR69_ID",
  MaxEnvelopes   => 2,
#  NoMoreRequests => undef,
  Parameter      => {
                      "\nInternetGatewayDevice.DeviceInfo.SpecVersion"                  => "1.1",
                      ".ExternalIPAddress"                                              => "192.168.1.254",
                      "InternetGatewayDevice.DeviceInfo.HardwareVersion"                => "BANT-R",
                      "InternetGatewayDevice.DeviceInfo.ProvisioningCode"               => undef,
                      "InternetGatewayDevice.DeviceInfo.SoftwareVersion"                => "6.2.15.5",
                      "InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Date"        => "0000-00-00T00:00:00",
                      "InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Description" => "Factory Defaults",
                      "InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Name"        => "Routed PPPoE on 0/35 and 8/35",
                      "InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Version"     => undef,
                      "InternetGatewayDevice.DeviceSummary"                             => "InternetGatewayDevice:1.1[] (Baseline:1, EthernetLAN:1, ADSLWAN:1, Bridging:1, Time:1, WiFiLAN:1)",
                      "InternetGatewayDevice.ManagementServer.ConnectionRequestURL"     => "http://192.168.1.254:51005/",
                      "InternetGatewayDevice.ManagementServer.ParameterKey"             => undef,
                    },
  RetryCount     => "01",
  _dispatch      => "InformResponse",
};

is_deeply( $store->current_store->get_state( 'CP0644JTHJ4' ), $state, 'store->current_store->get_state' );

diag "shutdown server";

ok( kill(9,$pid), 'kill ' . $pid );

ok( waitpid($pid,0), 'waitpid' );
1	dpavlin	41	#!/usr/bin/perl
2			use strict;
3			use warnings;
4
5			my $debug = shift @ARGV;
6
7	dpavlin	85	use Test::More tests => 19;
8	dpavlin	41	use Data::Dump qw/dump/;
9	dpavlin	77	use Cwd qw/abs_path/;
10	dpavlin	41	use blib;
11
12			BEGIN {
13			use_ok('Net::HTTP');
14			use_ok('CWMP::Server');
15	dpavlin	85	use_ok('CWMP::Store');
16	dpavlin	41	}
17
18			my $port = 4242;
19
20			eval {
21			$SIG{ALRM} = sub { die; };
22			alarm 30;
23			};
24
25	dpavlin	77	ok(my $abs_path = abs_path($0), "abs_path");
26			$abs_path =~ s!/[^/]*$!/!; #!fix-vim
27
28	dpavlin	163	my $store_path = "$abs_path/var/";
29			#my $store_module = 'DBMDeep';
30			my $store_module = 'YAML';
31	dpavlin	84
32	dpavlin	77	ok( my $server = CWMP::Server->new({
33			debug => $debug,
34			port => $port,
35	dpavlin	163	store => {
36			module => $store_module,
37			path => $store_path,
38			clean => 1,
39			},
40	dpavlin	77	}), 'new' );
41	dpavlin	41	isa_ok( $server, 'CWMP::Server' );
42
43			my $pid;
44
45			if ( $pid = fork ) {
46			ok( $pid, 'fork ');
47			diag "forked $pid";
48			} elsif (defined($pid)) {
49			# child
50			$server->run;
51			exit;
52			} else {
53			die "can't fork";
54			}
55
56	dpavlin	84	sleep 1; # so server can start
57
58	dpavlin	41	ok( my $s = Net::HTTP->new(Host => "localhost:$port"), 'client' );
59	dpavlin	42	$s->keep_alive( 1 );
60	dpavlin	41
61			ok( $s->write_request(
62			POST => '/',
63			'Transfer-Encoding' => 'chunked',
64			'SOAPAction' => '',
65			'Content-Type' => 'text/xml',
66			), 'write_request' );
67
68			foreach my $chunk (qq{
69
70			<soapenv:Envelope soapenv:encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:soap="http://schemas.xmlsoap.org/soap/encoding/" xmlns:xsd="http://www.w3.org/2001/XMLSchema" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:cwmp="urn:dslforum-org:cwmp-1-0">
71			<soapenv:Header>
72			<cwmp:ID soapenv:mustUnderstand="1">1_THOM_TR69_ID</cwmp:ID>
73			</soapenv:Header>
74			<soapenv:Body>
75			<cwmp:Inform>
76			<DeviceId>
77			<Manufacturer>THOMSON</Manufacturer>
78			<OUI>00147F</OUI>
79			<ProductClass>SpeedTouch 780</ProductClass>
80			<SerialNumber>CP0644JTHJ4</SerialNumber>
81			</DeviceId>
82			<Event soap:arrayType="cwmp:EventStruct[03]">
83			<EventStruct>
84			<EventCode>0 BOOTSTRAP</EventCode>
85			<CommandKey></CommandKey>
86			</EventStruct>
87			<EventStruct>
88			<Event},qq{Code>1 BOOT</EventCode>
89			<CommandKey></CommandKey>
90			</EventStruct>
91			<EventStruct>
92			<EventCode>4 VALUE CHANGE</EventCode>
93			<CommandKey></CommandKey>
94			</EventStruct>
95			</Event>
96			<MaxEnvelopes>2</MaxEnvelopes>
97			<CurrentTime>1970-01-01T00:04:33Z</CurrentTime>
98			<RetryCount>01</RetryCount>},qq{
99			<ParameterList soap:arrayType="cwmp:ParameterValueStruct[12]">
100			<ParameterValueStruct>
101			<Name>InternetGatewayDevice.DeviceSummary</Name>
102			<Value xsi:type="xsd:string">InternetGatewayDevice:1.1[] (Baseline:1, EthernetLAN:1, ADSLWAN:1, Bridging:1, Time:1, WiFiLAN:1)</Value>
103			</ParameterValueStruct>
104			<ParameterValueStruct>
105			<Name>}, qq{
106			InternetGatewayDevice.DeviceInfo.SpecVersion</Name>
107			<Value xsi:type="xsd:string">1.1</Value>
108			</ParameterValueStruct>
109			<ParameterValueStruct>
110			<Name>InternetGatewayDevice.DeviceInfo.HardwareVersion</Name>
111			<Value xsi:type="xsd:string">BANT-R</Value>
112			</ParameterValueStruct>
113			<ParameterValueStruct>
114			<Name>InternetGatewayDevice.DeviceInfo.SoftwareVersion</Name>
115			<Value xsi:type="xsd:string">6.2.15.5</Value>
116			</ParameterValueStruct>
117			<ParameterValueStruct>
118			<Name>InternetGatewayDevice.DeviceInfo.ProvisioningCode</Name>
119			<Value xsi:type="xsd:string"></Value>
120			</ParameterValueStruct>
121			<ParameterValueStruct>
122			<Name>InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Name</Name>
123			<Value xsi:type="xsd:string">Routed PPPoE on 0/35 and 8/35</Value>
124			</ParameterValueStruct>
125			<ParameterValueStruct>
126			<Name>InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Version</Name>
127			<Value xsi:type="xsd:string"></Value>
128			</ParameterValueStruct>
129			<ParameterValueStruct>
130			<Name>InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Date</Name>
131			<Value xsi:type="xsd:dateTime">0000-00-00T00:00:00</Value>
132			</ParameterValueStruct>
133			<ParameterValueStruct>
134			<Name>InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Description</Name>
135			<Value xsi:type="xsd:string">Factory Defaults</Value>
136			</ParameterValueStruct>
137			<ParameterValueStruct>
138			<Name>InternetGatewayDevice.ManagementServer.ConnectionRequestURL</Name>
139			<Value}, qq{ xsi:type="xsd:string">http://192.168.1.254:51005/</Value>
140			</ParameterValueStruct>
141			<ParameterValueStruct>
142			<Name>InternetGatewayDevice.ManagementServer.ParameterKey</Name>
143			<Value xsi:type="xsd:string"></Value>
144			</ParameterValueStruct>
145			<ParameterValueStruct>
146			<Name>.ExternalIPAddress</Name>
147			<Value xsi:type="xsd:string">192.168.1.254</Value>
148			</ParameterValueStruct>
149			</ParameterList>
150			</cwmp:Inform>
151			</soapenv:Body>
152			</soapenv:Envelope>
153			} ) {
154			ok( $s->write_chunk( $chunk ), "chunk " . length($chunk) . " bytes" );
155			}
156			ok( $s->write_chunk_eof, 'write_chunk_eof' );
157
158	dpavlin	84	sleep 1;
159	dpavlin	41
160	dpavlin	163	ok( my $store = CWMP::Store->new({ module => $store_module, path => $store_path, debug => $debug }), 'another store' );
161	dpavlin	85
162			my $state = {
163			CurrentTime => "1970-01-01T00:04:33Z",
164			DeviceID => {
165			Manufacturer => "THOMSON",
166			OUI => "00147F",
167			ProductClass => "SpeedTouch 780",
168			SerialNumber => "CP0644JTHJ4",
169			},
170			EventStruct => ["0 BOOTSTRAP", "1 BOOT", "4 VALUE CHANGE"],
171			ID => "1_THOM_TR69_ID",
172			MaxEnvelopes => 2,
173	dpavlin	175	# NoMoreRequests => undef,
174	dpavlin	85	Parameter => {
175			"\nInternetGatewayDevice.DeviceInfo.SpecVersion" => "1.1",
176			".ExternalIPAddress" => "192.168.1.254",
177			"InternetGatewayDevice.DeviceInfo.HardwareVersion" => "BANT-R",
178			"InternetGatewayDevice.DeviceInfo.ProvisioningCode" => undef,
179			"InternetGatewayDevice.DeviceInfo.SoftwareVersion" => "6.2.15.5",
180			"InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Date" => "0000-00-00T00:00:00",
181			"InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Description" => "Factory Defaults",
182			"InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Name" => "Routed PPPoE on 0/35 and 8/35",
183			"InternetGatewayDevice.DeviceInfo.VendorConfigFile.1.Version" => undef,
184			"InternetGatewayDevice.DeviceSummary" => "InternetGatewayDevice:1.1[] (Baseline:1, EthernetLAN:1, ADSLWAN:1, Bridging:1, Time:1, WiFiLAN:1)",
185			"InternetGatewayDevice.ManagementServer.ConnectionRequestURL" => "http://192.168.1.254:51005/",
186			"InternetGatewayDevice.ManagementServer.ParameterKey" => undef,
187			},
188			RetryCount => "01",
189			_dispatch => "InformResponse",
190			};
191
192	dpavlin	175	is_deeply( $store->current_store->get_state( 'CP0644JTHJ4' ), $state, 'store->current_store->get_state' );
193	dpavlin	85
194	dpavlin	197	diag "shutdown server";
195
196	dpavlin	84	ok( kill(9,$pid), 'kill ' . $pid );
197
198	dpavlin	41	ok( waitpid($pid,0), 'waitpid' );