File Coverage

blib/lib/TheEye.pm

Criterion	Covered	Total	%
statement	27	72	37.5
branch	0	16	0.0
condition			n/a
subroutine	9	14	64.2
pod	5	5	100.0
total	41	107	38.3

package TheEye;

use 5.010;
use Mouse;
use POSIX qw/strftime/;
use File::Util;
use File::ShareDir 'dist_dir';
use TAP::Parser qw/all/;
use TAP::Parser::Aggregator qw/all/;
use Time::HiRes qw(gettimeofday tv_interval);
use Sys::Hostname;

# ABSTRACT: TheEye is a TAP based monitoring system
#
our $VERSION = '0.5'; # VERSION

has 'test_dir' => (
    is       => 'rw',
    isa      => 'Str',
    required => 1,
    #default  => dist_dir('TheEye') . '/t',
    default  => './t',
);

has 'debug' => (
    is       => 'rw',
    isa      => 'Bool',
    required => 1,
    default  => 0,
    predicate => 'is_debug',
);

has 'hostname' => (
    is => 'rw',
    isa => 'Str',
    default => hostname()
);



sub run {
    my ($self) = @_;
    my $f = File::Util->new();
    print STDERR "processing files in " . $self->test_dir . "\n"
      if $self->debug;
    my @files = $f->list_dir( $self->test_dir, qw/ --files-only --recurse --pattern=\.t$/ );
    my @results;
    foreach my $file (@files) {
        print STDERR "processing " . $file . "\n" if $self->debug;
        my $t0 = [gettimeofday];
        my $parser = TAP::Parser->new( { source => $file, merge => 1 } );
        my $message;
        my @steps;
        my $t1 = [gettimeofday];
        while ( my $result = $parser->next ) {
            if ( $result->type eq 'comment' ) {
                if(exists $steps[-1]){
                    $steps[-1]->{comment} .= $result->as_string . "\n";
                } else {
                    # debug output of the tests
                    print STDERR $result->as_string."\n";
                }
            }
            else {
                my $hash = {
                    message => $result->as_string,
                    delta   => tv_interval($t1),
                    type    => $result->type,
                    status  => ( $result->is_ok ? 'ok' : 'not_ok' ),
                };
                print STDERR Dumper($hash);
                push( @steps, $hash );
            }
            $t1 = [gettimeofday];
        }
        my $aggregate = TAP::Parser::Aggregator->new;
        $aggregate->add( 'testcases', $parser );
        my $hash = {
            delta  => tv_interval($t0),
            passed => scalar $aggregate->passed,
            failed => scalar $aggregate->failed,
            file   => $file,
            'time' => time,
            steps  => \@steps,
        };
        push( @results, $hash );
    }
    return @results;
}


sub save {
    my ( $self, $tests ) = @_;

    #print STDERR "saving ".($#lines +1)." results\n" if $self->debug;
    return;
}


sub graph {
    my ( $self, $tests ) = @_;

    #print STDERR "saving ".($#lines +1)." results\n" if $self->debug;
    return;
}


sub notify {
    my ( $self, $tests ) = @_;
    foreach my $test ( @{$tests} ) {
        foreach my $step ( @{ $test->{steps} } ) {
            if ( $step->{status} eq 'not_ok' ) {
                my $message = 'we have a problem: ' . $test->{file} . "\n";
                $message .= $step->{message} . "\n";
                $message .= $step->{comment} if $step->{comment};
                print STDERR $message;
            }
        }
    }

    #print STDERR "saving ".($#lines +1)." results\n" if $self->debug;
    return;
}


sub load_plugin {
    my ($self, $plugin) = @_;

    my $plug = 'TheEye::Plugin::'.$plugin;
    print STDERR "Loading $plugin Plugin\n" if $self->is_debug;
    with($plug);
    return;
}


1;    # End of TheEye

__END__