File Coverage

blib/lib/XAS/Lib/Pipe.pm

Criterion	Covered	Total	%
statement	10	51	19.6
branch			n/a
condition			n/a
subroutine	4	11	36.3
pod	5	5	100.0
total	19	67	28.3

package XAS::Lib::Pipe;

our $VERSION = '0.01';

my $mixin;

BEGIN {
    $mixin = 'XAS::Lib::Pipe::Unix';
};

use POE;
use XAS::Lib::POE::PubSub;

use XAS::Class
  debug     => 0,
  version   => $VERSION,
  base      => 'XAS::Lib::POE::Session',
  mixin     => $mixin,
  accessors => 'pipe event',
  utils     => ':validation trim dotid',
  vars => {
    PARAMS => {
      -fifo   => { isa => 'Badger::Filesystem::File' },
      -filter => { optional => 1, default => undef },
      -eol    => { optional => 1, default => "\n" },
    }
  }
;

#use Data::Dumper;

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

sub session_initialize {
    my $self = shift;

    my $alias = $self->alias;

    $self->log->debug("$alias: entering session_initialize()");

    # public events

    # private events

    $poe_kernel->state('pipe_error',    $self, '_pipe_error');
    $poe_kernel->state('pipe_input',    $self, '_pipe_input');
    $poe_kernel->state('pipe_output',   $self, '_pipe_output');
    $poe_kernel->state('pipe_connect',  $self, '_pipe_connect');
    $poe_kernel->state('process_error', $self, '_process_error');
    $poe_kernel->state('process_input', $self, '_process_input');

    # walk the chain

    $self->SUPER::session_initialize();

    $self->log->debug("$alias: leaving session_initialize()");

}

sub process_input {
    my $self = shift;
    my ($input) = validate_params(\@_, [1]);

    my $alias = $self->alias;

    $self->log->debug("$alias: process_input()");

    $self->process_output($input);

}

sub process_error {
    my $self = shift;
    my ($syscall, $errnum, $errstr) = validate_params(\@_, [1,1,1]);

    my $alias = $self->alias;

    $self->log->debug("$alias: process_error()");

    $self->log->error_msg('net_client_error', $alias, $errnum, $errstr);

}

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

    my $alias = $self->alias;

    $self->log->debug("$alias: process_output()");
    $poe_kernel->post($alias, 'pipe_output', $output);

}

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

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

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

    my $alias = $self->alias;

    $self->log->debug("$alias: _process_input()");

    $self->process_input($input);

}

sub _process_error {
    my ($self, $syscall, $errnum, $errstr) = @_[OBJECT,ARG0..ARG2];

    my $alias = $self->alias;

    $self->log->debug("$alias: _process_error()");

    $self->process_error($syscall, $errnum, $errstr);

}

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

sub init {
    my $class = shift;

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

    $self->{'event'} = XAS::Lib::POE::PubSub->new();
    $self->event->subscribe($alias);

    $self->init_pipe();

    return $self;

}

1;

__END__