X-Git-Url: https://git.localhorst.tv/?a=blobdiff_plain;f=app%2FTwitchBot%2FTwitchBot.php;h=a45de87fcce69a36b32e06cdb2fc567b222144a0;hb=31127000e16c18389129546b9aa652de565683fb;hp=3ca2db9283e6651e521fa2fe4aeaa596d94f9e2e;hpb=898d01d4ac5ccaa23621abda0761a893ff8c1074;p=alttp.git

diff --git a/app/TwitchBot/TwitchBot.php b/app/TwitchBot/TwitchBot.php
index 3ca2db9..a45de87 100644
--- a/app/TwitchBot/TwitchBot.php
+++ b/app/TwitchBot/TwitchBot.php
@@ -3,6 +3,7 @@
 namespace App\TwitchBot;
 
 use App\Models\Channel;
+use App\Models\TwitchBotCommand;
 use App\Models\TwitchToken;
 use Monolog\Handler\StreamHandler;
 use Monolog\Logger;
@@ -15,7 +16,7 @@ class TwitchBot {
 
 	public function __construct() {
 		$this->logger = new Logger('TwitchBot');
-		$this->logger->pushHandler(new StreamHandler('php://stdout', Logger::DEBUG));
+		$this->logger->pushHandler(new StreamHandler('php://stdout', Logger::INFO));
 
 		$this->token = TwitchToken::firstWhere('nick', 'localhorsttv');
 		if (!$this->token) {
@@ -24,6 +25,8 @@ class TwitchBot {
 
 		$this->connector = new Connector();
 		$this->connect();
+		$this->listenCommands();
+		$this->startPinger();
 	}
 
 	public function getLogger() {
@@ -75,16 +78,17 @@ class TwitchBot {
 	public function handleWsMessage(Message $message, WebSocket $ws) {
 		$irc_messages = explode("\r\n", rtrim($message->getPayload(), "\r\n"));
 		foreach ($irc_messages as $irc_message) {
-			$this->logger->debug('received IRC message '.$irc_message);
+			$this->logger->info('received IRC message '.$irc_message);
 			$this->handleIRCMessage(IRCMessage::fromString($irc_message));
 		}
 	}
 
 	public function handleWsClose(int $op, string $reason) {
+		$this->ready = false;
 		$this->logger->info('websocket connection closed: '.$reason.' ['.$op.']');
 		if (!$this->shutting_down) {
-			$this->logger->info('reconnecting in 10 seconds');
-			Loop::addTimer(10, [$this, 'connect']);
+			$this->logger->info('reconnecting in 5 seconds');
+			Loop::addTimer(5, [$this, 'connect']);
 		}
 	}
 
@@ -94,6 +98,7 @@ class TwitchBot {
 
 
 	public function handleIRCMessage(IRCMessage $msg) {
+		$this->last_contact = time();
 		if ($msg->isPrivMsg()) {
 			$this->handlePrivMsg($msg);
 			return;
@@ -102,6 +107,9 @@ class TwitchBot {
 			$this->sendIRCMessage($msg->makePong());
 			return;
 		}
+		if ($msg->isPong()) {
+			return;
+		}
 		if ($msg->isNotice() && $msg->getText() == 'Login authentication failed') {
 			$this->logger->notice('login failed, refreshing access token');
 			$this->token->refresh();
@@ -111,6 +119,7 @@ class TwitchBot {
 		if ($msg->command == '001') {
 			// successful login
 			$this->joinChannels();
+			$this->ready = true;
 			return;
 		}
 	}
@@ -122,7 +131,20 @@ class TwitchBot {
 		if ($text[0] != '!') return;
 		$channel = Channel::firstWhere('twitch_chat', '=', $target);
 		if (!$channel) return;
-		$this->logger->info('got command '.$text.' on channel '.$channel->title);
+		$this->handleChatCommand($channel, $msg);
+	}
+
+	public function handleChatCommand(Channel $channel, IRCMessage $msg) {
+		$cmd = explode(' ', ltrim($msg->getText(), '!'), 2);
+		if (!isset($channel->chat_commands[$cmd[0]])) return;
+		$config = $channel->chat_commands[$cmd[0]];
+		$this->logger->info('got command '.$cmd[0].' on channel '.$channel->title);
+		try {
+			$command = ChatCommand::create($this, $channel, $config);
+			$command->execute($cmd[1] ?? '');
+		} catch (\Exception $e) {
+			$this->logger->warning('error executing command '.$cmd[0].' on channel '.$channel->title.': '.$e->getMessage());
+		}
 	}
 
 	public function login() {
@@ -132,7 +154,7 @@ class TwitchBot {
 
 	public function joinChannels() {
 		$this->logger->info('joining channels');
-		$channels = Channel::where('twitch_chat', '!=', '')->get();
+		$channels = Channel::where('twitch_chat', '!=', '')->where('join', '=', true)->get();
 		$names = [];
 		foreach ($channels as $channel) {
 			$names[] = $channel->twitch_chat;
@@ -143,10 +165,35 @@ class TwitchBot {
 		}
 	}
 
+	private function listenCommands() {
+		$this->getLoop()->addPeriodicTimer(1, function () {
+			if (!$this->ready) return;
+			$command = TwitchBotCommand::where('status', '=', 'pending')->oldest()->first();
+			if ($command) {
+				try {
+					$command->execute($this);
+				} catch (\Exception $e) {
+				}
+			}
+		});
+	}
+
+	private function startPinger() {
+		$this->getLoop()->addPeriodicTimer(15, function () {
+			if (!$this->ready) return;
+			if (time() - $this->last_contact < 60) return;
+			try {
+				$this->sendIRCMessage(IRCMessage::ping());
+			} catch (\Exception $e) {
+			}
+		});
+	}
+
 	public function sendIRCMessage(IRCMessage $msg) {
 		$irc_message = $msg->encode();
-		$this->logger->debug('sending IRC message '.$irc_message);
+		$this->logger->info('sending IRC message '.$irc_message);
 		$this->ws->send($irc_message);
+		$this->last_contact = time();
 	}
 
 
@@ -156,8 +203,11 @@ class TwitchBot {
 
 	private $connector;
 	private $ws;
+	private $ready = false;
 	private $shutting_down = false;
 
+	private $last_contact;
+
 }
 
 ?>