| #!/usr/bin/perl | |
| # (C) Maxim Dounin | |
| # Test for scgi backend. | |
| ############################################################################### | |
| use warnings; | |
| use strict; | |
| use Test::More; | |
| BEGIN { use FindBin; chdir($FindBin::Bin); } | |
| use lib 'lib'; | |
| use Test::Nginx; | |
| ############################################################################### | |
| select STDERR; $| = 1; | |
| select STDOUT; $| = 1; | |
| eval { require SCGI; }; | |
| plan(skip_all => 'SCGI not installed') if $@; | |
| my $t = Test::Nginx->new()->has(qw/http scgi/)->plan(7) | |
| ->write_file_expand('nginx.conf', <<'EOF'); | |
| %%TEST_GLOBALS%% | |
| daemon off; | |
| events { | |
| } | |
| http { | |
| %%TEST_GLOBALS_HTTP%% | |
| upstream u { | |
| server 127.0.0.1:8081; | |
| } | |
| server { | |
| listen 127.0.0.1:8080; | |
| server_name localhost; | |
| location / { | |
| scgi_pass 127.0.0.1:8081; | |
| scgi_param SCGI 1; | |
| scgi_param REQUEST_URI $request_uri; | |
| scgi_param HTTP_X_BLAH "blah"; | |
| } | |
| location /var { | |
| scgi_pass $arg_b; | |
| scgi_param SCGI 1; | |
| scgi_param REQUEST_URI $request_uri; | |
| } | |
| } | |
| } | |
| EOF | |
| $t->run_daemon(\&scgi_daemon); | |
| $t->run()->waitforsocket('127.0.0.1:' . port(8081)); | |
| ############################################################################### | |
| like(http_get('/'), qr/SEE-THIS/, 'scgi request'); | |
| like(http_get('/redir'), qr/ 302 /, 'scgi redirect'); | |
| like(http_get('/'), qr/^3$/m, 'scgi third request'); | |
| unlike(http_head('/'), qr/SEE-THIS/, 'no data in HEAD'); | |
| like(http_get_headers('/headers'), qr/SEE-THIS/, | |
| 'scgi request with many ignored headers'); | |
| like(http_get('/var?b=127.0.0.1:' . port(8081)), qr/SEE-THIS/, | |
| 'scgi with variables'); | |
| like(http_get('/var?b=u'), qr/SEE-THIS/, 'scgi with variables to upstream'); | |
| ############################################################################### | |
| sub http_get_headers { | |
| my ($url, %extra) = @_; | |
| return http(<<EOF, %extra); | |
| GET $url HTTP/1.0 | |
| Host: localhost | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| X-Blah: ignored header | |
| EOF | |
| } | |
| ############################################################################### | |
| sub scgi_daemon { | |
| my $server = IO::Socket::INET->new( | |
| Proto => 'tcp', | |
| LocalHost => '127.0.0.1:' . port(8081), | |
| Listen => 5, | |
| Reuse => 1 | |
| ) | |
| or die "Can't create listening socket: $!\n"; | |
| my $scgi = SCGI->new($server, blocking => 1); | |
| my $count = 0; | |
| while (my $request = $scgi->accept()) { | |
| eval { $request->read_env(); }; | |
| next if $@; | |
| $count++; | |
| $request->connection()->print(<<EOF); | |
| Location: http://localhost/redirect | |
| Content-Type: text/html | |
| SEE-THIS | |
| $count | |
| EOF | |
| } | |
| } | |
| ############################################################################### |