File Coverage

blib/lib/XAS/Lib/Stomp/POE/Filter.pm

Criterion	Covered	Total	%
statement	9	35	25.7
branch	0	8	0.0
condition			n/a
subroutine	3	8	37.5
pod	5	5	100.0
total	17	56	30.3

package XAS::Lib::Stomp::POE::Filter;

our $VERSION = '0.03';

use XAS::Lib::Stomp::Parser;
use XAS::Constants 'CRLF :stomp';

use XAS::Class
  debug     => 0,
  version   => $VERSION,
  base      => 'XAS::Base',
  accessors => 'filter eol',
  constant => {
    LF => "\n",
  },
  vars => {
    PARAMS => {
      -target => { optional => 1, default => undef, regex => STOMP_LEVELS },
    }
  }
;

#use Data::Hexdumper;

# ---------------------------------------------------------------------
# Public methods
# ---------------------------------------------------------------------

sub get_one_start {
    my ($self, $buffers) = @_;

    foreach my $buffer (@$buffers) {

        if (my $frame = $self->filter->parse($buffer)) {

            push(@{$self->{frames}}, $frame);

        }

    }

}

sub get_one {
    my ($self) = shift;

    my @ret;

    if (my $frame = shift(@{$self->{frames}})) {

        push(@ret, $frame);

    }

    return \@ret;

}

sub get_pending {
    my ($self) = shift;

    return $self->filter->get_pending;

}

sub put {
    my ($self, $frames) = @_;

    my @ret;

    foreach my $frame (@$frames) {

        my $buffer = $frame->as_string;

#        $self->log->debug(hexdump($buffer));
        push(@ret, $buffer);

    }

    return \@ret;

}

# ---------------------------------------------------------------------
# Private methods
# ---------------------------------------------------------------------

sub init {
    my $class = shift;

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

    unless (defined($self->{target})) {

        $self->{target} = $self->env->mqlevel;

    }

    $self->{eol} = ($self->target > 1.1) ? CRLF : LF;
    $self->{filter} = XAS::Lib::Stomp::Parser->new(-target => $self->target);

    return $self;

}

1;

__END__