File Coverage

blib/lib/Opsview/REST/APICaller.pm

Criterion	Covered	Total	%
statement	15	47	31.9
branch	0	14	0.0
condition	0	4	0.0
subroutine	5	12	41.6
pod	0	4	0.0
total	20	81	24.6

package Opsview::REST::APICaller;
{
  $Opsview::REST::APICaller::VERSION = '0.013';
}

use Moo::Role;

use Carp;

use Try::Tiny;
use JSON ();
use HTTP::Tiny 0.014;

has ua => (
    is      => 'ro',
    default => sub { HTTP::Tiny->new(
        agent => 'Opsview::REST/' . (__PACKAGE__->VERSION || '0.001_DEV'),
    ); },
);

has headers => (
    is      => 'rw',
    default => sub { {
        'Accept'        => 'application/json',
        'Content-type'  => 'application/json',
    }; },
);

has json => (
    is      => 'ro',
    default => sub { JSON->new },
);

sub get {
    my $self = shift;
    my $r = $self->ua->get($self->base_url . shift, {
        headers => $self->headers,
    });
    croak $self->_errmsg($r) unless $r->{success};

    return $self->json->decode($r->{content});
}

sub delete {
    my $self = shift;
    my $r = $self->ua->delete($self->base_url . shift, {
        headers => $self->headers,
    });
    croak $self->_errmsg($r) unless $r->{success};

    return $self->json->decode($r->{content});
}

sub post {
    my ($self, $method, $data) = @_;

    my $stuff = { headers => $self->headers };
    if (defined $data) {
        $stuff->{content} = $self->json->encode($data);
    } else {
        $stuff->{headers}->{'Content-Length'} = '0';
    }

    my $r = $self->ua->post($self->base_url . $method, $stuff);
    croak $self->_errmsg($r) unless $r->{success};

    return $self->json->decode($r->{content});
}

sub put {
    my ($self, $method, $data) = @_;

    my $stuff = { headers => $self->headers };
    $stuff->{content} = $self->json->encode($data) if defined $data;

    my $r = $self->ua->put($self->base_url . $method, $stuff);
    croak $self->_errmsg($r) unless $r->{success};

    return $self->json->decode($r->{content});
}

sub _errmsg {
    my ($self, $r) = @_;
    my $exc = {
        status => $r->{status},
        reason => $r->{reason},
    };

    if ($r->{content}) {
        try {
            my $resp;
            $resp = $self->json->decode($r->{content});
            $exc->{message} = $resp->{message} || undef;
            $exc->{detail}  = $resp->{detail}  || undef;
        } catch {
            $exc->{message} = $r->{content};
        };
    }

    return Opsview::REST::Exception->new($exc);
}

1;
__END__