LagFix, Added ThreadLimit

Author: FungY911

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>tech.codemein</groupId>
     <artifactId>AIChatBot</artifactId>
-    <version>1.0.0</version>
+    <version>1.0.0-beta</version>
     <packaging>jar</packaging>
 
     <name>AIChat</name>

src/main/java/tech/codemein/aichat/commands/ASKCommand.java

@@ -20,12 +20,18 @@
 
 import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+import static org.bukkit.Bukkit.getLogger;
 
 public class ASKCommand implements CommandExecutor, TabCompleter {
     private final List<ChatCompletionMessageData> messageHistory = new ArrayList<>();
+    private static AIHandler gpt = new AIHandler();
     private static String response;
     @Override
     public boolean onCommand(@NotNull CommandSender sender, @NotNull Command command, @NotNull String s, @NotNull String[] args) {
+        int maxThreads = FileManager.config.getInt("maxThreads");
 
         Player player = (Player) sender;
 
@@ -36,22 +42,39 @@ public boolean onCommand(@NotNull CommandSender sender, @NotNull Command command
 
         player.sendMessage(ColorUtil.translate(FileManager.config.getString("prefix") + "&7 Question: " + String.join(" ", args)));
 
-        AIHandler gpt = new AIHandler();
-
         //The first message that we want to send
         String message = String.join(" ", args);
 
-        //Response from ChatGPT
-        player.playSound(player.getLocation(), Sound.BLOCK_LAVA_POP, 1, 2);
-        try {
-            response = gpt.exampleBuilders(message);
-        } catch (Exception e) {
-            sender.sendMessage(ColorUtil.translate(FileManager.config.getString("prefix") + "&c Error: Failed, please look at console and check your API Key if is correct. If you do not know what to do, ask on out discord."));
-            Main.getInstance().getLogger().warning(e.getMessage());
+
+        if (maxThreads == 0) {
+            player.playSound(player.getLocation(), Sound.BLOCK_LAVA_POP, 1, 2);
+            try {
+                response = gpt.exampleBuilders(message);
+            } catch (Exception e) {
+                sender.sendMessage(ColorUtil.translate(FileManager.config.getString("prefix") + "&c Error: Failed, please look at console and check your API Key if is correct. If you do not know what to do, ask on out discord."));
+                Main.getInstance().getLogger().warning(e.getMessage());
+                return true;
+            }
+            sender.sendMessage(ColorUtil.translate(FileManager.config.getString("prefix") + "&7" +  response));
+            player.playSound(player.getLocation(), Sound.BLOCK_ANVIL_PLACE, 1, 2);
             return true;
         }
-        sender.sendMessage(ColorUtil.translate(FileManager.config.getString("prefix") + "&7" +  response));
-        player.playSound(player.getLocation(), Sound.BLOCK_ANVIL_PLACE, 1, 2);
+
+        //Response from ChatGPT
+        ExecutorService executorService = Executors.newFixedThreadPool(maxThreads);
+        executorService.submit(() -> {
+            player.playSound(player.getLocation(), Sound.BLOCK_LAVA_POP, 1, 2);
+            try {
+                response = gpt.exampleBuilders(message);
+            } catch (Exception e) {
+                sender.sendMessage(ColorUtil.translate(FileManager.config.getString("prefix") + "&c Error: Failed, please look at console and check your API Key if is correct. If you do not know what to do, ask on out discord."));
+                Main.getInstance().getLogger().warning(e.getMessage());
+                return;
+            }
+            sender.sendMessage(ColorUtil.translate(FileManager.config.getString("prefix") + "&7" +  response));
+            player.playSound(player.getLocation(), Sound.BLOCK_ANVIL_PLACE, 1, 2);
+        });
+
         return true;
     }
 

src/main/java/tech/codemein/aichat/commands/MainCommand.java

@@ -10,8 +10,6 @@
 import tech.codemein.aichat.managers.FileManager;
 import tech.codemein.aichat.utils.ColorUtil;
 
-import java.io.File;
-
 public class MainCommand implements CommandExecutor {
     private String SpigotMCUrlForPlugin = null;
 

src/main/java/tech/codemein/aichat/listeners/ChatListener.java

@@ -0,0 +1,7 @@
+package tech.codemein.aichat.listeners;
+
+import org.bukkit.event.Listener;
+
+public class ChatListener implements Listener {
+
+}