File Coverage

blib/lib/File/Extract/Filter/Exec.pm

Criterion	Covered	Total	%
statement	36	36	100.0
branch	3	8	37.5
condition	1	6	16.6
subroutine	8	8	100.0
pod	0	3	0.0
total	48	61	78.6

# $Id: /mirror/perl/File-Extract/trunk/lib/File/Extract/Filter/Exec.pm 4210 2007-10-27T13:43:07.499967Z daisuke  $
#
# Copyright (c) 2005 Daisuke Maki
# All rights reserved.

package File::Extract::Filter::Exec;
use strict;
use base qw(File::Extract::Filter::Base);
use IO::Scalar;
use IPC::Open2;
use UNIVERSAL::isa;

sub new
{
    my $class = shift;
    my %args  = @_;

    my $self = bless { cmd => $args{cmd} }, $class;
    return $self;
}

sub cmd { shift->{cmd} }

sub filter
{
    my $self = shift;
    my %args = @_;

    my $file = $args{file};
    my $o = $args{output};
    my $output =
        (ref($o) && UNIVERSAL::isa($o, 'GLOB'))   ? $o :
        (ref($o) && UNIVERSAL::isa($o, 'SCALAR')) ? IO::Scalar->new($o) :
        die "output must be a GLOB or ref to SCALAR";

    my $cmd = $self->cmd; # XXX - if we wanted to be paranoid, we need to
                          # cleanse this guy, but oh well..
=head1
    if ($cmd !~ /\|\s*$/) {
        $cmd .= " |"; # make sure it's piped
    }
    if ($cmd !~ /^\s*\|$/) {
        $cmd = "| " . $cmd; # make sure it's piped
    }
=cut

    open(my $input, $file) or die "Failed to open file $file: $!";
    my($p_read, $p_write);
    open2($p_read, $p_write, $cmd) or die "Failed to execute $cmd";

    while (<$input>) {
        print $p_write $_;
    }
    close($input);
    close($p_write);

    while (<$p_read>) {
        print $output $_;
    }
    close($p_read);
}

1;

__END__