File Coverage

blib/lib/WWW/ShipStation.pm

Criterion	Covered	Total	%
statement	23	104	22.1
branch	0	36	0.0
condition	0	11	0.0
subroutine	8	26	30.7
pod	14	17	82.3
total	45	194	23.2

package WWW::ShipStation;

use strict;
use 5.008_005;
our $VERSION = '0.05';

use LWP::UserAgent;
use JSON;
use Carp 'croak';
use URI::Escape qw/uri_escape/;
use HTTP::Request;

sub new {
    my $class = shift;
    my %args  = @_ % 2 ? %{$_[0]} : @_;

    $args{user} or croak "user is required.";
    $args{pass} or croak "pass is required.";

    $args{ua} ||= LWP::UserAgent->new();
    $args{json} ||= JSON->new->allow_nonref->utf8;

    $args{API_BASE} ||= 'https://ssapi.shipstation.com/';

    bless \%args, $class;
}

sub getCarriers {
    (shift)->request('carriers');
}

sub getCustomer {
    my ($self, $customerId) = @_;
    $self->request("customers/$customerId");
}

sub getCustomers {
    my $self = shift;
    my %args = @_ % 2 ? %{$_[0]} : @_;
    $self->request('customers', %args);
}

sub getOrder {
    my ($self, $orderId) = @_;
    $self->request("orders/$orderId");
}

sub getOrders {
    my $self = shift;
    my %args = @_ % 2 ? %{$_[0]} : @_;
    $self->request('orders', %args);
}

sub getProduct {
    my ($self, $productId) = @_;
    $self->request("products/$productId");
}

sub getProducts {
    my $self = shift;
    my %args = @_ % 2 ? %{$_[0]} : @_;
    $self->request('products/', %args);
}

sub getShipments {
    my $self = shift;
    my %args = @_ % 2 ? %{$_[0]} : @_;
    $self->request('shipments', %args);
}

sub getMarketplaces {
    my $self = shift;
    my %args = @_ % 2 ? %{$_[0]} : @_;
    $self->request('stores/marketplaces', %args);
}

sub getStores {
    my $self = shift;
    my %args = @_ % 2 ? %{$_[0]} : @_;
    $self->request('stores', %args);
}

sub getStore {
    my ($self, $storeId) = @_;
    $self->request("stores/$storeId");
}

sub getWarehouses {
    my $self = shift;
    my %args = @_ % 2 ? %{$_[0]} : @_;
    $self->request('warehouses', %args);
}

sub getWarehouse {
    my ($self, $warehouseId) = @_;
    $self->request("warehouses/$warehouseId");
}

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

    if (%params and keys %params) {
        $url .= '?' . join('&', map { join('=', $_, uri_escape($params{$_})) } keys %params);
    }

    my $req = HTTP::Request->new(GET => $self->{API_BASE} . $url);
    $req->authorization_basic($self->{user}, $self->{pass});
    $req->header('Accept', 'application/json'); # JSON is better
    my $res = $self->{ua}->request($req);
    use Data::Dumper; print STDERR Dumper(\$res);
    if ($res->header('Content-Type') =~ m{application/json}) {
        return $self->{json}->decode($res->decoded_content);
    }
    unless ($res->is_success) {
        return {
            'error' => {
                'code' => '',
                'message' => {
                    'lang' => 'en-US',
                    'value' => $res->status_line,
                }
            }
        };
    }
}

sub createOrder {
    my $self = shift;
    my %args = @_ % 2 ? %{$_[0]} : @_;
    $self->__request('POST', 'orders/createorder', $self->{json}->encode(\%args));
}

sub deleteOrder {
    my ($self, $orderID) = @_;

    $self->__request('DELETE', "orders/$orderID");
}

sub __request {
    my ($self, $method, $url, $content) = @_;

    my $req = HTTP::Request->new($method => $self->{API_BASE} . $url);
    $req->authorization_basic($self->{user}, $self->{pass});
    $req->header('Accept', 'application/json'); # JSON is better
    $req->header('Accept-Charset' => 'UTF-8');
    if ($method eq 'POST') {
        $req->header('Content-Type' => 'application/json');
    }
    $req->content($content) if $content;

    my $res = $self->{ua}->request($req);
    # use Data::Dumper; print STDERR Dumper(\$res);
    if ($res->header('Content-Type') =~ m{application/json}) {
        return $self->{json}->decode($res->decoded_content);
    }
    unless ($res->is_success) {
        return {
            'error' => {
                'code' => '',
                'message' => {
                    'lang' => 'en-US',
                    'value' => $res->status_line
                }
            }
        };
    }
    return $res->decoded_content;
}

1;
__END__