File Coverage

blib/lib/WWW/Google/Groups.pm

Criterion	Covered	Total	%
statement	29	69	42.0
branch	4	22	18.1
condition	1	8	12.5
subroutine	8	11	72.7
pod	0	4	0.0
total	42	114	36.8

# $Id: Groups.pm,v 1.18 2004/01/03 19:09:42 cvspub Exp $
package WWW::Google::Groups;

use strict;
our $VERSION = '0.09';

use Data::Dumper;

use WWW::Google::Groups::NewsGroup;
use WWW::Google::Groups::Vars;

use WWW::Google::Groups::Search;
our @ISA = qw(WWW::Google::Groups::Search);

use WWW::Mechanize;


# ----------------------------------------------------------------------
sub new {
    my $pkg = shift;
    my %arg = @_;
    foreach my $key (qw(server proxy)){
	next unless $arg{$key};
	$arg{$key} = 'http://'.$arg{$key} if $arg{$key} !~ m,^\w+?://,o;
    }

    my $a = new WWW::Mechanize onwarn => undef, onerror => undef;
    $a->proxy(['http'], $arg{proxy}) if $arg{proxy};

    bless {
	_server => ($arg{server} || 'http://groups.google.com/'),
	_proxy => $arg{proxy},
	_agent => $a,
    }, $pkg;
}

# ----------------------------------------------------------------------
sub select_group($$) { new WWW::Google::Groups::NewsGroup(@_) }


# ----------------------------------------------------------------------
use Date::Parse;
sub save2mbox {
    my $self = shift;
    my %arg = @_;
    my $article_count = 0;
    my $thread_count = 0;
    my $max_article_count = $arg{max_article_count};
    my $max_thread_count = $arg{max_thread_count};

    my $group = $self->select_group($arg{group});
    $group->starting_thread($arg{starting_thread});

    open F, '>', $arg{target_mbox} or die "Cannot create mbox $arg{target_mbox}";
  MIRROR:
    while( my $thread = $group->next_thread() ){
	while( my $article = $thread->next_article() ){
#	    print join q/ /, map{$article->header($_)} qw(From Date Subject);
#	    print $/;
	    my $email;
	    $article->header("From")=~ /\s*(?:[<\(])(.+?@.+?)(?:[>\)])\s*/;
	    unless($1){
		$article->header("From")=~ /\s*(.+?@.+?)\s/o;
		$email = $1;
	    }
	    else {
		$email = $1;
	    }
	    my $date = scalar localtime str2time($article->header("Date"));
	    my $content = $article->as_string;
	    $content = "From $email $date\n".$content;
	    print F $content;
	    $article_count++;
	    last MIRROR if
		defined($max_article_count) and
		$article_count >= $max_article_count;
        }
	$thread_count++;
	last MIRROR if
	    defined($max_thread_count) and
	    $thread_count >= $max_thread_count;
    }
    close F;
}


# ----------------------------------------------------------------------
sub post {
    my $self = shift;
    my %arg = @_;

    $self->{_agent}->get("http://posting.google.com/post?cmd=post&enc=ISO-8859-1&group=$arg{group}&gs=/groups%3Fhl%3Den%26lr%3D%26ie%3DUTF-8%26oe%3DUTF-8%26group%3D$arg{group}");
    return unless $self->{_agent}->success();

    $self->{_agent}->submit_form(
				 form_number => 1,
				 fields      => {
				     Email    => $arg{email},
				     Passwd   => $arg{passwd},
				 }
				 );
    return unless $self->{_agent}->success();

    $self->{_agent}->content=~/location\.replace\("(.+?)"\)/o;
    $self->{_agent}->get("$1");
    return unless $self->{_agent}->success();

    $self->{_agent}->submit_form(
				 form_number => 1,
				 fields      => {
				     group    => $arg{group},
				     subject   => $arg{subject},
				     body      => $arg{message},
				 },
				 button    => 'actYes',
				 );
    return unless $self->{_agent}->success();

    $self->{_agent}->follow_link( text_regex => qr/Sign out/i );
    1;
}


1;
__END__