File Coverage

lib/Druid.pm

Criterion	Covered	Total	%
statement	15	35	42.8
branch	0	6	0.0
condition			n/a
subroutine	5	7	71.4
pod	0	2	0.0
total	20	50	40.0

package Druid;


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

our $VERSION = '0.004';

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

has 'ua' => (
    'is'      => 'ro',
    'default' => sub {
        my $self = shift;
        my $ua   = LWP::UserAgent->new();
        $ua->ssl_opts( 'verify_hostname' => 0 );
        return $ua;
    },
);

has 'req' => (
    'is'      => 'ro',
    'lazy'    => 1,
    'default' => sub {
        my $self = shift;
        my $req  = HTTP::Request->new( 'POST' => $self->api_url );
        $req->header( 'Content-Type' => 'application/json' );
        return $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 "";
            $_->{'timestamp'} = iso8601_yyyy_mm_dd_hh_mm_ss( $_->{'timestamp'} )
                for @{$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__