From: Andy Grundman Date: Tue, 18 Oct 2005 03:51:28 +0000 (+0000) Subject: Added a test for auto-restart feature X-Git-Tag: 5.7099_04~1200 X-Git-Url: http://git.shadowcat.co.uk/gitweb/gitweb.cgi?a=commitdiff_plain;h=94d71828a50209d915cd9170fbe4f9d5b3f1b597;p=catagits%2FCatalyst-Runtime.git Added a test for auto-restart feature --- diff --git a/t/optional/http-server-restart.t b/t/optional/http-server-restart.t new file mode 100644 index 0000000..da1b313 --- /dev/null +++ b/t/optional/http-server-restart.t @@ -0,0 +1,114 @@ +#!perl + +# This test tests the standalone server's auto-restart feature. + +use strict; +use warnings; + +use File::Path; +use FindBin; +use LWP::Simple; +use IO::Socket; +use Test::More; +use Time::HiRes qw/sleep/; +eval "use File::Copy::Recursive"; + +plan skip_all => 'set TEST_HTTP to enable this test' unless $ENV{TEST_HTTP}; +plan skip_all => 'File::Copy::Recursive required' if $@; + +plan tests => 40; + +# clean up +rmtree "$FindBin::Bin/../../t/var" if -d "$FindBin::Bin/../../t/var"; + +# create a TestApp and copy the test libs into it +mkdir "$FindBin::Bin/../../t/var"; +chdir "$FindBin::Bin/../../t/var"; +system "$FindBin::Bin/../../script/catalyst.pl TestApp"; +chdir "$FindBin::Bin/../.."; +File::Copy::Recursive::dircopy( 't/live/lib', 't/var/TestApp/lib' ); + +# spawn the standalone HTTP server +my $port = 30000 + int rand(1 + 10000); +my $pid = open my $server, + "$FindBin::Bin/../../t/var/TestApp/script/testapp_server.pl -port $port -restart 2>&1 |" + or die "Unable to spawn standalone HTTP server: $!"; + +# wait for it to start +print "Waiting for server to start...\n"; +while ( check_port( 'localhost', $port ) != 1 ) { + sleep 1; +} + +# change various files +my @files = ( + "$FindBin::Bin/../../t/var/TestApp/lib/TestApp.pm", + "$FindBin::Bin/../../t/var/TestApp/lib/TestApp/Controller/Action/Begin.pm", + "$FindBin::Bin/../../t/var/TestApp/lib/TestApp/Controller/Engine/Request/URI.pm", +); + +# change some files and make sure the server restarts itself +for ( 1..20 ) { + my $index = rand @files; + open my $pm, '>>', $files[$index] + or die "Unable to open $files[$index] for writing: $!"; + print $pm "\n"; + close $pm; + + # give the server time to notice the change and restart + my $count = 0; + sleep 1; + while ( check_port( 'localhost', $port ) != 1 ) { + # wait for it to restart + sleep 0.1; + die "Server appears to have died" if $count++ > 50; + } + my $response = get("http://localhost:$port/action/default"); + like( $response, qr/Catalyst::Request/, 'Request OK' ); + + #print $server->getline; +} + +# add errors to the file and make sure server does not die or restart +for ( 1..20 ) { + my $index = rand @files; + open my $pm, '>>', $files[$index] + or die "Unable to open $files[$index] for writing: $!"; + print $pm "bleh"; + close $pm; + + # give the server time to notice the change + my $count = 0; + sleep 1; + if ( check_port( 'localhost', $port ) != 1 ) { + die "Server appears to have died"; + } + my $response = get("http://localhost:$port/action/default"); + like( $response, qr/Catalyst::Request/, 'Request OK' ); + + #print $server->getline; +} + +# shut it down +kill 2, $pid; +close $server; + +# clean up +rmtree "$FindBin::Bin/../../t/var" if -d "$FindBin::Bin/../../t/var"; + +sub check_port { + my ( $host, $port ) = @_; + + my $remote = IO::Socket::INET->new( + Proto => "tcp", + PeerAddr => $host, + PeerPort => $port + ); + if ($remote) { + close $remote; + return 1; + } + else { + return 0; + } +}