File Coverage

blib/lib/Google/API/Method.pm

Criterion	Covered	Total	%
statement	18	68	26.4
branch	0	24	0.0
condition	0	20	0.0
subroutine	6	9	66.6
pod	2	2	100.0
total	26	123	21.1

package Google::API::Method;

use strict;
use warnings;

use Encode;
use HTTP::Request;
use URI;
use URI::Escape qw/uri_escape/;

sub new {
    my $class = shift;
    my (%param) = @_;
    for my $required (qw/ua json_parser base_url opt doc/) {
        die unless $param{$required};
    }
    bless { %param }, $class;
}

sub execute {
    my ($self, $arg) = @_;
    my $url = $self->{base_url} . $self->{doc}{path};
    my $http_method = uc($self->{doc}{httpMethod});
    my %required_param;
    for my $p (@{$self->{doc}{parameterOrder}}) {
        $required_param{$p} = delete $self->{opt}{$p};
        if ($self->{opt}{body} && $self->{opt}{body}{$p}) {
            $required_param{$p} = delete $self->{opt}{body}{$p};
        }
    }
    $url =~ s/{([^}]+)}/uri_escape(delete $required_param{$1})/eg;
    my $uri = URI->new($url);
    my $request;
    if ($http_method eq 'POST' ||
        $http_method eq 'PUT' ||
        $http_method eq 'PATCH' ||
        $http_method eq 'DELETE') {
        $uri->query_form(\%required_param);
        $request = HTTP::Request->new($http_method => $uri);
        # Some API's (ie: admin/directoryv1/groups/delete) require requests
        # with an empty body section to be explicitly zero length.
        if (%{$self->{opt}{body}}) {
            $request->content_type('application/json');
            $request->content($self->{json_parser}->encode($self->{opt}{body}));
        } else {
            $request->content_length(0);
        }
    } elsif ($http_method eq 'GET') {
        my $body = $self->{opt}{body} || {};
        my %q = (
            %required_param,
            %$body,
        );
        if ($arg->{key}) {
            $q{key} = $arg->{key};
        }
        $uri->query_form(\%q);
        $request = HTTP::Request->new($http_method => $uri);
    }
    if ($arg->{auth_driver}) {
        $request->header('Authorization',
            sprintf "%s %s",
                $arg->{auth_driver}->token_type,
                $arg->{auth_driver}->access_token);
    }
    my $response = $self->{ua}->request($request);
    if ($response->code == 401 && $arg->{auth_driver}) {
        $arg->{auth_driver}->refresh;
        $request->header('Authorization',
            sprintf "%s %s",
                $arg->{auth_driver}->token_type,
                $arg->{auth_driver}->access_token);
        $response = $self->{ua}->request($request);
    }
    unless ($response->is_success) {
        $self->_die_with_error($response);
    }
    if ($response->code == 204) {
        return 1;
    }
    return $response->header('content-type') =~ m!^application/json!
           ? $self->{json_parser}->decode(decode_utf8($response->content))
           : $response->content
           ;
}

sub _die_with_error {
    my ($self, $response) = @_;
    my $err_str = $response->status_line;
    if ($response->content
        && $response->header('content-type') =~ m!^application/json!) {
        my $content = $self->{json_parser}->decode(decode_utf8($response->content));
        $err_str = "$err_str: $content->{error}{message}";
    }
    die $err_str;
}

1;
__END__