File Coverage

blib/lib/Pipe/Tube/Csv.pm

Criterion	Covered	Total	%
statement	27	27	100.0
branch	1	2	50.0
condition	2	5	40.0
subroutine	7	7	100.0
pod	0	2	0.0
total	37	43	86.0

package Pipe::Tube::Csv;
use strict;
use warnings;

our $VERSION = '0.04';

use base 'Pipe::Tube';
use Text::CSV;
use Data::Dumper;


sub init {
    my ($self, $attr) = @_;
    die "First paramater of csv should be HASH reference or nothing" if $attr and ref $attr ne 'HASH';
	$attr ||= {};

    $self->logger("Receiving Csv definition: " . Dumper $attr);

    $self->{csv} = Text::CSV->new($attr);

    return $self;
}

sub run {
    my ($self, @input) = @_;

    my @resp;
    foreach my $line (@input) {
      $self->{csv}->parse($line);
      push @resp, [ $self->{csv}->fields ];
    }
    return @resp;
}

1;

__END__