File Coverage

blib/lib/Search/Elasticsearch/Cxn/Async/Simple/AEHTTP.pm

Criterion	Covered	Total	%
statement	12	15	80.0
branch	0	4	0.0
condition			n/a
subroutine	4	5	80.0
pod	0	1	0.0
total	16	25	64.0

package Search::Elasticsearch::Cxn::Async::Simple::AEHTTP;

use Moo;

use AnyEvent::HTTP qw(http_request);

use Search::Elasticsearch::Role::Is_Async::Loader ();

use namespace::clean;

with 'Search::Elasticsearch::Role::Cxn::Async::Simple',
     'Search::Elasticsearch::Role::Cxn::HTTP',
     'Search::Elasticsearch::Role::Is_Async';


sub perform_request {
	my ($self, $pars, $cb) = @_;

	my $uri  = $self->build_uri($pars);
	my $meth = $pars->{method};

	http_request(
		$meth   => $uri,
		timeout => $pars->{timeout} || $self->request_timeout,
		headers => {
			'Content-Type' => $pars->{mime_type},
			%{$self->default_headers},
		},
		body    => $pars->{data},
		sub {
			my ($code, $res);

			eval {
				($code, $res) = $self->process_response(
					$pars,
					delete($_[1]{Status}),
					delete($_[1]{Reason}),
					$_[0],
					$_[1],
				);
			};
			$cb->($@ ? () : ($code, $res));
		}
	);

	return;
}

sub error_from_text {
	return 'Timeout' if $_[2] =~ /timed out/;
	return 'Cxn'     if $_[1] >= 590;
	return 'Request';
}


1;


__END__