File Coverage

blib/lib/POE/Component/Logger.pm

Criterion	Covered	Total	%
statement	4	6	66.6
branch			n/a
condition			n/a
subroutine	2	2	100.0
pod			n/a
total	6	8	75.0

package POE::Component::Logger;
use strict;

use POE;
use Log::Dispatch::Config;

use vars qw($VERSION $DefaultLevel);

$VERSION = '1.10';

$DefaultLevel = 'warning';

sub spawn {
    my $class = shift;
    POE::Session->create(
        inline_states => {
            _start => \&_start_logger,
            _stop => \&_stop_logger,

            # Log at the $DefaultLevel
            log =>       sub { my @args = @_; $args[STATE] = $DefaultLevel; _poe_log(@args) },
            # Log at a specific level
            debug =>     \&_poe_log,
            info =>      \&_poe_log,
            notice =>    \&_poe_log,
            warning =>   \&_poe_log,
            error =>     \&_poe_log,
            critical =>  \&_poe_log,
            alert =>     \&_poe_log,
            emergency => \&_poe_log,
        },
        args => [ @_ ],
    );
}

sub _start_logger {
    my ($kernel, $heap, %args) = @_[KERNEL, HEAP, ARG0 .. $#_];

    $args{Alias} ||= 'logger';

    Log::Dispatch::Config->configure($args{ConfigFile});

    $heap->{_logger} = Log::Dispatch::Config->instance;
    $heap->{_alias} = $args{Alias};
    $kernel->alias_set($args{Alias});
}

sub _stop_logger {
    my ($kernel, $heap) = @_[KERNEL, HEAP];

    $kernel->alias_remove($heap->{_alias});
    delete $heap->{_logger};
}


sub _poe_log {
    my ($heap, $level, $arg0, @args) = @_[HEAP, STATE, ARG0..$#_];

    $heap->{_logger}->log(
        # The default level is the POE event name ($_[STATE])
        # (may be overriden in given hashref)
        level => $level,
        # If we get a HASHREF, expand it
        # If we get a scalar, concatenate args as the message
        (ref $arg0) ? (%{$arg0})
                    : (message => join('', $arg0, @args))
    );
}


sub log {
    my ($class, @args) = @_;
    POE::Kernel->post(logger => $DefaultLevel => @args);
}

*Logger::log = \&log;

1;
__END__