File Coverage

blib/lib/XAS/Logmon/Format/Logstash.pm

Criterion	Covered	Total	%
statement	9	30	30.0
branch			n/a
condition			n/a
subroutine	3	9	33.3
pod	2	3	66.6
total	14	42	33.3

package XAS::Logmon::Format::Logstash;

our $VERSION = '0.01';

use Try::Tiny;
use Hash::Merge;

use XAS::Class
  debug     => 0,
  version   => $VERSION,
  base      => 'XAS::Base',
  utils     => ':validation dotid trim',
  constants => 'HASHREF',
  codec     => 'JSON',
  accessors => 'hm',
;

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

sub dt2ls {
    my $self = shift;
    my ($dt, $zone) = validate_params(\@_, [
        { isa => 'DateTime' },
        { optional => 1, default => 'local' },
    ]);

    try {

        $dt->set_time_zone($zone);

    } catch {

        my ($package, $file, $line) = caller(1);
        my $ex = XAS::Exception->new({
            type => dotid($self->class) . '.dt2ls.badzone',
            info => $self->message('logmon_badzone', $package, $line, $zone)
        });

        $ex->throw;

    };

    return $dt->strftime('%Y-%m-%dT%H:%M:%S.%3N%z');

}

sub format {
    my $self = shift;
    my ($data) = validate_params(\@_, [
        { type => HASHREF,
              callbacks => {'no datetime' => sub {defined($_[0]->{datetime}); }}
        },
    ]);

    my $event = {
        '@timestamp' => $self->dt2ls($data->{'datetime'}, 'UTC'),
        '@version'   => 1,
    };

    delete($data->{'datetime'});
    delete($data->{'level'});
    delete($data->{'task'});

    $event = $self->hm->merge($data, $event);

    return encode($event);

}

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

sub init {
    my $class = shift;

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

    $self->{'hm'} = Hash::Merge->new('RIGHT_PRECEDENT');

    return $self;

}

1;

__END__