HDDS-15570. [Recon-Chatbot] Call Recon methods directly instead of using HTTP-calls. (#10524).

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: ArafatKhan2198

hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/ReconConstants.java

@@ -63,6 +63,13 @@ public final class ReconConstants {
   public static final String RECON_QUERY_BUCKET = "bucket";
   public static final String RECON_QUERY_FILE_SIZE = "fileSize";
   public static final String RECON_QUERY_CONTAINER_SIZE = "containerSize";
+  public static final String RECON_QUERY_CONTAINER_STATE = "state";
+  public static final String RECON_QUERY_REPLICATION_TYPE = "replicationType";
+  public static final String RECON_QUERY_CREATION_DATE = "creationDate";
+  public static final String RECON_QUERY_KEY_SIZE = "keySize";
+  public static final String RECON_NAMESPACE_USAGE_FILES = "files";
+  public static final String RECON_NAMESPACE_USAGE_REPLICA = "replica";
+  public static final String RECON_NAMESPACE_USAGE_SORT_SUB_PATHS = "sortSubPaths";
   public static final String RECON_ENTITY_PATH = "path";
   public static final String RECON_ENTITY_TYPE = "entityType";
   public static final String RECON_ACCESS_METADATA_START_DATE = "startDate";

hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/chatbot/ChatbotConfigKeys.java

@@ -63,11 +63,6 @@ public final class ChatbotConfigKeys {
   public static final String OZONE_RECON_CHATBOT_GEMINI_BASE_URL_DEFAULT = "https://generativelanguage.googleapis.com/v1beta/openai/";
 
   // ── Execution policy ────────────────────────────────────────
-  // Total records aggregated for an answer are bounded by exec.max.pages * exec.page.size.
-  public static final String OZONE_RECON_CHATBOT_EXEC_MAX_PAGES = OZONE_RECON_CHATBOT_PREFIX + "exec.max.pages";
-  public static final int OZONE_RECON_CHATBOT_EXEC_MAX_PAGES_DEFAULT = 5;
-  public static final String OZONE_RECON_CHATBOT_EXEC_PAGE_SIZE = OZONE_RECON_CHATBOT_PREFIX + "exec.page.size";
-  public static final int OZONE_RECON_CHATBOT_EXEC_PAGE_SIZE_DEFAULT = 200;
 
   public static final String OZONE_RECON_CHATBOT_EXEC_REQUIRE_SAFE_SCOPE = OZONE_RECON_CHATBOT_PREFIX
       + "exec.require.safe.scope";
@@ -77,24 +72,6 @@ public final class ChatbotConfigKeys {
   public static final String OZONE_RECON_CHATBOT_MAX_TOOL_CALLS = OZONE_RECON_CHATBOT_PREFIX + "max.tool.calls";
   public static final int OZONE_RECON_CHATBOT_MAX_TOOL_CALLS_DEFAULT = 5;
 
-  // ── ToolExecutor HTTP timeouts (loopback calls to Recon REST APIs) ───────
-  /**
-   * Connect timeout in milliseconds for loopback HTTP calls from ToolExecutor
-   * to Recon's own REST APIs. Increase this on slow or heavily loaded clusters.
-   */
-  public static final String OZONE_RECON_CHATBOT_EXEC_CONNECT_TIMEOUT_MS =
-      OZONE_RECON_CHATBOT_PREFIX + "exec.connect.timeout.ms";
-  public static final int OZONE_RECON_CHATBOT_EXEC_CONNECT_TIMEOUT_MS_DEFAULT = 30_000;
-
-  /**
-   * Read timeout in milliseconds for loopback HTTP calls from ToolExecutor
-   * to Recon's own REST APIs. Increase this when Recon APIs are slow due to
-   * large dataset sizes (e.g. millions of unhealthy containers).
-   */
-  public static final String OZONE_RECON_CHATBOT_EXEC_READ_TIMEOUT_MS =
-      OZONE_RECON_CHATBOT_PREFIX + "exec.read.timeout.ms";
-  public static final int OZONE_RECON_CHATBOT_EXEC_READ_TIMEOUT_MS_DEFAULT = 30_000;
-
   // ── Async execution thread pool ──────────────────────────────
   /**
    * Number of threads in the dedicated thread pool used to execute chatbot

hadoop-ozone/recon/src/main/java/org/apache/hadoop/ozone/recon/chatbot/ChatbotModule.java

@@ -20,10 +20,13 @@
 import com.google.inject.AbstractModule;
 import com.google.inject.Scopes;
 import org.apache.hadoop.ozone.recon.chatbot.agent.ChatbotAgent;
-import org.apache.hadoop.ozone.recon.chatbot.agent.ToolExecutor;
+import org.apache.hadoop.ozone.recon.chatbot.agent.LlmToolSpecFactory;
 import org.apache.hadoop.ozone.recon.chatbot.api.ChatbotEndpoint;
 import org.apache.hadoop.ozone.recon.chatbot.llm.LLMClient;
 import org.apache.hadoop.ozone.recon.chatbot.llm.LangChain4jDispatcher;
+import org.apache.hadoop.ozone.recon.chatbot.recon.ReconApiAllowlist;
+import org.apache.hadoop.ozone.recon.chatbot.recon.ReconEndpointRouter;
+import org.apache.hadoop.ozone.recon.chatbot.recon.ReconQueryExecutor;
 import org.apache.hadoop.ozone.recon.chatbot.security.CredentialHelper;
 
 /**
@@ -39,8 +42,11 @@ protected void configure() {
     // Bind LLM provider — LangChain4j-backed dispatcher handles all three providers
     bind(LLMClient.class).to(LangChain4jDispatcher.class).in(Scopes.SINGLETON);
 
-    // Bind agent components
-    bind(ToolExecutor.class).in(Scopes.SINGLETON);
+    // Recon data access (direct endpoint bean calls)
+    bind(ReconEndpointRouter.class).in(Scopes.SINGLETON);
+    bind(ReconApiAllowlist.class).in(Scopes.SINGLETON);
+    bind(ReconQueryExecutor.class).in(Scopes.SINGLETON);
+    bind(LlmToolSpecFactory.class).in(Scopes.SINGLETON);
     bind(ChatbotAgent.class).in(Scopes.SINGLETON);
 
     // Bind API endpoint