File Coverage

blib/lib/XAS/Lib/Log/Json.pm

Criterion	Covered	Total	%
statement	6	16	37.5
branch			n/a
condition			n/a
subroutine	2	4	50.0
pod	2	2	100.0
total	10	22	45.4

package XAS::Lib::Log::Json;

our $VERSION = '0.01';

use XAS::Factory;

use XAS::Class
  debug      => 0,
  version    => $VERSION,
  base       => 'XAS::Base',
  utils      => ':validation level2syslog',
  codec      => 'JSON',
  accessors  => 'spooler',
  constants  => 'HASHREF',
  filesystem => 'Dir',
;

# note to self: Don't but $self->log->debug() statements in here
# it will produce a nice race condition.

# ----------------------------------------------------------------------
# Public Methods
# ----------------------------------------------------------------------

sub output {
    my $self  = shift;
    my ($args) = validate_params(\@_, [
        { type => HASHREF }
    ]);

    my $message = sprintf('[%s] %-5s - %s',
        $args->{'datetime'}->strftime('%Y-%m-%d %H:%M:%S'),
        uc($args->{'priority'}),
        $args->{'message'}
    );

    # create a logstash "json_event"

    my $data = {
        '@timestamp' => $args->{'datetime'}->strftime('%Y-%m-%dT%H:%M:%S.%3N%z'),
        '@version'   => '1',
        '@message'   => $message,
        type         => 'xas-logs',
        message      => $args->{'message'},
        hostname     => $args->{'hostname'},
        priority     => level2syslog($args->{'priority'}),
        facility     => $args->{'facility'},
        process      => $args->{'process'},
        pid          => $args->{'pid'}
    };

    my $json = encode($data);

    # write the spool file

    $self->spooler->write($json);

}

# ----------------------------------------------------------------------
# Private Methods
# ----------------------------------------------------------------------

sub init {
    my $class = shift;

    my $self = $class->SUPER::init(@_);

    $self->{'spooler'} = XAS::Factory->module('spool', {
        -directory => Dir($self->env->spool, 'logs'),
        -lock      => Dir($self->env->spool, 'logs', 'locked')->path,
    });

    return $self;

}

1;

__END__