File Coverage

blib/lib/PX/API.pm

Criterion	Covered	Total	%
statement	15	15	100.0
branch			n/a
condition			n/a
subroutine	5	5	100.0
pod			n/a
total	20	20	100.0

package PX::API;
use warnings;
use strict;
use Carp;

use version; our $VERSION = qv('0.0.3');

use base qw/Class::Accessor::Fast/;
__PACKAGE__->mk_accessors( qw/api_key secret method args do_sign api_sig ua/ );

use LWP::UserAgent;
use PX::API::Request;
use PX::API::Response;
use Digest::MD5 qw(md5_hex);

sub new {
	my $class = shift;
	my $args  = shift;

	$class = ref($class) || $class;
	my $self = bless {}, $class;

	my $ua = LWP::UserAgent->new(agent => $self->_agent, timeout => 60);
	$self->ua($ua);
	$self->api_key($args->{'api_key'});
	$self->secret($args->{'secret'});
	warn "No API key present!!" unless ($self->api_key);

	return $self;
	}

sub call {
	my $self = shift;
	my $meth = shift;
	my $args = shift;

	$self->args($args);
	my $req = PX::API::Request->new({
				method  => $meth,
				args	=> $args,
				});
	$self->execute_request($req);
	}

sub execute_request {
	my $self = shift;
	my $req  = shift;

	$req->{'args'}->{'api_key'} = $self->api_key;
	$req->{'args'}->{'api_sig'} = $self->_sign_args($req->{'args'}) if $self->do_sign;

	my $uri = $req->uri;
	$uri .= "?" . $self->_query_string($req->{'args'});
	$req->uri($uri);
	my $resp = $self->ua->request($req);
	bless $resp, 'PX::API::Response';
	$resp->_init({format => $req->{'args'}->{'format'}});

	if ($resp->{'_rc'} != 200) {
		$resp->fault(0,"API returned status code ($resp->{_rc})");
		return $resp;
		}

	my $parser = $resp->{'parser'};
	my $ref = $parser->parse($resp->{'_content'});
	$resp->fault(0,"Error parsing server response") if (!defined $ref->{response});

	my $stat = $ref->{response}->{status} if defined $ref->{response}->{status};
	if ($stat eq "error") {
		my $error = $ref->{response}->{content}->{error};
		$resp->fault(0,"($error->{err_code}) $error->{err_string}");
		return $resp;
		}

	if ($ref->{response}->{status} eq "ok") {
		$resp->success($ref->{response});
		return $resp;
		}

	$resp->fault(0,"API returned an invalid status code");
	return $resp;
	}

sub auth_url {
	my $self = shift;
	my $perms = shift;
	return undef unless defined $self->secret;

	my $args = {
		api_key => $self->api_key,
		perms	=> $perms,
		};

	my $sig = $self->_sign_args($args);
	$args->{api_sig} = $sig;

	my $q = $self->_query_string($args);
	my $uri = "http://services.peekshows.com/auth?" . $q;
	return $uri;
	}

sub _sign_args {
	my $self = shift;
	my $args = shift;

	my $sig = $self->secret;
	foreach my $k(sort {$a cmp $b} keys %{$args}) {
		$sig .= $k . $args->{$k};
		}
	return md5_hex($sig);
	}

sub _query_string {
	my $self = shift;
	my $args = shift;

	my @pairs;
        foreach my $k(keys %{$args}) {
                my $kv = $k . "=" . $args->{$k};
                push(@pairs,$kv);
                }
        my $q = join("&",@pairs);
	return $q;
	}

sub _agent { __PACKAGE__ . "/" . $VERSION }


1;
__END__