File Coverage

blib/lib/POE/Filter/IASLog.pm

Criterion	Covered	Total	%
statement	39	42	92.8
branch	4	6	66.6
condition	1	3	33.3
subroutine	9	11	81.8
pod	6	6	100.0
total	59	68	86.7

package POE::Filter::IASLog;

use strict;
use warnings;
use Parse::IASLog;
use base qw(POE::Filter);
use vars qw($VERSION);

$VERSION = '1.08';

sub new {
  my $class = shift;
  my %opts = @_;
  $opts{lc $_} = delete $opts{$_} for keys %opts;
  $opts{enumerate} = 1 unless defined $opts{enumerate} and !$opts{enumerate};
  $opts{BUFFER} = [];
  $opts{IAS} = Parse::IASLog->new( enumerate => $opts{enumerate} );
  return bless \%opts, $class;
}

sub get_one_start {
  my ($self, $raw) = @_;
  push @{ $self->{BUFFER} }, $_ for @$raw;
}

sub get_one {
  my $self = shift;
  my $events = [];

  my $event = shift @{ $self->{BUFFER} };
  if ( defined $event ) {
    my $record = $self->{IAS}->parse($event);
    push @$events, $record if $record;
  }
  return $events;
}

sub get_pending {
  my $self = shift;
  return $self->{BUFFER};
}

sub put {
  return;
}

sub clone {
  my $self = shift;
  my $nself = { };
  $nself->{$_} = $self->{$_} for keys %{ $self };
  $nself->{BUFFER} = [ ];
  return bless $nself, ref $self;
}

1;
__END__