File Coverage

blib/lib/WWW/OpenResty/Simple.pm

Criterion	Covered	Total	%
statement	32	62	51.6
branch	3	20	15.0
condition	2	20	10.0
subroutine	7	9	77.7
pod	2	3	66.6
total	46	114	40.3

package WWW::OpenResty::Simple;

use strict;
use warnings;

use Carp 'croak';
use JSON::XS ();
use base 'WWW::OpenResty';
use Params::Util qw( _HASH );

our $VERSION = '0.09';
our $json_xs = JSON::XS->new->utf8->allow_nonref;

sub request {
    my $self = shift;
    my $data = $_[0];
    my $meth = $_[1];
    my $url = $_[2];
    if ($data && ref $data) {
        $_[0] = $json_xs->encode($data);
    }
    my $retries = $self->{retries} || 0;
    my $ignore_dup_error = $self->{ignore_dup_error};
    my $i = 0;
    while (1) {
        my $res = $self->SUPER::request(@_);
        if ($res->is_success) {
            my $json = $res->content;
            #$json =~ s/\n+$//gs;
            my $data = $json_xs->decode($json);
            if (_HASH($data) && defined $data->{success} && $data->{success} == 0) {
                if ($ignore_dup_error &&
                    $data->{error} =~ /duplicate key (?:value )?violates unique constraint/) {
                    #print "Ignored
                    return $data;
                }
                if ($i >= $retries) {
                    croak "$meth $url: $json";
                } else {
                    warn "Retrying...\n";
                }
            } else {
                return $data;
            }
        } else {
            my $status_line = $res->status_line;
            if ($i >= $retries) {
                croak "$meth $url: $status_line";
            } else {
                warn "Retrying...\n";
            }
        }
    } continue { $i++ }
}

sub has_model {
    my ($self, $model) = @_;
    my $res;
    eval {
        $res = $self->get("/=/model/$model");
    };
    if ($@) {
        if ($@ =~ /Model .*? not found/i) {
            return undef;
        }
        die $@;
    }
    return _HASH($res) && $res->{name} eq $model;
}

sub has_view {
    my ($self, $view) = @_;
    my $res;
    eval {
        $res = $self->get("/=/view/$view");
    };
    if ($@) {
        if ($@ =~ /View .*? not found/i) {
            return undef;
        }
        die $@;
    }
    return _HASH($res) && $res->{name} eq $view;
}

1;
__END__