package fr.aichatbot.managers; import com.google.gson.JsonArray; import com.google.gson.JsonObject; import com.google.gson.JsonParser; import fr.aichatbot.AIChatBot; import org.bukkit.Bukkit; import org.bukkit.entity.Player; import java.net.URI; import java.net.http.HttpClient; import java.net.http.HttpRequest; import java.net.http.HttpResponse; import java.time.Duration; import java.util.List; import java.util.UUID; import java.util.concurrent.CompletableFuture; import java.util.function.Consumer; public class OpenAIClient { private final AIChatBot plugin; private final HttpClient httpClient; private final String apiKey; private final String model; private final String apiUrl; private final int maxTokens; private final double temperature; private final String systemPrompt; public OpenAIClient(AIChatBot plugin) { this.plugin = plugin; this.httpClient = HttpClient.newBuilder() .connectTimeout(Duration.ofSeconds(10)) .build(); this.apiKey = plugin.getConfig().getString("api.api-key", ""); this.model = plugin.getConfig().getString("api.model", "gpt-4o-mini"); this.apiUrl = plugin.getConfig().getString("api.api-url", "https://api.openai.com/v1/chat/completions"); this.maxTokens = plugin.getConfig().getInt("api.max-tokens", 50); this.temperature = plugin.getConfig().getDouble("api.temperature", 0.9); this.systemPrompt = plugin.getConfig().getString("bobby.system-prompt", ""); } public void sendMessageAsync(List conversationHistory, String userMessage, Consumer callback, Consumer errorCallback) { sendMessageAsync(conversationHistory, userMessage, null, callback, errorCallback); } public void sendMessageAsync(List conversationHistory, String userMessage, UUID playerId, Consumer callback, Consumer errorCallback) { if (apiKey.isEmpty() || apiKey.equals("YOUR_OPENAI_API_KEY_HERE")) { Bukkit.getScheduler().runTask(plugin, () -> errorCallback.accept("API key not configured") ); return; } CompletableFuture.runAsync(() -> { try { JsonObject requestBody = buildRequestBody(conversationHistory, userMessage); HttpRequest request = HttpRequest.newBuilder() .uri(URI.create(apiUrl)) .header("Content-Type", "application/json") .header("Authorization", "Bearer " + apiKey) .timeout(Duration.ofSeconds(30)) .POST(HttpRequest.BodyPublishers.ofString(requestBody.toString())) .build(); httpClient.sendAsync(request, HttpResponse.BodyHandlers.ofString()) .thenApply(HttpResponse::body) .thenAccept(responseBody -> { try { handleResponse(responseBody, conversationHistory, playerId, userMessage, callback, errorCallback); } catch (Exception e) { Bukkit.getScheduler().runTask(plugin, () -> errorCallback.accept("Error parsing response: " + e.getMessage()) ); } }) .exceptionally(throwable -> { Bukkit.getScheduler().runTask(plugin, () -> errorCallback.accept("HTTP request failed: " + throwable.getMessage()) ); return null; }); } catch (Exception e) { Bukkit.getScheduler().runTask(plugin, () -> errorCallback.accept("Error building request: " + e.getMessage()) ); } }); } private void handleResponse(String responseBody, List conversationHistory, UUID playerId, String originalMessage, Consumer callback, Consumer errorCallback) { JsonObject jsonResponse = JsonParser.parseString(responseBody).getAsJsonObject(); if (jsonResponse.has("error")) { throw new RuntimeException(jsonResponse.get("error").getAsJsonObject().get("message").getAsString()); } JsonObject choice = jsonResponse.getAsJsonArray("choices").get(0).getAsJsonObject(); JsonObject message = choice.getAsJsonObject("message"); if (message.has("tool_calls") && playerId != null) { JsonArray toolCalls = message.getAsJsonArray("tool_calls"); if (toolCalls.size() > 0) { handleToolCalls(toolCalls, message, conversationHistory, playerId, originalMessage, callback, errorCallback); return; } } String aiResponse = message.get("content").getAsString().trim(); Bukkit.getScheduler().runTask(plugin, () -> callback.accept(aiResponse)); } private void handleToolCalls(JsonArray toolCalls, JsonObject assistantMessage, List conversationHistory, UUID playerId, String originalMessage, Consumer callback, Consumer errorCallback) { Player player = Bukkit.getPlayer(playerId); if (player == null) { Bukkit.getScheduler().runTask(plugin, () -> errorCallback.accept("Player not found") ); return; } JsonArray toolResults = new JsonArray(); for (int i = 0; i < toolCalls.size(); i++) { JsonObject toolCall = toolCalls.get(i).getAsJsonObject(); String toolId = toolCall.get("id").getAsString(); JsonObject function = toolCall.getAsJsonObject("function"); String functionName = function.get("name").getAsString(); JsonObject arguments = JsonParser.parseString(function.get("arguments").getAsString()).getAsJsonObject(); String result = executeTool(player, functionName, arguments); JsonObject toolResult = new JsonObject(); toolResult.addProperty("tool_call_id", toolId); toolResult.addProperty("role", "tool"); toolResult.addProperty("name", functionName); toolResult.addProperty("content", result); toolResults.add(toolResult); } sendFollowUpWithToolResults(conversationHistory, originalMessage, assistantMessage, toolResults, callback, errorCallback); } private String executeTool(Player player, String functionName, JsonObject arguments) { switch (functionName) { case "give_item": String itemKey = arguments.get("item_key").getAsString(); boolean success = plugin.getItemManager().giveItem(player, itemKey); if (success) { return "Item '" + itemKey + "' donné avec succès à " + player.getName(); } else { if (plugin.getItemManager().isOnCooldown(player.getUniqueId())) { return "Échec: Le joueur est en cooldown"; } else if (plugin.getItemManager().hasReachedDailyLimit(player.getUniqueId())) { return "Échec: Limite quotidienne atteinte"; } else { return "Échec: Item non disponible ou permission manquante"; } } case "teleport_warp": String warpName = arguments.get("warp_name").getAsString(); boolean teleported = plugin.getWarpManager().teleportToWarp(player, warpName); if (teleported) { return "Téléportation de " + player.getName() + " vers '" + warpName + "' effectuée"; } else { return "Échec: Warp non autorisé ou permission manquante"; } case "list_warps": List warps = plugin.getWarpManager().getAllowedWarps(); if (warps.isEmpty()) { return "Aucun warp disponible"; } return "Warps disponibles: " + String.join(", ", warps); default: return "Fonction inconnue"; } } private void sendFollowUpWithToolResults(List conversationHistory, String originalMessage, JsonObject assistantMessage, JsonArray toolResults, Consumer callback, Consumer errorCallback) { CompletableFuture.runAsync(() -> { try { JsonObject requestBody = buildFollowUpRequest(conversationHistory, originalMessage, assistantMessage, toolResults); HttpRequest request = HttpRequest.newBuilder() .uri(URI.create(apiUrl)) .header("Content-Type", "application/json") .header("Authorization", "Bearer " + apiKey) .timeout(Duration.ofSeconds(30)) .POST(HttpRequest.BodyPublishers.ofString(requestBody.toString())) .build(); httpClient.sendAsync(request, HttpResponse.BodyHandlers.ofString()) .thenApply(HttpResponse::body) .thenAccept(responseBody -> { try { String aiResponse = parseResponse(responseBody); Bukkit.getScheduler().runTask(plugin, () -> callback.accept(aiResponse)); } catch (Exception e) { Bukkit.getScheduler().runTask(plugin, () -> errorCallback.accept("Error parsing follow-up response: " + e.getMessage()) ); } }) .exceptionally(throwable -> { Bukkit.getScheduler().runTask(plugin, () -> errorCallback.accept("Follow-up request failed: " + throwable.getMessage()) ); return null; }); } catch (Exception e) { Bukkit.getScheduler().runTask(plugin, () -> errorCallback.accept("Error building follow-up request: " + e.getMessage()) ); } }); } private JsonObject buildRequestBody(List conversationHistory, String userMessage) { JsonObject requestBody = new JsonObject(); requestBody.addProperty("model", model); requestBody.addProperty("max_tokens", maxTokens); requestBody.addProperty("temperature", temperature); JsonArray messages = new JsonArray(); JsonObject systemMessage = new JsonObject(); systemMessage.addProperty("role", "system"); systemMessage.addProperty("content", systemPrompt + buildToolsInstructions()); messages.add(systemMessage); for (String historyMessage : conversationHistory) { JsonObject msgObj = new JsonObject(); if (historyMessage.startsWith("USER: ")) { msgObj.addProperty("role", "user"); msgObj.addProperty("content", historyMessage.substring(6)); } else if (historyMessage.startsWith("BOBBY: ")) { msgObj.addProperty("role", "assistant"); msgObj.addProperty("content", historyMessage.substring(7)); } messages.add(msgObj); } JsonObject userMsg = new JsonObject(); userMsg.addProperty("role", "user"); userMsg.addProperty("content", userMessage); messages.add(userMsg); requestBody.add("messages", messages); requestBody.add("tools", buildTools()); return requestBody; } private JsonObject buildFollowUpRequest(List conversationHistory, String originalMessage, JsonObject assistantMessage, JsonArray toolResults) { JsonObject requestBody = new JsonObject(); requestBody.addProperty("model", model); requestBody.addProperty("max_tokens", maxTokens); requestBody.addProperty("temperature", temperature); JsonArray messages = new JsonArray(); JsonObject systemMessage = new JsonObject(); systemMessage.addProperty("role", "system"); systemMessage.addProperty("content", systemPrompt); messages.add(systemMessage); for (String historyMessage : conversationHistory) { JsonObject msgObj = new JsonObject(); if (historyMessage.startsWith("USER: ")) { msgObj.addProperty("role", "user"); msgObj.addProperty("content", historyMessage.substring(6)); } else if (historyMessage.startsWith("BOBBY: ")) { msgObj.addProperty("role", "assistant"); msgObj.addProperty("content", historyMessage.substring(7)); } messages.add(msgObj); } JsonObject userMsg = new JsonObject(); userMsg.addProperty("role", "user"); userMsg.addProperty("content", originalMessage); messages.add(userMsg); messages.add(assistantMessage); for (int i = 0; i < toolResults.size(); i++) { messages.add(toolResults.get(i)); } requestBody.add("messages", messages); return requestBody; } private String buildToolsInstructions() { StringBuilder instructions = new StringBuilder("\n\n=== OUTILS DISPONIBLES ===\n"); if (plugin.getConfig().getBoolean("items.enabled", true)) { instructions.append("Tu peux DONNER DES ITEMS aux joueurs avec give_item():\n"); instructions.append("- Utilise cette fonction UNIQUEMENT si le joueur exprime un BESOIN CLAIR\n"); instructions.append("- Exemples: 'j'ai faim' → nourriture, 'j'ai pas de torches' → torches, 'besoin de bois' → planches\n"); instructions.append("- Items disponibles: ").append(String.join(", ", plugin.getItemManager().getAvailableItemKeys())).append("\n"); instructions.append("- N'abuse PAS de cette fonction. Sois sarcastique AVANT/APRÈS avoir donné l'item\n\n"); } if (plugin.getConfig().getBoolean("warps.enabled", true)) { instructions.append("Tu peux TÉLÉPORTER les joueurs avec teleport_warp():\n"); instructions.append("- Utilise si demande explicite de téléportation vers un endroit\n"); instructions.append("- Warps autorisés: ").append(plugin.getWarpManager().getWarpsAsList()).append("\n"); instructions.append("- Tu peux LISTER les warps avec list_warps() si on te demande 'où je peux aller'\n\n"); } instructions.append("RÈGLE: Génère ta RÉPONSE SARCASTIQUE normale, les outils sont AUTOMATIQUES si besoin."); return instructions.toString(); } private JsonArray buildTools() { JsonArray tools = new JsonArray(); if (plugin.getConfig().getBoolean("items.enabled", true)) { JsonObject giveItemTool = new JsonObject(); giveItemTool.addProperty("type", "function"); JsonObject giveItemFunction = new JsonObject(); giveItemFunction.addProperty("name", "give_item"); giveItemFunction.addProperty("description", "Donne un item basique au joueur qui en exprime le besoin (faim, besoin d'outils, etc)"); JsonObject giveItemParams = new JsonObject(); giveItemParams.addProperty("type", "object"); JsonObject giveItemProperties = new JsonObject(); JsonObject itemKeyParam = new JsonObject(); itemKeyParam.addProperty("type", "string"); itemKeyParam.addProperty("description", "Clé de l'item à donner"); JsonArray itemEnum = new JsonArray(); for (String key : plugin.getItemManager().getAvailableItemKeys()) { itemEnum.add(key); } itemKeyParam.add("enum", itemEnum); giveItemProperties.add("item_key", itemKeyParam); giveItemParams.add("properties", giveItemProperties); JsonArray requiredParams = new JsonArray(); requiredParams.add("item_key"); giveItemParams.add("required", requiredParams); giveItemFunction.add("parameters", giveItemParams); giveItemTool.add("function", giveItemFunction); tools.add(giveItemTool); } if (plugin.getConfig().getBoolean("warps.enabled", true)) { JsonObject teleportTool = new JsonObject(); teleportTool.addProperty("type", "function"); JsonObject teleportFunction = new JsonObject(); teleportFunction.addProperty("name", "teleport_warp"); teleportFunction.addProperty("description", "Téléporte le joueur vers un warp autorisé"); JsonObject teleportParams = new JsonObject(); teleportParams.addProperty("type", "object"); JsonObject teleportProperties = new JsonObject(); JsonObject warpParam = new JsonObject(); warpParam.addProperty("type", "string"); warpParam.addProperty("description", "Nom du warp"); JsonArray warpEnum = new JsonArray(); for (String warp : plugin.getWarpManager().getAllowedWarps()) { warpEnum.add(warp); } warpParam.add("enum", warpEnum); teleportProperties.add("warp_name", warpParam); teleportParams.add("properties", teleportProperties); JsonArray requiredTeleportParams = new JsonArray(); requiredTeleportParams.add("warp_name"); teleportParams.add("required", requiredTeleportParams); teleportFunction.add("parameters", teleportParams); teleportTool.add("function", teleportFunction); tools.add(teleportTool); JsonObject listWarpsTool = new JsonObject(); listWarpsTool.addProperty("type", "function"); JsonObject listWarpsFunction = new JsonObject(); listWarpsFunction.addProperty("name", "list_warps"); listWarpsFunction.addProperty("description", "Liste tous les warps disponibles"); JsonObject listWarpsParams = new JsonObject(); listWarpsParams.addProperty("type", "object"); listWarpsParams.add("properties", new JsonObject()); listWarpsFunction.add("parameters", listWarpsParams); listWarpsTool.add("function", listWarpsFunction); tools.add(listWarpsTool); } return tools; } private String parseResponse(String responseBody) { JsonObject jsonResponse = JsonParser.parseString(responseBody).getAsJsonObject(); if (jsonResponse.has("error")) { throw new RuntimeException(jsonResponse.get("error").getAsJsonObject().get("message").getAsString()); } return jsonResponse .getAsJsonArray("choices") .get(0).getAsJsonObject() .getAsJsonObject("message") .get("content").getAsString() .trim(); } }