File Coverage

lib/WebService/LogDNA.pm

Criterion	Covered	Total	%
statement	41	43	95.3
branch	3	6	50.0
condition	1	3	33.3
subroutine	10	10	100.0
pod	0	1	0.0
total	55	63	87.3

use strict;
use warnings;

package WebService::LogDNA;

# ABSTRACT: Implements the ingest API call for L

use Moo;
use LWP::UserAgent;
use URI;
use Time::HiRes;
use MIME::Base64 qw/encode_base64/;
use WebService::LogDNA::Body;

use namespace::clean;

has key => ( is => 'ro', required => 1 );

has hostname => (
	is => 'ro',
	default => sub {
		require POSIX;

		return( (POSIX::uname())[1] ); #nodename
	}
);

has mac => ( is => 'ro' );
has ip => ( is => 'ro' );

# Private!
has agent => (
	is => 'ro',
	default => sub {
		return LWP::UserAgent->new;
	}
);

# Mostly overrideable for testing
has url => (
	is => 'ro',
	default => sub {
		URI->new("https://logs.logdna.com/logs/ingest");
	},
	coerce => sub {
		unless( ref $_[0] ) { return URI->new($_[0]) }

		return $_[0];
	},
);

sub ingest {
	my( $self, $body ) = @_;

	unless( defined $body and ref $body ) {
		die 'Ingest requires a $body argument';
	}

	# Attempt to upgrade a hashref to a proper object
	if( ref $body eq 'HASH' ) {
		$body = WebService::LogDNA::Body->new( %$body );
	}

	unless( UNIVERSAL::isa( $body, 'WebService::LogDNA::Body' ) ) {
		die "Ingest requires WebService::LogDNA::Body argument, got: $body";
	}

	my $now = int( Time::HiRes::time() * 1000 );
	my $url = $self->url->clone;
	$url->query_form(
		hostname => $self->hostname,
		mac => $self->mac,
		ip => $self->ip,
		now => $now,
	);

	my $headers = HTTP::Headers->new;
	$headers->authorization_basic($self->key, "");
	$headers->content_type('application/json; charset=UTF-8');

	my $content = '{"lines":[' . $body->to_json . ']}';

	my $request = HTTP::Request->new( "POST", $url, $headers, $content );

	my $resp = $self->agent->request($request);
}

1;

__END__