File Coverage

lib/XML/RPC/UA/AnyEvent.pm

Criterion	Covered	Total	%
statement	24	40	60.0
branch	0	4	0.0
condition	0	3	0.0
subroutine	8	12	66.6
pod	3	3	100.0
total	35	62	56.4

package XML::RPC::UA::AnyEvent;

use strict;
use warnings;
use HTTP::Response;
use HTTP::Headers;
use AnyEvent::HTTP 'http_request';
use Carp;

use XML::RPC::Fast ();
our $VERSION = $XML::RPC::Fast::VERSION;

=head1 NAME

XML::RPC::UA::AnyEvent - XML::RPC useragent, using AnyEvent::HTTP

=head1 SYNOPSIS

    use XML::RPC::Fast;
    use XML::RPC::UA::AnyEvent;

    my $rpc = XML::RPC::Fast->new(
        $uri,
        ua => XML::RPC::UA::AnyEvent->new(
            ua      => 'YourApp/0.1',
            timeout => 3,
        ),
    );

=head1 DESCRIPTION

Asyncronous useragent for L. Could be used in any AnyEvent application.

=head1 IMPLEMENTED METHODS

=head2 new

=head2 async = 1

=head2 call

=head1 SEE ALSO

=over 4

=item * L

Base class (also contains documentation)

=item * L

Syncronous UA using AnyEvent

=item * L

DBI of event-loop programming

=item * L

HTTP-client using AnyEvent

=back

=cut


sub async { 1 }

sub new {
	my $pkg = shift;
	my %args = @_;
	return bless \(do {my $o = $args{ua} || 'XML-RPC-Fast/'.$XML::RPC::Fast::VERSION }),$pkg;
}

sub call {
	my $self = shift;
	my ($method, $url) = splice @_,0,2;
	my %args = @_;
	$args{cb} or croak "cb required for useragent @{[%args]}";
	#warn "call";
	http_request
		$method => $url,
		headers => {
			'Content-Type'   => 'text/xml',
			'User-Agent'     => $$self,
			do { use bytes; ( 'Content-Length' => length($args{body}) ) },
			%{$args{headers} || {}},
		},
		body => $args{body},
		cb => sub {
			$args{cb}( HTTP::Response->new(
				$_[1]{Status},
				$_[1]{Reason},
				HTTP::Headers->new(%{$_[1]}),
				$_[0],
			) );
		},
	;
	return;
}

1;