File Coverage

blib/lib/POE/Component/WWW/CPANRatings/RSS.pm

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

package POE::Component::WWW::CPANRatings::RSS;

use warnings;
use strict;

our $VERSION = '0.0101';

use POE;
use base 'POE::Component::NonBlockingWrapper::Base';
use WWW::CPANRatings::RSS;

sub _methods_define {
    return (
        fetch => '_wheel_entry',
        stop_repeat => '_stop_repeat',
    );
}

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

sub stop_repeat {
    $poe_kernel->call( shift->{session_id} => stop_repeat => @_ );
}

sub _stop_repeat {
    my ( $kernel, $self, $repeat_name ) = @_[ KERNEL, OBJECT, ARG0 ];
    return
        unless exists $self->{timers}{ $repeat_name };

    $kernel->refcount_decrement(
        $self->{timers}{ $repeat_name }{session}
        =>'POE::Component::NonBlockingWrapper::Base'
    );

    $kernel->alarm_remove( $_ )
        for @{ $self->{timers}{ $repeat_name }{timers} };

    delete $self->{timers}{ $repeat_name };
}

sub _prepare_wheel {
    my $self = shift;
    $self->{obj} = WWW::CPANRatings::RSS->new(
        $self->{ua} ? ( ua => $self->{ua} ) : ()
    );
}

sub _process_request {
    my ( $self, $req_ref ) = @_;

    my $method = $req_ref->{unique} ? 'fetch_unique' : 'fetch';
    my $ratings_ref = $self->{obj}->$method(
        $method eq 'fetch_unique' ? $req_ref->{file} : ()
    );

    if ( $ratings_ref ) {
        $req_ref->{ratings} = $ratings_ref;
        delete $req_ref->{error};
    }
    else {
        $req_ref->{error} = $self->{obj}->error;
    }
}

sub _child_stdout {
    my ( $kernel, $self, $input ) = @_[ KERNEL, OBJECT, ARG0 ];

    delete $input->{session};
    my $session = delete $input->{sender};
    my $event   = delete $input->{event};

    if ( $input->{repeat} ) {
        my $repeat_name = $input->{repeat_name} || 'GENERAL';

        $kernel->refcount_increment( $session =>'POE::Component::NonBlockingWrapper::Base' );

        if ( exists $self->{timers}{ $repeat_name } ) {
            $kernel->refcount_decrement( $session =>'POE::Component::NonBlockingWrapper::Base' );
            $kernel->alarm_remove( $_ )
                for @{ $self->{timers}{ $repeat_name }{timers} || [] };

            delete $self->{timers}{ $repeat_name };
        }

        push @{ $self->{timers}{ $repeat_name }{timers} },
            $kernel->delay_set(
                fetch => $input->{repeat} => {
                    %$input,
                    session => $session,
                    event   => $event,
                }
            );

        $self->{timers}{ $repeat_name }{session} = $session;
    }

    $kernel->post( $session, $event, $input );
    $kernel->refcount_decrement( $session =>'POE::Component::NonBlockingWrapper::Base' );

    undef;
}

sub _shutdown {
    my ( $kernel, $self ) = @_[ KERNEL, OBJECT ];
    for my $timer ( values %{ $self->{timers} } ) {
        $kernel->refcount_decrement( $timer->{session} =>'POE::Component::NonBlockingWrapper::Base');
        $kernel->alarm_remove( $_ )
            for @{ $timer->{timers} || [] };
    }
    delete $self->{timers};
    $kernel->alarm_remove_all;
    $kernel->alias_remove( $_ ) for $kernel->alias_list;
    $kernel->refcount_decrement( $self->{session_id} => 'POE::Component::NonBlockingWrapper::Base' )
        unless $self->{alias};

    $self->{shutdown} = 1;

    $self->{wheel}->shutdown_stdin
        if $self->{wheel};
}

1;
__END__