use strict; use warnings FATAL => 'all'; use lib 't/inc'; use POE; use POE::Component::IRC; use POE::Component::IRC::Plugin::Connector; use POE::Component::Server::IRC; use Test::More tests => 4; my $bot = POE::Component::IRC->spawn( Flood => 1, plugin_debug => 1, ); my $ircd = POE::Component::Server::IRC->spawn( Auth => 0, AntiFlood => 0, ); $bot->plugin_add(Connector => POE::Component::IRC::Plugin::Connector->new( timeout => 2, reconnect => 2, )); POE::Session->create( package_states => [ main => [qw( _start ircd_listener_add ircd_listener_failure _shutdown irc_001 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]; $bot->yield(register => 'all'); $bot->yield(connect => { nick => 'TestBot1', server => '127.0.0.1', port => $port, }); } sub irc_001 { my ($kernel, $sender, $heap) = @_[KERNEL, SENDER, HEAP]; my $irc = $sender->get_heap(); if (!$heap->{killed}) { pass('Logged in'); $ircd->daemon_server_kill($irc->nick_name()); $heap->{killed}++; return; } pass('Re-logged in'); $irc->plugin_del('Connector'); $irc->yield('quit'); } sub irc_disconnected { my ($kernel, $heap) = @_[KERNEL, HEAP]; if ($heap->{killed} < 2) { $heap->{killed}++; pass('Killed from the IRC server'); return; } pass('irc_disconnected'); $kernel->yield('_shutdown'); } sub _shutdown { my ($kernel, $error) = @_[KERNEL, ARG0]; fail($error) if defined $error; $kernel->alarm_remove_all(); $ircd->yield('shutdown'); $bot->yield('shutdown'); }