chat bot settings

[alttp.git] / app / TwitchBot / TwitchChatBot.php

diff --git a/app/TwitchBot/TwitchChatBot.php b/app/TwitchBot/TwitchChatBot.php
index 7a6eb1c1357cb9c59d12c2bfc9af81467383ae53..0896c2b98017b77808630929ff4f47ce9c0b8852 100644 (file)
--- a/app/TwitchBot/TwitchChatBot.php
+++ b/app/TwitchBot/TwitchChatBot.php
@@ -9,16 +9,7 @@ class TwitchChatBot extends TwitchBot {
 
        public function __construct() {
                parent::__construct('horstiebot');
-               $this->channels = Channel::where('twitch_chat', '!=', '')->where('chat', '=', true)->get();
-               foreach ($this->channels as $channel) {
-                       $this->notes[$channel->id] = [
-                               'last_read' => 0,
-                               'last_write' => time(),
-                               'read_since_last_write' => 0,
-                               'wait_msgs' => $this->randomWaitMsgs($channel),
-                               'wait_time' => $this->randomWaitTime($channel),
-                       ];
-               }
+               $this->updateChannels();
                $this->startTimer();
                $this->listenCommands();
        }
@@ -57,10 +48,17 @@ class TwitchChatBot extends TwitchBot {
                                $this->decideSend($channel);
                        }
                });
+               $this->getLoop()->addPeriodicTimer(60, function () {
+                       $this->updateChannels();
+               });
+       }
+
+       private function updateChannels() {
+               $this->channels = Channel::where('twitch_chat', '!=', '')->where('chat', '=', true)->get();
        }
 
        private function decideSend(Channel $channel) {
-               $notes = $this->notes[$channel->id];
+               $notes = $this->getNotes($channel);
                if ($notes['read_since_last_write'] < $notes['wait_msgs']) {
                        return;
                }
@@ -77,6 +75,26 @@ class TwitchChatBot extends TwitchBot {
                $this->sendIRCMessage(IRCMessage::privmsg($channel->twitch_chat, $text));
        }
 
+       private function getChatSetting(Channel $channel, $name, $default = null) {
+               if (array_key_exists($name, $channel->chat_settings)) {
+                       return $channel->chat_settings[$name];
+               }
+               return $default;
+       }
+
+       private function getNotes(Channel $channel) {
+               if (!isset($this->notes[$channel->id])) {
+                       $this->notes[$channel->id] = [
+                               'last_read' => 0,
+                               'last_write' => time(),
+                               'read_since_last_write' => 0,
+                               'wait_msgs' => $this->randomWaitMsgs($channel),
+                               'wait_time' => $this->randomWaitTime($channel),
+                       ];
+               }
+               return $this->notes[$channel->id];
+       }
+
        private function randomMsg(Channel $channel) {
                $line = ChatLog::where('type', '=', 'chat')
                        ->where('banned', '=', false)
@@ -91,19 +109,25 @@ class TwitchChatBot extends TwitchBot {
        }
 
        private function randomWaitMsgs(Channel $channel) {
-               return random_int(1, 10);
+               $min = $this->getChatSetting($channel, 'wait_msgs_min', 1);
+               $max = $this->getChatSetting($channel, 'wait_msgs_max', 10);
+               return random_int($min, $max);
        }
 
        private function randomWaitTime(Channel $channel) {
-               return random_int(1, 900);
+               $min = $this->getChatSetting($channel, 'wait_time_min', 1);
+               $max = $this->getChatSetting($channel, 'wait_time_max', 900);
+               return random_int($min, $max);
        }
 
        private function tagChannelRead(Channel $channel) {
+               $this->getNotes($channel);
                $this->notes[$channel->id]['last_read'] = time();
                ++$this->notes[$channel->id]['read_since_last_write'];
        }
 
        private function tagChannelWrite(Channel $channel) {
+               $this->getNotes($channel);
                $this->notes[$channel->id]['last_write'] = time();
                $this->notes[$channel->id]['read_since_last_write'] = 0;
                $this->notes[$channel->id]['wait_msgs'] = $this->randomWaitMsgs($channel);