Changeset 397 for bot

Timestamp:

11/11/11 17:40:04 (12 years ago)

Author:

nanardon

Message:

• add timeout to reconnect to server

Location:

bot/trunk

Files:

• MANIFEST (modified) (1 diff)
• lib/Sophie/Bot/IRC.pm (modified) (4 diffs)

bot/trunk/MANIFEST

@@ -8 +8 @@
 lib/Sophie/Bot/Term.pm
 lib/Sophie/Bot.pm
+sophie-tools.spec.in
 t/Sophie-Bot.t

bot/trunk/lib/Sophie/Bot/IRC.pm

@@ -8 +8 @@
 
 our $VERSION = '0.01';
+
+sub PING_INTERVAL { 60 }
+sub NO_PONG_TOUT  { 5  }
 
 sub setup_server {
@@ -25 +28 @@
         Server   => $server,
         Ircname  => 'Rpm2sql',
-        Debug    => 0,
+        Debug    => 1,
     );
  
@@ -37 +40 @@
         },
         package_states => [
-            ref($self)  => [ qw(_start irc_001 irc_public irc_msg) ],
+            ref($self)  => [ qw(_start irc_001 irc_public irc_msg ping_server
+                irc_pong) ],
         ],
     ); 
@@ -44 +48 @@
 sub _start {
     my $heap = $_[HEAP];
-    my $irc = $heap->{irc};
+    my $kernel = $_[KERNEL];
+    my $irc = $heap->{irc};
+
     $irc->yield('register', 'all', '001');
     $irc->yield('connect', { });
+
+    $kernel->delay( 'ping_server' => PING_INTERVAL );
+}
+
+sub ping_server {
+    my $heap = $_[HEAP];
+    my $kernel = $_[KERNEL];
+    $heap->{nopong} ||= 0;
+    if ($heap->{nopong} >= NO_PONG_TOUT) {
+        $heap->{irc}->yield( 'connect', { } );
+        return;
+    }
+    $heap->{nopong}++;
+    $heap->{irc}->yield( 'ping' => scalar(time()) );
+    $kernel->delay( 'ping_server' => PING_INTERVAL );
+}
+
+sub irc_pong {
+    my $heap = $_[HEAP];
+    my $kernel = $_[KERNEL];
+    $heap->{nopong} = 0;
+}
+
+sub irc_433  {
+    my $heap = $_[HEAP];
+    my $irc = $heap->{irc};
+    my $self = $heap->{sophie};
+
+    die "Nick already in use\n";
 }