File Coverage

blib/lib/Druid.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 Druid;


use Moo;
use JSON;
use LWP::UserAgent;
use HTTP::Request;
use Druid::Util qw(iso8601_yyyy_mm_dd_hh_mm_ss);

our $VERSION = '0.001';

has api_url => (is	=> 'ro');

has _ua     => (is => 'rwp', lazy => 1);
has _req    => (is => 'rwp', lazy => 1);

sub _set_ua     { $_[0]->{_ua}    = $_[1] }
sub _set_req    { $_[0]->{_req } = $_[1] }

sub BUILD {
    my $self = shift;

    my $ua	= LWP::UserAgent->new();
    my $req	= HTTP::Request->new( 'POST' => $self->api_url );

    $ua->ssl_opts( verify_hostname => 0 );
    $req->header( 'Content-Type' => 'application/json' );

    $self->_set_ua( $ua );
    $self->_set_req( $req );
}

sub send {
    my $self = shift;
    my $query = shift;

    $self->{error} = undef;

    my $response;
    my $request_hash = $query->gen_query;
    $self->_req->content( encode_json( $request_hash ) );

    my $res = $self->_ua->request( $self->_req );
    if ($res->is_success) {
        eval {
            $response = decode_json($res->content) if $res->content ne "";
            map {
                $_->{'timestamp'} =  iso8601_yyyy_mm_dd_hh_mm_ss($_->{'timestamp'})
            } @{$response};
            1;
        } or do {
            $self->handle_error("500", "Parsing of the reponse failed");
            warn "error: $@";
        }
    }else{
        $self->handle_error($res->code, $res->message, $res->content);
    }
    return $response;
}

sub handle_error {
    my $self = shift;
    my ($code, $message, $content) = @_;

    $self->{error} = {
        "code"      => $code,
        "message"   => $message,
        "content"   => $content
    };

}

1;

__END__