view release on metacpan or  search on metacpan

t/app/Plack/Loader/Shotgun.t  view on Meta::CPAN

use strict;
use warnings;
use Test::More;
use Compiler::Lexer;
use Compiler::Parser;
use Compiler::Parser::AST::Renderer;
use Test::Compiler::Parser;

subtest 'parse Plack/Loader/Shotgun.pm' => sub {
    my $script = do { local $/; <DATA> };
    my $tokens = Compiler::Lexer->new('')->tokenize($script);
    my $ast = Compiler::Parser->new->parse($tokens);
    Compiler::Parser::AST::Renderer->new->render($ast);
    node_ok($ast->root, [
        Test::Compiler::Parser::package { 'Plack::Loader::Shotgun',
        },
        module { 'strict',
        },
        module { 'parent',
            args => reg_prefix { 'qw',
                expr => leaf 'Plack::Loader',
            },
        },
        module { 'Storable',
        },
        module { 'Try::Tiny',
        },
        module { 'Plack::Middleware::BufferedStreaming',
        },
        function { 'preload_app',
            body => [
                branch { '=',
                    left => list { '()',
                        data => branch { ',',
                            left => leaf '$self',
                            right => leaf '$builder',
                        },
                    },
                    right => leaf '@_',
                },
                branch { '=',
                    left => branch { '->',
                        left => leaf '$self',
                        right => hash_ref { '{}',
                            data => leaf 'builder',
                        },
                    },
                    right => function { 'sub',
                        body => branch { '->',
                            left => leaf 'Plack::Middleware::BufferedStreaming',
                            right => function_call { 'wrap',
                                args => [
                                    branch { '->',
                                        left => leaf '$builder',
                                        right => list { '()',
                                        },
                                    },
                                ],
                            },
                        },
                    },
                },
            ],
        },
        function { 'run',
            body => [
                branch { '=',
                    left => list { '()',
                        data => branch { ',',
                            left => leaf '$self',
                            right => leaf '$server',
                        },
                    },
                    right => leaf '@_',
                },
                branch { '=',
                    left => leaf '$app',
                    right => function { 'sub',
                        body => [
                            branch { '=',
                                left => leaf '$env',
                                right => function_call { 'shift',
                                    args => [
                                    ],
                                },
                            },

t/app/Plack/Loader/Shotgun.t  view on Meta::CPAN

                                                                            data => leaf 'Internal Server Error',
                                                                        },
                                                                    },
                                                                },
                                                            },
                                                        ],
                                                    ],
                                                },
                                            ],
                                        },
                                        function_call { 'print',
                                            args => [
                                                branch { '->',
                                                    left => hash_ref { '{}',
                                                        data => leaf '$write',
                                                    },
                                                    right => function_call { 'Storable::freeze',
                                                        args => [
                                                            leaf '$res',
                                                        ],
                                                    },
                                                },
                                            ],
                                        },
                                        function_call { 'close',
                                            args => [
                                                leaf '$write',
                                            ],
                                        },
                                        function_call { 'exit',
                                            args => [
                                            ],
                                        },
                                    ],
                                },
                            },
                        ],
                    },
                },
                branch { '->',
                    left => leaf '$server',
                    right => function_call { 'run',
                        args => [
                            leaf '$app',
                        ],
                    },
                },
            ],
        },
        leaf '1',
    ]);
};

done_testing;

__DATA__
package Plack::Loader::Shotgun;
use strict;
use parent qw(Plack::Loader);
use Storable;
use Try::Tiny;
use Plack::Middleware::BufferedStreaming;

sub preload_app {
    my($self, $builder) = @_;
    $self->{builder} = sub { Plack::Middleware::BufferedStreaming->wrap($builder->()) };
}

sub run {
    my($self, $server) = @_;

    my $app = sub {
        my $env = shift;

        pipe my $read, my $write;

        my $pid = fork;
        if ($pid) {
            # parent
            close $write;
            my $res = Storable::thaw(join '', <$read>);
            close $read;
            waitpid($pid, 0);

            return $res;
        } else {
            # child
            close $read;

            my $res;
            try {
                $env->{'psgi.streaming'} = 0;
                $res = $self->{builder}->()->($env);
                my @body;
                Plack::Util::foreach($res->[2], sub { push @body, $_[0] });
                $res->[2] = \@body;
            } catch {
                $env->{'psgi.errors'}->print($_);
                $res = [ 500, [ "Content-Type", "text/plain" ], [ "Internal Server Error" ] ];
            };

            print {$write} Storable::freeze($res);
            close $write;
            exit;
        }
    };

    $server->run($app);
}

1;

__END__

=head1 NAME

Plack::Loader::Shotgun - forking implementation of plackup

=head1 SYNOPSIS

  plackup -L Shotgun