File Coverage

blib/lib/Process/Pipeline/DSL.pm

Criterion	Covered	Total	%
statement	24	30	80.0
branch	1	4	25.0
condition			n/a
subroutine	6	7	85.7
pod	0	2	0.0
total	31	43	72.0

package Process::Pipeline::DSL;
use 5.008001;
use strict;
use warnings;
use Process::Pipeline;

use Exporter qw/ import /;
our @EXPORT = qw/ proc set /;

our $PIPELINE;
our $PROCESS;

sub set {
    die "Cannot call outside proc()\n" unless $PROCESS;
    my ($key, $value) = @_;
    $PROCESS->set($key, $value);
}

sub proc (&;@) {
    my ($code, @process) = @_;
    if (!$PIPELINE) {
        local $PIPELINE = Process::Pipeline->new;
        local $PROCESS  = Process::Pipeline::Process->new;
        $PROCESS->cmd($code->());
        $PIPELINE->_push($PROCESS);
        $PIPELINE->_push($_) for map { @{$_->{process}} } @process;
        return $PIPELINE;
    } else {
        local $PROCESS = Process::Pipeline::Process->new;
        $PROCESS->cmd($code->());
        return $PROCESS;
    }
}

1;