X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=t%2Fhttpd-corner.psgi;h=ea643024db5032ab006514b1927736f76479b5c0;hb=65db62eb006fdbe74348f0e8f2ef9b9e938cb90b;hp=5628f4abd5c92002abc48bd971a35f88454ab59a;hpb=9bd675d33ad1e49bd2ebe12a1d216216e61380de;p=public-inbox.git diff --git a/t/httpd-corner.psgi b/t/httpd-corner.psgi index 5628f4ab..ea643024 100644 --- a/t/httpd-corner.psgi +++ b/t/httpd-corner.psgi @@ -1,11 +1,25 @@ -# Copyright (C) 2016-2019 all contributors +# Copyright (C) all contributors # License: AGPL-3.0+ # corner case tests for the generic PSGI server # Usage: plackup [OPTIONS] /path/to/this/file -use strict; -use warnings; +use v5.12; use Plack::Builder; require Digest::SHA; +if (defined(my $f = $ENV{TEST_OPEN_FIFO})) { + open my $fh, '>', $f or die "open($f): $!"; + say $fh 'hi'; + close $fh; +} + +END { + if (defined(my $f = $ENV{TEST_EXIT_FIFO})) { + open my $fh, '>', $f or die "open($f): $!"; + say $fh "bye from $$"; + close $fh; + } +} + +my $pi_config = $ENV{PI_CONFIG} // 'unset'; # capture ASAP my $app = sub { my ($env) = @_; my $path = $env->{PATH_INFO}; @@ -48,7 +62,7 @@ my $app = sub { } } elsif ($path eq '/host-port') { $code = 200; - push @$body, "$env->{REMOTE_ADDR}:$env->{REMOTE_PORT}"; + push @$body, "$env->{REMOTE_ADDR} $env->{REMOTE_PORT}"; } elsif ($path eq '/callback') { return sub { my ($res) = @_; @@ -85,8 +99,43 @@ my $app = sub { close $null; [ 200, [ qw(Content-Type application/octet-stream) ]]; }); + } elsif ($path eq '/psgi-return-gzip') { + require PublicInbox::Qspawn; + require PublicInbox::GzipFilter; + my $cmd = [qw(echo hello world)]; + my $qsp = PublicInbox::Qspawn->new($cmd); + $env->{'qspawn.filter'} = PublicInbox::GzipFilter->new; + return $qsp->psgi_return($env, undef, sub { + [ 200, [ qw(Content-Type application/octet-stream)]] + }); + } elsif ($path eq '/psgi-return-compressible') { + require PublicInbox::Qspawn; + my $cmd = [qw(echo goodbye world)]; + my $qsp = PublicInbox::Qspawn->new($cmd); + return $qsp->psgi_return($env, undef, sub { + [200, [qw(Content-Type text/plain)]] + }); + } elsif ($path eq '/psgi-return-enoent') { + require PublicInbox::Qspawn; + my $cmd = [ 'this-better-not-exist-in-PATH'.rand ]; + my $qsp = PublicInbox::Qspawn->new($cmd); + return $qsp->psgi_return($env, undef, sub { + [ 200, [ qw(Content-Type application/octet-stream)]] + }); + } elsif ($path eq '/pid') { + $code = 200; + push @$body, "$$\n"; + } elsif ($path eq '/url_scheme') { + $code = 200; + push @$body, $env->{'psgi.url_scheme'} + } elsif ($path eq '/PI_CONFIG') { + $code = 200; + push @$body, $pi_config; # show value at ->refresh_groups + } elsif ($path =~ m!\A/exit-fifo(.+)\z!) { + $code = 200; + $ENV{TEST_EXIT_FIFO} = $1; # for END {} + push @$body, "fifo $1 registered"; } - [ $code, $h, $body ] };