File Coverage

blib/lib/POE/Component/WWW/Alexa/TrafficRank.pm

Criterion	Covered	Total	%
statement	17	28	60.7
branch	0	6	0.0
condition	0	2	0.0
subroutine	7	9	77.7
pod	1	1	100.0
total	25	46	54.3

package POE::Component::WWW::Alexa::TrafficRank;

use warnings;
use strict;

our $VERSION = '1.001004'; # VERSION

use POE;
use base 'POE::Component::NonBlockingWrapper::Base';
use WWW::Alexa::TrafficRank;

sub _methods_define {
    return ( rank => '_wheel_entry' );
}

sub rank {
    $poe_kernel->post( shift->{session_id} => rank => @_ );
}

sub _prepare_wheel {
    my $self = shift;
    $self->{timeout} ||= 30;
    $self->{obj} = WWW::Alexa::TrafficRank->new(
        map { defined $self->{$_} ? ( $_ => $self->{$_} ) : () }
            qw/agent  proxy  timeout/
    );
}

sub _process_request {
    my ( $self, $in_ref ) = @_;
    $in_ref->{uri} =~ s{^(?:ht|f)tps?://|/$}{}gi;
    $in_ref->{rank} = $self->{obj}->get( $in_ref->{uri} );
    if ( not length $in_ref->{rank} ) {
        $in_ref->{error} = 'No result';
        delete $in_ref->{rank};
    }
    elsif ( $in_ref->{rank} !~ /^[\d,]+$/ ) {
        $in_ref->{error} = delete $in_ref->{rank};
    }
}

1;
__END__