File Coverage

blib/lib/WebService/Leanpub.pm

Criterion	Covered	Total	%
statement	36	136	26.4
branch	4	48	8.3
condition	1	3	33.3
subroutine	9	28	32.1
pod	14	14	100.0
total	64	229	27.9

package WebService::Leanpub;

use warnings;
use strict;
use Carp;

use version; our $VERSION = qv('v0.3.1');

use HTTP::Request::Common;
use JSON;
use LWP::UserAgent;
use URI::Escape;

# Module implementation here

my $lpurl = 'https://leanpub.com/';

sub new {
    my ($self, $api_key, $slug) = @_;
    my $type = ref($self) || $self;

    unless ($api_key) { die "Missing API key for Leanpub"; }
    unless ($slug)    { die "Missing SLUG for book"; }

    $self = bless {}, $type;

    $self->{api_key} = uri_escape($api_key);
    $self->{slug}    = uri_escape($slug);
    $self->{ua}      = LWP::UserAgent->new(
	agent => "libwebservice-leanpub-perl/$VERSION",
    );
    $self->{json}    = JSON->new;

    return $self;
} # new()

#----- coupons -----
sub create_coupon {
    my ($self,$opt) = @_;

    unless ($opt->{coupon_code})	{ return; }
    unless ($opt->{discounted_price})	{ return; }
    unless ($opt->{start_date})		{ return; }

    my $var = {
	'coupon[coupon_code]'	   => $opt->{coupon_code},
	'coupon[discounted_price]' => $opt->{discounted_price},
	'coupon[start_date]'	   => $opt->{start_date},
    };

    if ($opt->{end_date}) {
	$var->{'coupon[end_date]'} = $opt->{end_date};
    }
    if ($opt->{has_uses_limit}) {
	$var->{'coupon[has_uses_limit]'} = $opt->{has_uses_limit};
    }
    if ($opt->{max_uses}) {
	$var->{'coupon[max_uses]'} = $opt->{max_uses};
    }
    if ($opt->{note}) {
	$var->{'coupon[note]'} = $opt->{note};
    }
    if ($opt->{suspended}) {
	$var->{'coupon[suspended]'} = $opt->{suspended};
    }
    return $self->_post_request( { path => '/coupons.json', var => $var } );
} # create_coupon()

sub get_coupon_list {
    my ($self) = @_;

    return $self->_get_request( { path => '/coupons.json' } );

} # get_coupon_list()

sub update_coupon {
    my ($self,$opt) = @_;

    unless ($opt->{coupon_code})    { return; }

    my $cc = delete $opt->{coupon_code};
    my $path = "/coupons/$cc.json";

    _wash_coupon_opts($opt);
    my $content = encode_json( $opt );

    return $self->_put_request( { path => $path, content => $content } );
} # update_coupon()

sub _wash_coupon_opts {
    my $opt = $_[0];
    my $bool = sub {
	return ($_[0] =~/^(no|false|0)$/i) ? 'false' : 'true';
    };
    if (exists $opt->{suspended}) {
	$opt->{suspended} = $bool->($opt->{suspended});
    }
    if (exists $opt->{has_uses_limit}) {
	$opt->{has_uses_limit} = $bool->($opt->{has_uses_limit});
    }
} # _wash_coupon_opts;

#----- sales -----

sub get_individual_purchases {
    my ($self,$opt) = @_;
    my $req = { path => '/individual_purchases.json' };
    $req->{var} = { page => $opt->{page} } if ($opt->{page});
    return $self->_get_request($req);

} # get_individual_purchases()

sub get_sales_data {
    my ($self) = @_;

    return $self->_get_request( { path => '/sales.json' } );

} # get_sales_data()

#----- jobs -----

sub get_job_status {
    my ($self) = @_;

    return $self->_get_request( { path => '/book_status.json' } );

} # get_job_status()

sub partial_preview {
    my ($self) = @_;

    return $self->_post_request( { path => '/preview/subset.json' } );
} # partial_preview()

sub preview {
    my ($self) = @_;

    return $self->_post_request( { path => '/preview.json' } );
} # preview()

sub publish {
    my ($self,$opt) = @_;
    my $var = {};

    if ($opt->{email_readers}) {
	$var->{'publish[email_readers]'} = 'true';
    }
    if (exists $opt->{release_notes}) {
	$var->{'publish[release_notes]'} = $opt->{release_notes};
    }
    return $self->_post_request( { path => '/publish.json', var => $var } );
} # publish()

sub single {
    my ($self,$opt) = @_;

    if ($opt->{content}) {
	my $json = JSON->new->encode({ 'content' => $opt->{content} });
	return $self->_json_post_request({ path => '/preview/single.json'
					 , content => $json });
    }
    else {
	return;
    }
} # single()

sub subset {
    my ($self) = @_;

    return $self->_post_request( { path => '/preview/subset.json' } );
} # subset()

sub summary {
    my ($self) = @_;

    return $self->_get_request( { path => '.json' } );
} # summary()

#----- JSON functions -----
sub pretty_json {
    my $json = $_[0]->{json};
    return $json->pretty->encode($json->decode($_[1]));
} # pretty_json()
#----- helper functions -----

sub _get_request {
    my ($self,$opt) = @_;

    my $url = $lpurl . $self->{slug} . $opt->{path}
            . '?api_key=' . $self->{api_key};
    if ($opt->{var}) {
	foreach my $var (keys %{$opt->{var}}) {
	    $url .= "&$var=" . uri_escape($opt->{var}->{$var});
	}
    }
    my $res = $self->{ua}->get($url);

    if ($res->is_success) {
	return $res->decoded_content;
    }
    return;
} # _get_request()

sub _json_post_request {
    my ($self,$opt) = @_;
    my $url  = $lpurl . $self->{slug} . $opt->{path}
             . '?api_key=' .  $self->{api_key};
    my @args = (
	'Content_Type' => 'application/json; charset=utf-8',
	'Content'      => $opt->{content},
    );
    my $res = $self->{ua}->post($url, @args);

    if ($res->is_success) {
	return $res->decoded_content;
    }
} # _json_post_request()

sub _post_request {
    my ($self,$opt) = @_;
    my $url  = $lpurl . $self->{slug} . $opt->{path};
    my $form = { api_key => $self->{api_key}, };

    if ($opt->{var}) {
	foreach my $var (keys %{$opt->{var}}) {
	    $form->{$var} = $opt->{var}->{$var};
	}
    }
    my $res = $self->{ua}->post($url, $form);

    if ($res->is_success) {
	return $res->decoded_content;
    }
    return;
} # _post_request()

sub _put_request {
    my ($self,$opt) = @_;
    my $url = $lpurl . $self->{slug} . $opt->{path}
            . '?api_key=' . $self->{api_key};

    my $req = HTTP::Request::Common::PUT($url,
	                                 'Content-Type' => 'application/json',
	                                 'Content' => $opt->{content});
    my $res = $self->{ua}->request($req);
    if ($res->is_success) {
	return $res->decoded_content;
    }
    return;
} # _put_request();

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