my
$bot1
= POE::Component::IRC->spawn(
Flood
=> 1,
plugin_debug
=> 1,
);
my
$bot2
= POE::Component::IRC->spawn(
Flood
=> 1,
plugin_debug
=> 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_disconnected
irc_dcc_request
irc_dcc_done
irc_dcc_chat
irc_dcc_start
irc_dcc_error
)
],
],
);
$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(
'Logged in'
);
$irc
->yield(
join
=>
'#testchannel'
);
}
sub
irc_join {
my
(
$heap
,
$sender
,
$who
,
$where
) =
@_
[HEAP, SENDER, ARG0, ARG1];
my
$nick
= (
split
/!/,
$who
)[0];
my
$irc
=
$sender
->get_heap();
return
if
$nick
ne
$irc
->nick_name();
is(
$where
,
'#testchannel'
,
'Joined Channel Test'
);
$heap
->{joined}++;
return
if
$heap
->{joined} != 2;
$bot1
->yield(
dcc
=>
$bot2
->nick_name() =>
CHAT
=>
undef
,
undef
, 5);
}
sub
irc_dcc_request {
my
(
$sender
,
$cookie
) =
@_
[SENDER, ARG3];
pass(
'Got dcc request'
);
$sender
->get_heap()->yield(
dcc_accept
=>
$cookie
);
}
sub
irc_dcc_start {
my
(
$sender
,
$id
) =
@_
[SENDER, ARG0];
pass(
'DCC started'
);
$sender
->get_heap()->yield(
dcc_chat
=>
$id
=>
'MOO'
);
}
sub
irc_dcc_chat {
my
(
$sender
,
$id
,
$what
) =
@_
[SENDER, ARG0, ARG3];
is(
$what
,
'MOO'
,
'DCC CHAT test'
);
$sender
->get_heap()->yield(
dcc_close
=>
$id
);
}
sub
irc_dcc_done {
pass(
'Got dcc close'
);
$_
[SENDER]->get_heap()->yield(
'quit'
);
}
sub
irc_dcc_error {
my
(
$sender
,
$error
) =
@_
[SENDER, ARG1];
my
$irc
=
$sender
->get_heap();
fail(
'('
.
$irc
->nick_name() .
") DCC failed: $error"
);
$sender
->get_heap()->yield(
'quit'
);
}
sub
irc_disconnected {
my
(
$kernel
,
$heap
) =
@_
[KERNEL, HEAP];
pass(
'irc_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'
);
}