File Coverage

blib/lib/Dancer/Logger/Pipe.pm

Criterion	Covered	Total	%
statement	28	28	100.0
branch	4	6	66.6
condition	4	9	44.4
subroutine	8	8	100.0
pod	1	1	100.0
total	45	52	86.5

package Dancer::Logger::Pipe;

use strict;
use warnings;
use Carp;
use base 'Dancer::Logger::Abstract';
use Dancer::Config 'setting';
use IO::Handle;

our $VERSION = '0.01';

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

    my $pipe    = setting('pipe')  || croak "Missing pipe settings";
    my $command = $pipe->{command} || croak "Missing pipe command setting";

    open( my $fh, '|-', $command)
        || croak "Unable to open pipe: $!";

    $fh->autoflush(1);

    $self->{fh}          = $fh;
}

sub _log {
    my ( $self, $level, $message ) = @_;
    my $fh = $self->{fh};

    return unless ref $fh && $fh->opened;

    $fh->print( $self->format_message( $level => $message ) )
        or carp "writing logs to pipe failed: $!";
}

1;

__END__