File Coverage

blib/lib/XAS/Service/Server.pm

Criterion	Covered	Total	%
statement	27	54	50.0
branch			n/a
condition	0	2	0.0
subroutine	9	13	69.2
pod	3	3	100.0
total	39	72	54.1

package XAS::Service::Server;

our $VERSION = '0.01';

use POE;
use Try::Tiny;
use Plack::Util;
use Data::Dumper;
use Socket ':all';
use HTTP::Message::PSGI;
use XAS::Constants 'CODEREF';
use POE::Filter::HTTP::Parser;

use XAS::Class
  debug   => 0,
  version => $VERSION,
  base    => 'XAS::Lib::Net::Server',
  utils   => ':validation',
  vars => {
    PARAMS => {
      -app => { type => CODEREF },
    }
  }
;

# ---------------------------------------------------------------------
# Public Events
# ---------------------------------------------------------------------

sub process_request {
    my $self = shift;
    my ($request, $ctx) = validate_params(\@_, [1,1]);

    my $app      = $self->app;
    my $alias    = $self->alias;
    my $version  = $request->header('X-HTTP-Verstion') || '0.9';
    my $protocol = "HTTP/$version";

    my $env = req_to_psgi($request,
       SERVER_NAME        => $self->address,
       SERVER_PORT        => $self->port,
       SERVER_PROTOCOL    => $protocol,
       'psgi.streaming'   => Plack::Util::TRUE,
       'psgi.nonblocking' => Plack::Util::TRUE,
       'psgi.runonce'     => Plack::Util::FALSE,
    );

    $self->log->debug(Dumper($env));

    my $r        = Plack::Util::run_app($app, $env);
    my $response = res_from_psgi($r);

    $self->log->debug(Dumper($response));

    $self->process_response($response, $ctx);

}

sub process_response {
    my $self = shift;
    my ($output, $ctx) = validate_params(\@_, [1,1]);

    my $alias = $self->alias;

    $poe_kernel->call($alias, 'client_output', $output, $ctx);

}

# ---------------------------------------------------------------------
# Public Methods
# ---------------------------------------------------------------------

# ---------------------------------------------------------------------
# Private Events
# ---------------------------------------------------------------------

sub _client_flushed {
    my ($self, $wheel) = @_[OBJECT, ARG0];

    my $alias = $self->alias;
    my $host  = $self->peerhost($wheel);
    my $port  = $self->peerport($wheel);

    $self->log->debug(sprintf('%s: _client_flushed() - wheel: %s, host: %s, port: %s', $alias, $wheel, $host, $port));
    $self->log->info_msg('service_client_flushed', $alias, $host, $port, $wheel);

    delete $self->{'clients'}->{$wheel};

}

# ---------------------------------------------------------------------
# Private Methods
# ---------------------------------------------------------------------

sub init {
    my $class = shift;

    my $self = $class->SUPER::init(@_);

    $self->{'filter'} = POE::Filter::HTTP::Parser->new(type => 'server');

    return $self;

}

1;

__END__