1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148
|
use strict;
use warnings FATAL => 'all';
use lib 't/inc';
use POE;
use POE::Component::IRC::State;
use POE::Component::IRC::Plugin::AutoJoin;
use POE::Component::Server::IRC;
use Test::More tests => 10;
my $bot1 = POE::Component::IRC::State->spawn(
Flood => 1,
plugin_debug => 1,
);
my $bot2 = POE::Component::IRC::State->spawn(
Flood => 1,
plugin_debug => 1,
AwayPoll => 1,
);
my $ircd = POE::Component::Server::IRC->spawn(
Auth => 0,
AntiFlood => 0,
);
POE::Session->create(
package_states => [
main => [qw(
_start
ircd_listener_add
ircd_listener_failure
_shutdown
irc_001
irc_join
irc_chan_sync
irc_user_away
irc_user_back
irc_disconnected
)],
],
);
$poe_kernel->run();
sub _start {
my ($kernel) = $_[KERNEL];
$ircd->yield('register', 'all');
$ircd->yield('add_listener');
$kernel->delay(_shutdown => 60, 'Timed out');
}
sub ircd_listener_failure {
my ($kernel, $op, $reason) = @_[KERNEL, ARG1, ARG3];
$kernel->yield('_shutdown', "$op: $reason");
}
sub ircd_listener_add {
my ($kernel, $port) = @_[KERNEL, ARG0];
$bot1->yield(register => 'all');
$bot1->yield(connect => {
nick => 'TestBot1',
server => '127.0.0.1',
port => $port,
});
$bot2->yield(register => 'all');
$bot2->yield(connect => {
nick => 'TestBot2',
server => '127.0.0.1',
port => $port,
});
}
sub irc_001 {
my $irc = $_[SENDER]->get_heap();
pass($irc->nick_name . ' logged in');
if ($irc == $bot1) {
$irc->yield(join => '#testchannel');
}
}
sub irc_join {
my ($sender, $who, $where) = @_[SENDER, ARG0, ARG1];
my $nick = ( split /!/, $who )[0];
my $irc = $sender->get_heap();
return if $nick ne $irc->nick_name();
is($where, '#testchannel', $irc->nick_name . ' joined channel');
}
sub irc_chan_sync {
my ($sender, $where) = @_[SENDER, ARG0];
my $irc = $sender->get_heap();
is($where, '#testchannel', $irc->nick_name . ' synced channel');
if ($irc == $bot1) {
$bot2->yield(join => $where);
}
else {
$bot1->yield(away => "I'm gone now");
$bot2->yield(away => "I'm gone now");
}
}
sub irc_user_away {
my ($sender, $nick) = @_[SENDER, ARG0];
my $irc = $sender->get_heap();
if ($irc == $bot1) {
fail("Shouldn't get irc_user_away when AwayPoll is off");
}
is($nick, $bot1->nick_name(), $bot1->nick_name() .' went away');
$bot1->yield('away');
$bot2->yield('away');
}
sub irc_user_back {
my ($sender, $nick) = @_[SENDER, ARG0];
my $irc = $sender->get_heap();
if ($irc == $bot1) {
fail("Shouldn't get irc_user_back when AwayPoll is off");
}
is($nick, $bot1->nick_name(), $bot1->nick_name() .' came back');
$_->yield('quit') for ($bot1, $bot2);
}
sub irc_disconnected {
my ($kernel, $heap, $info) = @_[KERNEL, HEAP, ARG1];
pass($info->{Nick} . ' disconnected');
$heap->{count}++;
$kernel->yield('_shutdown') if $heap->{count} == 2;
}
sub _shutdown {
my ($kernel, $error) = @_[KERNEL, ARG0];
fail($error) if defined $error;
$kernel->alarm_remove_all();
$ircd->yield('shutdown');
$bot1->yield('shutdown');
$bot2->yield('shutdown');
}
|