From b215dfe9de6395654aa71a9cf096d927424ae715 Mon Sep 17 00:00:00 2001
From: Pragmatic Software <pragma78@gmail.com>
Date: Fri, 1 Jul 2016 13:00:20 -0700
Subject: [PATCH] Add command queue for delayed command processing

---
 PBot/Interpreter.pm | 54 ++++++++++++++++++++++++++++++++++++++++++---
 1 file changed, 51 insertions(+), 3 deletions(-)

diff --git a/PBot/Interpreter.pm b/PBot/Interpreter.pm
index 8f8151ba..195b8459 100644
--- a/PBot/Interpreter.pm
+++ b/PBot/Interpreter.pm
@@ -39,10 +39,12 @@ sub initialize {
   $self->{pbot}->{registry}->add_default('text',  'general', 'paste_ratelimit',                 $conf{paste_ratelimit}                 // 60);
   $self->{pbot}->{registry}->add_default('text',  'interpreter', 'max_recursion',  10);
 
-  $self->{output_queue} = {};
-  $self->{last_paste}   = 0;
+  $self->{output_queue}  = {};
+  $self->{command_queue} = {};
+  $self->{last_paste}    = 0;
 
-  $self->{pbot}->{timer}->register(sub { $self->process_output_queue }, 1);
+  $self->{pbot}->{timer}->register(sub { $self->process_output_queue  }, 1);
+  $self->{pbot}->{timer}->register(sub { $self->process_command_queue }, 1);
 }
 
 sub process_line {
@@ -201,6 +203,8 @@ sub interpret {
       message => "$nick: Why would I want to do that to myself?"
     };
     $self->add_message_to_output_queue($from, $message, $delay);
+    $delay = duration($delay);
+    $self->{pbot}->{logger}->log("Final result ($delay delay) [$message->{message}]\n");
     return undef;
   }
 
@@ -387,6 +391,50 @@ sub process_output_queue {
   }
 }
 
+sub add_to_command_queue {
+  my ($self, $channel, $command, $delay) = @_;
+
+  if (exists $self->{command_queue}->{$channel}) {
+    my $last_when = $self->{command_queue}->{$channel}->[-1]->{when};
+    $command->{when} = $last_when + $delay;
+  } else {
+    $command->{when} = gettimeofday + $delay;
+  }
+
+  push @{$self->{command_queue}->{$channel}}, $command;
+}
+
+sub add_botcmd_to_command_queue {
+  my ($self, $channel, $command, $delay) = @_;
+
+  my $botcmd = {
+    nick => $self->{pbot}->{registry}->get_value('irc', 'botnick'),
+    user => 'stdin',
+    host => 'localhost',
+    command => $command
+  };
+
+  $self->add_to_command_queue($channel, $botcmd, $delay);
+}
+
+sub process_command_queue {
+  my $self = shift;
+
+  foreach my $channel (keys %{$self->{command_queue}}) {
+    for (my $i = 0; $i < @{$self->{command_queue}->{$channel}}; $i++) {
+      my $command = $self->{command_queue}->{$channel}->[$i];
+      if (gettimeofday >= $command->{when}) {
+        $self->interpret($channel, $command->{nick}, $command->{user}, $command->{host}, 0, $command->{command});
+        splice @{$self->{command_queue}->{$channel}}, $i--, 1;
+      }
+    }
+
+    if (not @{$self->{command_queue}->{$channel}}) {
+      delete $self->{command_queue}->{$channel};
+    }
+  }
+}
+
 sub paste {
   my $self = shift;