File Coverage

blib/lib/POE/Component/Omegle.pm

Criterion	Covered	Total	%
statement	27	51	52.9
branch			n/a
condition			n/a
subroutine	9	19	47.3
pod	0	1	0.0
total	36	71	50.7

package POE::Component::Omegle;

use 5.006000;
use strict;
use warnings;

use POE;

our $VERSION = '0.02';

sub new {
    my $class = shift;
    my @args = @_;

    my $self = {
        session => POE::Session->create(
            package_states => [
                                  OMSession => [qw/_start _stop start_chat say disconnect set_callback
                                                on_event_handled poke/],
                              ],
            args => \@args,
        ),
    };

    bless $self, $class;
    return $self;
}

sub AUTOLOAD {
    my $self = shift;

    use vars qw($AUTOLOAD);
    my $state = $AUTOLOAD;
    $state =~ s/.*:://;
    $poe_kernel->post( $self->{session} => $state => @_ );
}


#####

package OMSession;

use strict;
use warnings;

use POE;
use WWW::Omegle;


sub _start {
    my ($kernel, $sender, $heap, $session, %args) = @_[KERNEL, SENDER, HEAP, SESSION, ARG0..$#_];

    my $om = $heap->{om} = new WWW::Omegle();
    $kernel->yield(set_callback => 'event_handled', $session->postback('on_event_handled'));
}

sub set_callback {
    my ($sender, $heap, $callback, $state, @extra) = @_[SENDER, HEAP, ARG0, ARG1, ARG2..$#_];
    $heap->{om}->set_callback($callback => $sender->postback($state), @extra);
}

sub _stop {}

# initiate a convo
sub start_chat {
    my ($kernel, $sender, $heap, $pb) = @_[KERNEL, SENDER, HEAP, ARG0];

    $heap->{om}->start;
}

sub poke {
    my ($kernel, $sender, $heap) = @_[KERNEL, SENDER, HEAP];
    $heap->{om}->poke;
}

sub on_event_handled {
    my ($sender, $heap, $success) = @_[SENDER, HEAP, ARG0];
}

sub say {
    my ($sender, $heap, $msg) = @_[SENDER, HEAP, ARG0];
    $heap->{om}->say($msg);
}

sub disconnect {
    my ($sender, $heap) = @_[SENDER, HEAP];
    $heap->{om}->disconnect;
}

1;
__END__