File Coverage

blib/lib/Test2/Harness/Parser/EventStream.pm

Criterion	Covered	Total	%
statement	82	84	97.6
branch	11	12	91.6
condition			n/a
subroutine	24	24	100.0
pod	2	4	50.0
total	119	124	95.9

package Test2::Harness::Parser::EventStream;
use strict;
use warnings;

our $VERSION = '0.000013';

use base 'Test2::Harness::Parser';
use Test2::Util::HashBase;

use Test2::Event 1.302068;
use Test2::Event::Bail;
use Test2::Event::Diag;
use Test2::Event::Encoding;
use Test2::Event::Exception;
use Test2::Event::Note;
use Test2::Event::Ok;
use Test2::Event::ParseError;
use Test2::Event::Plan;
use Test2::Event::Skip;
use Test2::Event::Subtest;
use Test2::Event::UnknownStderr;
use Test2::Event::UnknownStdout;
use Test2::Event::Waiting;
use Test2::Harness::JSON;

sub morph { }

sub step {
    my $self = shift;

    return ($self->parse_stderr, $self->parse_stdout);
}

sub parse_stderr {
    my $self = shift;

    my $line = $self->proc->get_err_line or return;
    chomp $line;

    return Test2::Event::UnknownStderr->new(output => $line);
}

sub parse_stdout {
    my $self = shift;

    my $line = $self->proc->get_out_line or return;
    $line =~ s/\s+\z//s;

    if ($line =~ m/^T2_ENCODING: (.+)$/) {
        my $enc = $1;

        $self->proc->encoding($enc);

        return Test2::Event::Encoding->new(
            encoding => $enc,
        );
    }

    if ( my $event  = $self->_event_from_stdout($line) ) {
        return $event;
    }

    return Test2::Event::UnknownStdout->new(output => $line);
}

sub _event_from_stdout {
    my $self = shift;
    my $out = shift;

    return unless $out =~ s/^T2_EVENT:\s//;

    local $@ = undef;
    my $data = eval { JSON->new->decode($out) };
    my $err = $@;

    if ($data) {
        return Test2::Event->from_json(%$data);
    }

    chomp($err);
    return Test2::Event::ParseError->new(parse_error => $err);
}

1;

__END__