File Coverage

blib/lib/Couchbase/Couch/HandleInfo.pm

Criterion	Covered	Total	%
statement	27	64	42.1
branch	0	24	0.0
condition	0	3	0.0
subroutine	9	15	60.0
pod	3	3	100.0
total	39	109	35.7

package Couchbase::Couch::HandleInfo;
# Subclass of Couchbase::Client::Return, with extra fields
# for handling callbacks and http codes. This 'unimplements'
# the cas method, which is not applicable to HTTP queries.
#
# ^^^^ This might change in the future, as CAS is actually encoded in the rev
# field.

use strict;
use warnings;

use Couchbase::Client::Return;
use Couchbase::Client::IDXConst;
use Couchbase::Client::Return;
use JSON;
use base qw(Couchbase::Client::Return);

use Class::XSAccessor::Array {
    accessors => {
        http_code => COUCHIDX_HTTP,
        on_data => COUCHIDX_CALLBACK_DATA,
        on_complete => COUCHIDX_CALLBACK_COMPLETE,
        path => COUCHIDX_PATH,
        parent => COUCHIDX_CBO,
        errinfo => COUCHIDX_ERREXTRA,
        count => COUCHIDX_ROWCOUNT,
        _priv => COUCHIDX_UDATA
    }
};

sub cas {
    warn ("This method is not implemented for " . __PACKAGE__);
    return;
}


# These two methods implement handling of HTTP errors as well
sub is_ok {
    my $self = shift;
    my $ret = $self->SUPER::is_ok();
    if (!$ret) {
        return $ret;
    }
    if ($self->errinfo) {
        return 0;
    }
    if ($self->http_code > 299 && $self->http_code < 200) {
        return 0;
    }
    return $ret;
}

sub errstr {
    my $self = shift;
    my $ret = $self->SUPER::errstr;
    if (!$ret) {
        return $ret;
    }
    if ($self->http_code !~ /^2\d\d/) {
        $ret .= sprintf(" (HTTP=%d)", $self->http_code);
    }
    if ($self->errinfo) {
        if ($self->errinfo->{errors}) {
            $ret .= " [There were some errors fetching individual rows. "
                    ."See ->errinfo]";

        } elsif ($self->errinfo->{error}) {
            $ret .= sprintf(" [Query Error (error=%s, reason=%s)]",
                            $self->errinfo->{error}, $self->errinfo->{reason});
        }
    }
    return $ret;
}

sub _extract_row_errors {
    my ($self,$hash) = @_;
    if (exists $hash->{errors}) {
        $self->[COUCHIDX_ERREXTRA] = delete $hash->{errors};
    } elsif (exists $hash->{error}) {
        $self->[COUCHIDX_ERREXTRA] = { reason => delete $hash->{reason},
                                        error => delete $hash->{error} };
    }
}

sub _extract_item_count {
    my ($self,$hash) = @_;
    if (!defined $hash) {
        return;
    }

    $self->[COUCHIDX_ROWCOUNT] = $hash->{total_rows};
    return $self->[COUCHIDX_ROWCOUNT];
}

sub _extract_view_results {
    my $self = shift;
    my $json = delete $self->[RETIDX_VALUE];
    if (defined $json) {
        $json = decode_json($json);
        $self->_extract_row_errors($json);
        $self->[RETIDX_VALUE] = delete $json->{rows};
    }
}

{
    no warnings 'once';
    *rows = *Couchbase::Client::Return::value;
}

1;

__END__