File Coverage

blib/lib/Triglav/Client.pm

Criterion	Covered	Total	%
statement	54	70	77.1
branch	14	18	77.7
condition	4	6	66.6
subroutine	15	17	88.2
pod	0	9	0.0
total	87	120	72.5

package Triglav::Client;
use strict;
use warnings;
use Carp qw(croak);

use 5.008008;
our $VERSION = '0.03';

use URI;
use URI::QueryParam;
use JSON ();
use LWP::UserAgent;

sub new {
    my ($class, %args) = @_;

    croak 'Both `base_url` and `api_token` are required[u].'
        if !$args{base_url} || !$args{api_token};

    bless {
        base_url  => $args{base_url},
        api_token => $args{api_token},
        ua        => LWP::UserAgent->new,
    }, $class;
}

sub ua { $_[0]->{ua} }

sub services {
    my $self = shift;
       $self->dispatch_request('get', '/api/services.json');
}

sub roles {
    my $self = shift;
       $self->dispatch_request('get', '/api/roles.json');
}

sub roles_in {
    my ($self, $service) = @_;
    croak '`service` is required' if !$service;
    $self->dispatch_request('get', "/api/services/${service}/roles.json");
}

sub hosts {
    my ($self, %options) = @_;
    my $response = $self->dispatch_request('get', '/api/hosts.json');

    [
        grep {
            if ($options{with_inactive}) {
                1
            }
            else {
                $_->{active}
            }
        } @$response
    ];
}

sub hosts_in {
    my ($self, $service, $role, %options) = @_;
    my $response;

    croak "`role` must be passed (even if it's not needed) when you want to pass `%options`." if @_ == 4;

    if ($role) {
        $response = $self->dispatch_request('get', "/api/services/${service}/roles/${role}/hosts.json");
    }
    else {
        $response = $self->dispatch_request('get', "/api/services/${service}/hosts.json");
    }

    [
        grep {
            if ($options{with_inactive}) {
                1
            }
            else {
                $_->{active}
            }
        } @$response
    ];
}

sub dispatch_request {
    my ($self, $method, $path, %params) = @_;

    croak 'Both `method` and `path` are required.'
        if !$method || !$path;

    my $json = $self->do_request($method, $path, %params);
    JSON::decode_json($json);
}

sub do_request {
    my ($self, $method, $path, %params) = @_;
    my $uri = URI->new($self->{base_url});
       $uri->path($path);
    my $response;
    %params = (%params, api_token => $self->{api_token});

    if ($method eq 'get') {
        for my $key (keys %params) {
            $uri->query_param($key => $params{$key});
        }

        $response = $self->ua->get($uri);
    }
    else {
        $response = $self->ua->post($uri, \%params);
    }

    if ($response->code >= 300) {
        die "@{[$response->code]}: @{[$response->message]}";
    }

    $response->content;
}

!!1;

__END__