File Coverage

blib/lib/Plack/Middleware/Auth/FCGI.pm

Criterion	Covered	Total	%
statement	12	45	26.6
branch	0	14	0.0
condition	0	11	0.0
subroutine	4	6	66.6
pod	2	2	100.0
total	18	78	23.0

package Plack::Middleware::Auth::FCGI;

use strict;

our $VERSION = '0.02';

use base qw(Plack::Middleware);
use Plack::Util;
use Plack::Util::Accessor qw(
  on_reject
  host
  port
  fcgi_auth_params
);

sub prepare_app {
    my ($self) = @_;
    Plack::Util::load_class('FCGI::Client');
}

sub call {
    my ( $self, $env ) = @_;
    my $sock = IO::Socket::INET->new(
        PeerAddr => $self->host,
        PeerPort => $self->port,
    ) or die $!;
    $env->{$_} = $self->fcgi_auth_params->{$_}
      foreach ( keys %{ $self->fcgi_auth_params } );
    my $client = FCGI::Client::Connection->new( sock => $sock );
    my ( $stdout, $stderr ) = $client->request($env);
    my $rejApp = $self->on_reject;
    my @lines = split /\r?\n/, $stdout;
    my %hdrs;

    foreach (@lines) {
        if (/^(.*?): (.*)$/) {
            my ( $k, $v ) = ( lc($1), $2 );
            if ( $hdrs{$k} ) {
                $hdrs{$k} = $hdrs{$k} . ",$v";
            }
            else {
                $hdrs{$k} = $v;
            }
        }
    }
    my $code;
    if ( $hdrs{status} =~ /^(\d+)\s+(.*)$/ ) {
        $code = $1;
    }
    else {
        $hdrs{status} ||= '500 Server Error';
        $code = 500;
    }
    if ( $hdrs{location} and $code == 302 or $code == 303 or $code == 401 ) {
        return [ 302, [ Location => $hdrs{location} ], [] ];
    }
    unless ( $code < 300 ) {
        if ($rejApp) {
            return $self->$rejApp( $env, \%hdrs );
        }
        else {
            return [ $code, [%hdrs], [ $hdrs{status} ] ];
        }
    }
    my $app  = $self->app;
    foreach ( keys %hdrs ) {
        $env->{$_} = 'fcgiauth-' . $hdrs{$_} foreach ( keys %hdrs );
    }
    @_ = $env;
    goto $app;
}

1;
__END__