File Coverage

blib/lib/WebService/Bukget.pm

Criterion	Covered	Total	%
statement	21	65	32.3
branch	0	26	0.0
condition	0	38	0.0
subroutine	7	13	53.8
pod	4	4	100.0
total	32	146	21.9

use strict;
use warnings;
package WebService::Bukget;
{
  $WebService::Bukget::VERSION = '1.00';
}
# ABSTRACT: Provides access to the v3 Bukget API
use Mojo::Base '-base';
use Mojo::JSON;
use Mojo::UserAgent;
use Try::Tiny qw/try catch/;
use boolean;

has     '_ua'           =>  sub { Mojo::UserAgent->new };

# these are here so they can be overridden if needed
has     'url_base'      =>  'http://dev.bukget.org/3';

sub _fetch {
    my $self = shift;
    my $e    = shift;
    my $args = shift;
    my $p    = $args->{'params'} || {};

    my $u = Mojo::URL->new(sprintf('%s/%s', $self->url_base, $e));
    foreach my $pk (keys(%$p)) {
        $u->query->param($pk => $p->{$pk});
    }

    if(my $tx = $self->_ua->get($u)) {
        if(my $res = $tx->success) {
            $args->{on_success}->($self => $res->json) if(defined($args->{on_success}));
        } else {
            my ($err, $code) = $tx->error;
            $args->{on_failure}->($self => $err => $code) if(defined($args->{on_failure}));
        }
    } else {
        $args->{on_failure}->($self) if(defined($args->{on_failure}));
    }
}

sub _fix_fields {
    my $self = shift;
    my $s    = shift;

    $s->{params}->{fields} = join(',', @{$s->{params}->{fields}}) if(defined($s->{params}->{fields}) && ref($s->{params}->{fields}) eq 'ARRAY');
    return $s;
}

# endpoint accessors
sub geninfo { shift->_fetch('geninfo' => shift) }

sub plugins {
    my $self = shift;
    my $s    = shift;
    my $e    = 'plugins';

    unless(defined($s) && ref($s) eq 'HASH') {
        $e .= '/' . $s;
        $s = shift;
    }
    $self->_fetch($e => $self->_fix_fields($s));
}

sub categories {
    my $self = shift;
    my $e    = 'categories';
    my $scn  = shift;
    my $cn   = shift;
    my $s    = shift;

    if(defined($scn) && ref($scn) eq 'HASH') {
        # plain categories
        $self->_fetch('categories' => $self->_fix_fields($scn));
    } elsif(defined($cn) && ref($cn) eq 'HASH') {
        # categories/categoryname
        $self->_fetch(sprintf('categories/%s', $scn) => $self->_fix_fields($cn));
    } elsif(defined($scn) && defined($cn) && defined($s) && ref($s) eq 'HASH') {
        # categories/server/categoryname
        $self->_fetch(sprintf('categories/%s/%s', $scn, $cn) => $self->_fix_fields($s));
    }
}

sub authors {
    my $self = shift;
    my $e    = 'authors';
    my $san  = shift;
    my $an   = shift;
    my $s    = shift;

    if(defined($san) && ref($san) eq 'HASH') {
        # plain authors
        $self->_fetch('authors' => $self->_fix_fields($san));
    } elsif(defined($an) && ref($an) eq 'HASH') {
        # authors/authorname
        $self->_fetch(sprintf('authors/%s', $san) => $self->_fix_fields($an));
    } elsif(defined($san) && defined($an) && defined($s) && ref($s) eq 'HASH') {
        # authors/server/authorname
        $self->_fetch(sprintf('authors/%s/%s', $san, $an) => $self->_fix_fields($s));
    }
}

1;

__END__