File Coverage

blib/lib/DNS/Hetzner/APIBase.pm

Criterion	Covered	Total	%
statement	29	71	40.8
branch	0	12	0.0
condition	0	8	0.0
subroutine	10	12	83.3
pod	1	1	100.0
total	40	104	38.4

package DNS::Hetzner::APIBase;
$DNS::Hetzner::APIBase::VERSION = '0.05';
# ABSTRACT: Base class for all entity classes

use v5.24;

use Carp;
use Moo;
use Mojo::UserAgent;
use Mojo::Util qw(url_escape);
use Types::Mojo qw(:all);
use Types::Standard qw(Str);

use DNS::Hetzner::Schema;

use Mojo::Base -strict, -signatures;

has token    => ( is => 'ro', isa => Str, required => 1 );
has host     => ( is => 'ro', isa => MojoURL["https?"], default => sub { 'https://dns.hetzner.com' }, coerce => 1 );
has base_uri => ( is => 'ro', isa => Str, default => sub { 'api/v1' } );

has client   => (
    is      => 'ro',
    lazy    => 1,
    isa     => MojoUserAgent,
    default => sub {
        Mojo::UserAgent->new,
    }
);

sub _do ( $self, $op, $params, $path, $opts ) {
    my ($req_params, @errors) = DNS::Hetzner::Schema->validate( $op, $params );

    croak 'invalid parameters' if @errors;

    $self->request( $path, $req_params, $opts );
}

sub request ( $self, $partial_uri, $params = {}, $opts = {} ) {

    my $method = delete $opts->{type} // 'get';
    my $sub    = $self->client->can(lc $method);

    croak sprintf 'Invalid request method %s', $method if !$sub;

    $params->{path} //= {};
    my %path_params = $params->{path}->%*;

    $partial_uri =~ s{
        :(?\w+)\b
    }{
        $path_params{$+{mandatory}}
    }xmsge;

    my %request_opts;
    $params->{body} //= {};
    if ( $params->{body}->%* ) {
        %request_opts = ( json => $params->{body} );
    }

    $params->{query} //= {};
    my $query = '';
    if ( $params->{query}->%* ) {
        my $query_params = delete $params->{query};

        $query = join '&', map{
            $_ . '=' . url_escape($query_params->{$_})
        }sort keys $query_params->%*;
    }

    my $uri = join '/',
        $self->host,
        $self->base_uri,
        $self->endpoint,
        $partial_uri;

    $uri =~ s{/\z}{};

    $uri .= '?' . $query if $query;

    my $tx = $self->client->$method(
        $uri,
        {
            'Auth-API-Token' => $self->token,
        },
        %request_opts,
    );

    my $response = $tx->res;

    if ( $tx->error ) {
        carp $tx->error->{message};
        return;
    }

    return $response->json;
}

1;

__END__