File Coverage

lib/WebService/Qiita/Client/Base.pm

Criterion	Covered	Total	%
statement	62	62	100.0
branch	14	14	100.0
condition	9	12	75.0
subroutine	17	17	100.0
pod	0	5	0.0
total	102	110	92.7

package WebService::Qiita::Client::Base;
use strict;
use warnings;
use utf8;

use Carp qw(croak);
use LWP::UserAgent;
use JSON;
use HTTP::Request;
use URI;

use Class::Accessor::Lite (
    new => 1,
    rw => [qw(
        url_name
        password
        token
    )],
);

use constant {
    ROOT_URL    => 'https://qiita.com',
    PREFIX_PATH => '/api/v1',
};

sub agent {
    my $self = shift;
    my $options = {
        ssl_opts => { verify_hostname => 0 },
        timeout  => 10,
    };
    $self->{agent} ||= LWP::UserAgent->new(%$options);
}

sub get {
    my ($self, $path, $params) = @_;
    $self->_request('GET', $path, $params);
}

sub post {
    my ($self, $path, $params) = @_;
    $self->_request('POST', $path, $params);
}

sub put {
    my ($self, $path, $params) = @_;
    $self->_request('PUT', $path, $params);
}

sub delete {
    my ($self, $path, $params) = @_;
    $self->_request('DELETE', $path, $params);
}

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

    my $url = ROOT_URL . PREFIX_PATH . $path;
    $params->{token} = $self->token if $self->token;

    my $request = HTTP::Request->new("$method" => $url);
    $request->content_type('application/json');

    if ($method eq 'GET' || $method eq 'DELETE') {
        my $uri = URI->new($url);
        $uri->query_form(%$params);
        $request->uri($uri->as_string);
    } elsif ($method eq 'POST' || $method eq 'PUT') {
        $request->content(JSON::encode_json $params);
    } else {
        croak "invalid http method: $method";
    }

    my $response = agent->request($request);
    croak _error_message($response, $method, $url) if $response->is_error;

    $response->content ? JSON::decode_json($response->content) : "";
}

sub _error_message {
    my ($response, $method, $url) = @_;

    my $content = $response->content;
    if ($content) {
        my $json = eval { JSON::decode_json($content) };
        return $json->{error} if $json && $json->{error};
    }
    sprintf "%s %s: %d", $method, $url, $response->code;
}

1;