-# Copyright (C) 2016 all contributors <meta@public-inbox.org>
+# Copyright (C) 2016-2018 all contributors <meta@public-inbox.org>
# License: AGPL-3.0+ <https://www.gnu.org/licenses/agpl-3.0.txt>
# corner case tests for the generic PSGI server
# Usage: plackup [OPTIONS] /path/to/this/file
use strict;
use warnings;
-use Plack::Request;
use Plack::Builder;
require Digest::SHA;
my $app = sub {
}
$code = 200;
push @$body, $sha1->hexdigest;
+ } elsif (my $fifo = $env->{HTTP_X_CHECK_FIFO}) {
+ if ($path eq '/slow-header') {
+ return sub {
+ open my $f, '<', $fifo or
+ die "open $fifo: $!\n";
+ local $/ = "\n";
+ my @r = <$f>;
+ $_[0]->([200, $h, \@r ]);
+ };
+ } elsif ($path eq '/slow-body') {
+ return sub {
+ my $fh = $_[0]->([200, $h]);
+ open my $f, '<', $fifo or
+ die "open $fifo: $!\n";
+ local $/ = "\n";
+ while (defined(my $l = <$f>)) {
+ $fh->write($l);
+ }
+ $fh->close;
+ };
+ }
+ } elsif ($path eq '/host-port') {
+ $code = 200;
+ push @$body, "$env->{REMOTE_ADDR}:$env->{REMOTE_PORT}";
+ } elsif ($path eq '/callback') {
+ return sub {
+ my ($res) = @_;
+ my $buf = "hello world\n";
+ push @$h, 'Content-Length', length($buf);
+ my $fh = $res->([200, $h]);
+ $fh->write($buf);
+ $fh->close;
+ }
+ } elsif ($path eq '/empty') {
+ $code = 200;
+ } elsif ($path eq '/getline-die') {
+ $code = 200;
+ $body = Plack::Util::inline_object(
+ getline => sub { die 'GETLINE FAIL' },
+ close => sub { die 'CLOSE FAIL' },
+ );
+ } elsif ($path eq '/close-die') {
+ $code = 200;
+ $body = Plack::Util::inline_object(
+ getline => sub { undef },
+ close => sub { die 'CLOSE FAIL' },
+ );
}
+
[ $code, $h, $body ]
};