File Coverage

blib/lib/Fennec/Finder.pm

Criterion	Covered	Total	%
statement	54	59	91.5
branch	9	16	56.2
condition			n/a
subroutine	13	13	100.0
pod	0	4	0.0
total	76	92	82.6

package Fennec::Finder;
use strict;
use warnings;

use base 'Fennec::Runner';

use File::Find qw/find/;
use Fennec::Util qw/accessors verbose_message/;
use List::Util qw/shuffle/;

accessors qw/test_files parallel/;

sub import {
    my $self = shift->new;
    $self->find_files(@_);
    $self->inject_run( scalar caller );
}

sub init {
    my $self = shift;
    my (%params) = @_;

    $self->test_files( [] );
    $self->parallel( defined $params{parallel} ? $params{parallel} : 2 );

    return $self;
}

sub find_files {
    my $self = shift;
    my @paths = @_ ? @_ : -d './t' ? ('./t') : ('./');

    find(
        {
            wanted => sub {
                my $file = $File::Find::name;
                return unless $self->validate_file($file);
                push @{$self->test_files} => $file;
            },
            no_chdir => 1,
        },
        @paths
    );
}

sub validate_file {
    my $self = shift;
    my ($file) = @_;
    return unless $file =~ m/\.(pm|ft)$/;
    return 1;
}

sub run {
    my $self = shift;
    my ($follow) = @_;

    $self->_ran(1);

    my $frunner = $self->prunner( $self->parallel );

    for my $file ( @{$self->test_files} ) {
        $frunner->run(
            sub {
                $self->load_file($file);

                for my $class ( shuffle @{$self->test_classes} ) {
                    next unless $class;
                    $self->run_test_class($class);
                }
            },
            1
        );

        $self->check_pid;
    }

    $frunner->finish();

    if ($follow) {
        $self->collector->collect;
        verbose_message("Entering final follow-up stage\n");
        eval { $follow->(); 1 } || $self->exception( 'done_testing', $@ );
    }

    $self->collector->collect;
    $self->collector->finish();
}

1;

__END__