File Coverage

blib/lib/XiaoI.pm

Criterion	Covered	Total	%
statement	33	74	44.5
branch	1	14	7.1
condition	0	3	0.0
subroutine	9	15	60.0
pod	0	7	0.0
total	43	113	38.0

package XiaoI;

use 5.008005;
use strict;
use warnings;
use JSON;
require Exporter;

our @ISA = qw(Exporter);

our $VERSION = '0.03';


# Preloaded methods go here.
use LWP::UserAgent;
use Encode qw/encode decode/;
use Data::Dumper;
sub new {
    my ($class) = @_;
    my $ua = LWP::UserAgent->new;
    $ua->cookie_jar({});

    my $self = {ua => $ua};
    bless $self, $class;
    $self->login;
    return $self;
}



sub login {
    my $self = shift;
    my $ua = $self->{ua};
    my $login_page = $ua->get('http://webbot.xiaoi.com/engine/flashrobot2/webbot.js?encoding=utf-8')->content;
    if ($login_page =~ m{L_IDS_SEND_MESSAGE_URL\s*=\s*"(.*?)";.*?L_IDS_RECV_MESSAGE_URL\s*=\s*"(.*?)";.*?L_IDS_GET_RESOURCE_URL\s*=\s*"(.*?)";.*?__sessionId\s*=\s*"(.*?)";}is) {
        my ($send_url, $recv_url, $resource_url, $sessionid) = ($1, $2, $3, $4);
        $self->{send_url} = $send_url;
        $self->{recv_url} = $recv_url;
        $self->{resource_url} = $resource_url;
        $self->{sessionid} = $sessionid;
        my $res = $ua->get( $self->join_url());

        $self->{last_login_time} = time;
    } else {
        print "login failed\n";
    }
}

sub check_need_login {
    my $self = shift;
    if (time - $self->{last_login_time} > 60 * 60 * 5 ) {
        $self->login;
    }
}

sub get_robot_text {
    my $self = shift;
    my $msg = shift;
    my $try_times = 5;
    my $text;
    for (1..$try_times) {
        $text = $self->_invoke_robot($msg);
        if ($text eq '') {
            $self->login;
        } else {
            last;
        }
    }
    return $text;
}
sub _invoke_robot {
    my $self = shift;
    my $msg = shift;

    #$self->check_need_login;
    my $ua = $self->{ua};
    my $res = $ua->get( $self->send_message_url($msg));
    return '' if ($res->code ne '200');
    $res = $ua->get( $self->recv_message_url());
    return '' if ($res->code ne '200');
    my $text = $res->content;
    if ($text =~ m{processMessageReceived\((.*)\)}s) {
        my $json_text = $1;
        my $ra = JSON->new->utf8(0)->decode($json_text);
        if (@$ra > 0  and $ra->[0]->{CMD} eq 'CHAT') {
            return  encode('utf8', decode('utf8', $ra->[0]->{MSG}) );
        }
    }

    return '';
}


sub join_url {
    my $self = shift;
    my $url = sprintf('%sSID=%s&USR=%s&CMD=JOIN&r=0.%s', $self->{send_url}, $self->{sessionid}, $self->{sessionid}, int(rand(100000)));

}

sub send_message_url {
    my $self = shift;
    my $msg = shift;
    my $url = sprintf('%sSID=%s&USR=%s&CMD=CHAT&MSG=%s&r=0.%s', $self->{send_url}, $self->{sessionid}, $self->{sessionid}, $msg, int(rand(100000)));

}

sub recv_message_url {
    my $self = shift;

    my $url = sprintf('%sSID=%s&USR=%s&r=0.%s', $self->{recv_url}, $self->{sessionid}, $self->{sessionid},int(rand(100000)) );

}

1;
__END__