File Coverage

blib/lib/WebService/Shutterstock/Client.pm

Criterion	Covered	Total	%
statement	59	74	79.7
branch	17	26	65.3
condition	5	9	55.5
subroutine	14	17	82.3
pod	5	6	83.3
total	100	132	75.7

package WebService::Shutterstock::Client;
{
  $WebService::Shutterstock::Client::VERSION = '0.006';
}

# ABSTRACT: Provides easy REST interactions with the Shutterstock API

use strict;
use warnings;
use Moo;
use JSON qw(decode_json);
use WebService::Shutterstock::Exception;

use REST::Client;
extends 'REST::Client';


sub response {
	my $self = shift;
	if(@_){
		$self->{_res} = $_[0];
	}
	return $self->{_res};
}

sub GET {
	my($self, $url, $query, $headers) = @_;
	if(ref($query) eq 'HASH'){
		$url .= $self->buildQuery(%$query);
	}
	$self->SUPER::GET($url, $headers);
	return $self->response;
}

sub DELETE {
	my($self, $url, $query, $headers) = @_;
	if(ref($query) eq 'HASH'){
		$url .= $self->buildQuery(%$query);
	}
	$self->SUPER::DELETE($url, $headers);
	return $self->response;
}

sub PUT {
	my($self, $url, $content, $headers) = @_;
	if(ref($content) eq 'HASH'){
		my $uri = URI->new();
		$uri->query_form(%$content);
		$content = $uri->query;
		$headers ||= {};
		$headers->{'Content-Type'} = 'application/x-www-form-urlencoded';
	}
	$self->SUPER::PUT($url, $content, $headers);
	return $self->response;
}

sub POST {
	my($self, $url, $content, $headers) = @_;
	if(ref($content) eq 'HASH'){
		my $uri = URI->new();
		$uri->query_form(%$content);
		$content = $uri->query;
		$headers ||= {};
		$headers->{'Content-Type'} = 'application/x-www-form-urlencoded';
	}
	$self->SUPER::POST($url, $content, $headers);
	return $self->response;
}


sub process_response {
	my $self = shift;
	my %handlers = (
		204 => sub { 1 }, # empty response, but success
		401 => sub { die WebService::Shutterstock::Exception->new(response => shift, error => "invalid api_username or api_key"); },
		@_
	);

	my $code = $self->responseCode;
	my $content_type = $self->responseHeader('Content-Type') || '';

	my $response = $self->{_res}; # blech, why isn't this public?
	my $request = $response->request;

	if(my $error = $response->header('X-Died')){
		die WebService::Shutterstock::Exception->new(
			response => $response,
			error    => sprintf( 'Transport error: %s', $error )
		);
	}

	if(my $h = $handlers{$code}){
		$h->($response);
	} elsif($code <= 299){ # a success
		return $content_type =~ m{^application/json} && $self->responseContent ? decode_json($self->responseContent) : $response->decoded_content;
	} elsif($code <= 399){ # a redirect of some sort
		return $self->responseHeader('Location');
	} elsif($code <= 499){ # client-side error
		die WebService::Shutterstock::Exception->new( response => $response, error => sprintf('%s: %s', $response->status_line, $response->decoded_content) );
	} elsif($code >= 500){ # server-side error
		die WebService::Shutterstock::Exception->new( response => $response, error => sprintf('%s: %s', $response->status_line, $response->decoded_content) );
	}
}


sub BUILD {
	my $self = shift;
	if($ENV{SS_API_DEBUG}){
		$self->getUseragent->add_handler("request_send",  sub { shift->dump(prefix => '> '); return });
		$self->getUseragent->add_handler("response_done", sub { shift->dump(prefix => '< '); return });
	}
}

1;

__END__