File Coverage

blib/lib/WebService/Hatena/Graph.pm

Criterion	Covered	Total	%
statement	18	77	23.3
branch	0	24	0.0
condition	0	3	0.0
subroutine	6	20	30.0
pod	7	12	58.3
total	31	136	22.7

package WebService::Hatena::Graph;

use strict;
use warnings;
use Carp qw(croak);

use URI;
use JSON::Any;
use LWP::UserAgent;

our $VERSION = '0.08';

our $GraphHost = 'graph.hatena.ne.jp:80';

sub new {
    my ($class, %args) = @_;
    my %param;
    if (defined $args{access_token}) {
        @param{qw(
            access_token access_token_secret
            consumer_key consumer_secret
        )} = @args{qw(
            access_token access_token_secret
            consumer_key consumer_secret
        )};
    } else {
        croak ('Both username and password are required.')
            if (!defined $args{username} || !defined $args{password});
    }

    my $ua = LWP::UserAgent->new(agent => __PACKAGE__."/$VERSION");
       $ua->credentials($GraphHost, '', @args{qw(username password)});
    $param{ua} = $ua;

    return bless \%param, $class;
}

sub ua { shift->{ua} }

sub use_oauth {
    return defined $_[0]->access_token;
}

sub consumer_key { $_[0]->{consumer_key} }
sub consumer_secret { $_[0]->{consumer_secret} }
sub access_token { $_[0]->{access_token} }
sub access_token_secret { $_[0]->{access_token_secret} }


# This method remains only for backward compatibility (less or equal
# version 0.04). Use post_data() method instead.
sub post {
    my ($self, %args) = @_;
    return $self->post_data(%args);
}

sub post_data {
    my ($self, %args) = @_;

    croak ('Graphname parameter must be passed in.')
        if !defined $args{graphname};

    my $res = $self->_post('http://'.$GraphHost.'/api/data', %args);

    croak (sprintf "%d: %s", $res->code, $res->message)
        if $res->code != 201;

    return 1;
}

sub get_data {
    my ($self, %args) = @_;

    croak ('Graphname parameter must be passed in.')
        if !defined $args{graphname};

    my $res = $self->_get('http://'.$GraphHost.'/api/data', (%args, type => 'json'));

    croak (sprintf "%d: %s", $res->code, $res->message)
        if $res->code != 200;

    return JSON::Any->jsonToObj($res->content);
}

sub post_config {
    my ($self, %args) = @_;

    croak ('Graphname parameter must be passed in.')
        if !defined $args{graphname};

    my $res = $self->_post('http://'.$GraphHost.'/api/config', %args);

    croak (sprintf "%d: %s", $res->code, $res->message)
        if $res->code != 201;

    return 1;
}

sub get_config {
    my ($self, %args) = @_;

    croak ('Graphname parameter must be passed in.')
        if !defined $args{graphname};

    my $res = $self->_get('http://'.$GraphHost.'/api/config', (%args, type => 'json'));

    croak (sprintf "%d: %s", $res->code, $res->message)
        if $res->code != 200;

    return JSON::Any->jsonToObj($res->content);
}

sub _get {
    my ($self, $url, %params) = @_;
    my $uri;

    if ($self->use_oauth) {
        require OAuth::Lite::Consumer;
        require OAuth::Lite::Token;
        require OAuth::Lite::AuthMethod;

        my $consumer = OAuth::Lite::Consumer->new(
            consumer_key => $self->consumer_key,
            consumer_secret => $self->consumer_secret,
            auth_method => OAuth::Lite::AuthMethod::URL_QUERY(),
        );
        my $access_token = OAuth::Lite::Token->new(
            token => $self->access_token,
            secret => $self->access_token_secret,
        );

        $uri = $url . '?' . $consumer->gen_auth_query('GET', $url, $access_token, \%params);
    } else {
        $uri = URI->new($url);
        $uri->query_form(%params);
    }

    return $self->ua->get($uri);
}

sub _post {
    my ($self, $url, %params) = @_;

    if ($self->use_oauth) {
        require OAuth::Lite::Consumer;
        require OAuth::Lite::Token;
        require OAuth::Lite::AuthMethod;

        my $consumer = OAuth::Lite::Consumer->new(
            consumer_key => $self->consumer_key,
            consumer_secret => $self->consumer_secret,
            auth_method => OAuth::Lite::AuthMethod::POST_BODY(),
        );
        my $access_token = OAuth::Lite::Token->new(
            token => $self->access_token,
            secret => $self->access_token_secret,
        );
        my $oauth_req = $consumer->gen_oauth_request(
            method => 'POST',
            url => $url,
            token => $access_token,
            params => \%params,
        );
        return $self->ua->post(
            $url,
            'Content-Type' => 'application/x-www-form-urlencoded',
            Content => $oauth_req->content,
        );
    } else {
        return $self->ua->post($url, \%params);
    }
}

1;

__END__