File Coverage

blib/lib/Test/Fluent/Logger.pm

Criterion	Covered	Total	%
statement	27	27	100.0
branch	2	2	100.0
condition	2	2	100.0
subroutine	13	13	100.0
pod	4	5	80.0
total	48	49	97.9

package Test::Fluent::Logger;
use 5.008001;
use strict;
use warnings;
no warnings qw/redefine/;

our $VERSION = "0.03";

require Exporter;
our @ISA = qw/Exporter/;
our @EXPORT = qw/get_fluent_logs clear_fluent_logs/;
our @EXPORT_OK = qw/is_active activate deactivate/;

use Fluent::Logger;

my $original__post = Fluent::Logger->can('_post');

my $is_active;
my @fluent_logs;

sub is_active () {
    return $is_active;
}

sub import {
    Test::Fluent::Logger->export_to_level(1, @_);

    activate();

    *Fluent::Logger::_post = sub {
        if ($is_active) {
            my ($self, $tag, $msg, $time) = @_;
            push @fluent_logs, {
                message    => $msg,
                time       => $time,
                tag_prefix => $self->tag_prefix || "",
            };
        } else {
            $original__post->(@_);
        }
    };
}

sub unimport {
    deactivate();
}

sub activate () {
    $is_active = 1;
}

sub deactivate () {
    $is_active = 0;
}

sub clear_fluent_logs () {
    @fluent_logs = ();
}

sub get_fluent_logs () {
    return @fluent_logs;
}

1;
__END__