File Coverage

blib/lib/WebService/Wedata.pm

Criterion	Covered	Total	%
statement	16	18	88.8
branch			n/a
condition			n/a
subroutine	6	6	100.0
pod			n/a
total	22	24	91.6

package WebService::Wedata;

use warnings;
use strict;
use Carp;
use LWP::UserAgent;
use JSON::XS;
use WebService::Wedata::Database;

use version; our $VERSION = qv('0.0.4');
our $URL_BASE = 'http://wedata.net';

sub new {
    my($class, $api_key) = @_;
    bless {
        ua => LWP::UserAgent->new,
        api_key => $api_key,
    }, $class;
}

sub get_databases {
    my($self) = @_;
    $self->get_database;
}

sub get_database {
    my($self, $dbname, $page) = @_;
    my $path = ($dbname) ? "/databases/$dbname.json" : '/databases.json';
    $page ||= '';
    my $url = $URL_BASE . $path;
    my $response = $self->{ua}->get($url, page => $page);
    if ($response->is_success) {
        my $data = decode_json($response->content);
        my $parse_response = sub {
            my($data) = @_;
            my @required_keys = split / /, $data->{required_keys};
            my @optional_keys = (defined $data->{optional_keys}) ? split / /, $data->{optional_keys} : ();
            my $database = WebService::Wedata::Database->new(
                ua => $self->{ua},
                api_key => $self->{api_key},
                name => $data->{name},
                description => $data->{description},
                resource_url => $data->{resource_url},
                required_keys => [@required_keys],
                optional_keys => [@optional_keys],
                permit_other_keys => $data->{permit_other_keys},
            );
            $database;
        };
        if ($dbname) {
            $parse_response->($data);
        }
        else {
            my $result = [];
            foreach my $db (@$data) {
                push @$result, $parse_response->($db);
            }
            $result;
        }
    }
    else {
        croak 'Faild to get_database:' . $response->status_line;
    }
}

sub create_database {
    my($self, @params) = @_;
    my $params = {@params};
    croak "require name on create_database\n" unless $params->{name};

    my $param_description = $params->{description} || '';
    my $param_required_keys = join '%20', @{$params->{required_keys}};
    my $param_optional_keys = join '%20', @{$params->{optional_keys}};
    my $param_permit_other_keys = ($params->{permit_other_keys}) ? 'true' : 'false';

    my $url = $URL_BASE . '/databases';
    my $content = '';
    $content = join '&',
        "api_key=$self->{api_key}",
        "database[name]=$params->{name}",
        "database[description]=$param_description",
        "database[required_keys]=$param_required_keys",
        "database[optional_keys=$param_optional_keys",
        "database[permit_other_keys]=$param_permit_other_keys"
    ;
    my $req = HTTP::Request->new(
        POST => $url,
        HTTP::Headers->new(
            'content-type' => 'application/x-www-form-urlencoded',
            'content-length' => length($content),
        ),
        $content,
    );

    my $response = $self->{ua}->request($req);
    if ($response->is_success) {
        my $database = WebService::Wedata::Database->new(
            ua => $self->{ua},
            api_key => $self->{api_key},
            name => $params->{name},
            description => $params->{description},
            required_keys => $params->{required_keys},
            optional_keys => $params->{optional_keys},
            permit_other_keys => ($params->{permit_other_keys} == 1) ? 1 : 0,
            resource_url => $response->header('location'),
        );
        $database;
    }
    else {
        croak 'Faild to create_database:' . $response->status_line;
    }
}

sub update_database {
    my($self, @params) = @_;
    my $params = {@params};
    croak "require name on create_database\n" unless $params->{name};

    $params->{api_key} = $self->{api_key};
    $params->{resource_url} = $URL_BASE . '/databases/' . $params->{name};
    my $req = WebService::Wedata::Database::_make_update_request($params);

    my $response = $self->{ua}->request($req);
    if ($response->is_success) {
        $self->get_database($params->{name});
    }
    else {
        croak 'Faild to update_database:' . $response->status_line;
    }
}

sub delete_database {
    my($self, @params) = @_;
    my $params = {@params};
    croak "require name on create_database\n" unless $params->{name};

    $params->{api_key} = $self->{api_key};
    my $req = WebService::Wedata::Database::_make_delete_request($params);
    my $response = $self->{ua}->request($req);
    if ($response->is_success) {
        return;
    }
    else {
        croak 'Faild to delete_database:' . $response->status_line;
    }
}


1; # Magic true value required at end of module
__END__