File Coverage

blib/lib/POE/Component/WWW/Cache/Google.pm

Criterion	Covered	Total	%
statement	20	46	43.4
branch	0	14	0.0
condition	0	3	0.0
subroutine	8	9	88.8
pod	1	1	100.0
total	29	73	39.7

package POE::Component::WWW::Cache::Google;

use warnings;
use strict;

our $VERSION = '1.001004'; # VERSION

use POE;
use base 'POE::Component::NonBlockingWrapper::Base';
use WWW::Cache::Google;
use LWP::UserAgent;

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

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

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

    my $cache = WWW::Cache::Google->new( $in_ref->{uri} );

    $in_ref->{cache} = $cache->cache;

    if ( $in_ref->{fetch} ) {
        my $ua = LWP::UserAgent->new(
            agent   => 'Mozilla/5.0 (X11; Ubuntu; Linux i686; rv:21.0) '
             . 'Gecko/20100101 Firefox/21.0',
             # trick google into not giving us 403s
            timeout => 30,
            max_size => $in_ref->{max_size},
        );

        my $response = $ua->get( $in_ref->{cache} );
        if ( not $response->is_success ) {
            $in_ref->{error} = $response->status_line;
            if ( $in_ref->{error} eq '404 Not Found' ) {
                $in_ref->{error} = q|Doesn't look like cache exists|;
            }
            return;
        }

        $in_ref->{content} = $response->content;
        if ( $in_ref->{content} !~ /
            $in_ref->{error} = q|Doesn't look like cache exists|;
            return;
        }
    }

    if ( ref $in_ref->{fetch} eq 'SCALAR' ) {

        my $filename = ${ $in_ref->{fetch} };

        if ( -e $filename and not $in_ref->{overwrite} ) {
            $in_ref->{error} = "File `$filename` already exists";
            return;
        }

        if ( open my $fh, '>', $filename ) {
            print $fh delete $in_ref->{content}, "\n";
            close $fh;
        }
        else {
            $in_ref->{error} = "Failed to open `$filename` for writing [$!]";
        }
    }

    return;
}

1;
__END__