trunk/t/30-server.t

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

my $debug = shift @ARGV;

use Test::More tests => 20;
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,
        session => {
                store => {
                        module => $store_module,
                        path => $store_path,
                        clean => 1,
                },
                create_dump => 0,
        }
}), '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",
};

ok( my $store_state = $store->current_store->get_state( 'CP0644JTHJ4' ), 'get_state' );

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

diag "shutdown server";

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

ok( waitpid($pid,0), 'waitpid' );

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