fix(mcp): use /api/request endpoint for MCP connector queries (#14)

* fix(mcp): use /api/request endpoint for MCP connector queries

- Changed queryConnector() to use /api/request with request_type: "mcp-query"
- This matches the Go and TypeScript SDK implementations
- Previously used non-existent /api/v1/connectors/query endpoint causing 404 errors
- Updated tests to match new endpoint

Fixes MCP connector examples failing with 404 errors.

* fix: use constructor instead of builder for ConnectorResponse

- Fix compilation error: ConnectorResponse doesn't have builder()
- Fix clientId fallback: use config.getClientId() with fallback to license key

Author: saurabhjain1592

CHANGELOG.md

@@ -5,6 +5,17 @@ All notable changes to the AxonFlow Java SDK will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [1.3.1] - 2025-12-29
+
+### Fixed
+
+- **MCP Connector Queries**: Fixed endpoint mismatch causing 404 errors
+  - Changed `queryConnector()` to use `/api/request` with `request_type: "mcp-query"` (matches Go and TypeScript SDKs)
+  - Previously used non-existent `/api/v1/connectors/query` endpoint
+  - MCP connector examples now work correctly with configured connectors
+
+---
+
 ## [1.3.0] - 2025-12-28
 
 ### Added

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>com.getaxonflow</groupId>
     <artifactId>axonflow-sdk</artifactId>
-    <version>1.3.0</version>
+    <version>1.3.1</version>
     <packaging>jar</packaging>
 
     <name>AxonFlow Java SDK</name>

src/main/java/com/getaxonflow/sdk/AxonFlow.java

@@ -32,6 +32,7 @@
 import java.io.Closeable;
 import java.io.IOException;
 import java.util.Collections;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
@@ -550,6 +551,10 @@ public ConnectorInfo installConnector(String connectorId, Map<String, Object> co
     /**
      * Queries an MCP connector.
      *
+     * <p>This method sends the query to the AxonFlow Agent using the standard
+     * request format with request_type: "mcp-query", which is routed to the
+     * configured MCP connector.
+     *
      * @param query the connector query
      * @return the query response
      * @throws ConnectorException if the query fails
@@ -558,9 +563,41 @@ public ConnectorResponse queryConnector(ConnectorQuery query) {
         Objects.requireNonNull(query, "query cannot be null");
 
         return retryExecutor.execute(() -> {
-            Request httpRequest = buildRequest("POST", "/api/v1/connectors/query", query);
+            // Build a ClientRequest with MCP_QUERY request type
+            // This follows the same pattern as Go and TypeScript SDKs
+            Map<String, Object> context = new HashMap<>();
+            context.put("connector", query.getConnectorId());
+            if (query.getParameters() != null && !query.getParameters().isEmpty()) {
+                context.put("params", query.getParameters());
+            }
+
+            // Determine clientId: prefer config.getClientId(), fallback to license key
+            String clientId = config.getClientId();
+            if (clientId == null || clientId.isEmpty()) {
+                clientId = config.getLicenseKey();
+            }
+
+            ClientRequest clientRequest = ClientRequest.builder()
+                .query(query.getOperation())
+                .userToken(query.getUserToken() != null ? query.getUserToken() : clientId)
+                .clientId(clientId)
+                .requestType(RequestType.MCP_QUERY)
+                .context(context)
+                .build();
+
+            Request httpRequest = buildRequest("POST", "/api/request", clientRequest);
             try (Response response = httpClient.newCall(httpRequest).execute()) {
-                ConnectorResponse result = parseResponse(response, ConnectorResponse.class);
+                ClientResponse clientResponse = parseResponse(response, ClientResponse.class);
+
+                // Convert ClientResponse to ConnectorResponse
+                ConnectorResponse result = new ConnectorResponse(
+                    clientResponse.isSuccess(),
+                    clientResponse.getData(),
+                    clientResponse.getError(),
+                    query.getConnectorId(),
+                    query.getOperation(),
+                    null  // processingTime not available from ClientResponse
+                );
 
                 if (!result.isSuccess()) {
                     throw new ConnectorException(

src/test/java/com/getaxonflow/sdk/AxonFlowTest.java

@@ -354,11 +354,12 @@ void queryConnectorShouldRequireQuery() {
     @Test
     @DisplayName("queryConnector should throw on failure")
     void queryConnectorShouldThrowOnFailure() {
-        stubFor(post(urlEqualTo("/api/v1/connectors/query"))
+        // MCP connector queries now use /api/request with request_type: "mcp-query"
+        stubFor(post(urlEqualTo("/api/request"))
             .willReturn(aResponse()
                 .withStatus(200)
                 .withHeader("Content-Type", "application/json")
-                .withBody("{\"success\":false,\"error\":\"Connector not found\"}")));
+                .withBody("{\"success\":false,\"error\":\"Connector not found\",\"blocked\":false}")));
 
         ConnectorQuery query = ConnectorQuery.builder()
             .connectorId("unknown")
@@ -373,11 +374,12 @@ void queryConnectorShouldThrowOnFailure() {
     @Test
     @DisplayName("queryConnectorAsync should return future")
     void queryConnectorAsyncShouldReturnFuture() throws Exception {
-        stubFor(post(urlEqualTo("/api/v1/connectors/query"))
+        // MCP connector queries now use /api/request with request_type: "mcp-query"
+        stubFor(post(urlEqualTo("/api/request"))
             .willReturn(aResponse()
                 .withStatus(200)
                 .withHeader("Content-Type", "application/json")
-                .withBody("{\"success\":true,\"data\":[]}")));
+                .withBody("{\"success\":true,\"data\":[],\"blocked\":false}")));
 
         ConnectorQuery query = ConnectorQuery.builder()
             .connectorId("salesforce")

src/test/java/com/getaxonflow/sdk/integration/AxonFlowIntegrationTest.java

@@ -304,15 +304,15 @@ void listConnectorsShouldReturnConnectors() {
     @Test
     @DisplayName("queryConnector should return response")
     void queryConnectorShouldReturnResponse() {
-        stubFor(post(urlEqualTo("/api/v1/connectors/query"))
+        // MCP connector queries now use /api/request with request_type: "mcp-query"
+        stubFor(post(urlEqualTo("/api/request"))
             .willReturn(aResponse()
                 .withStatus(200)
                 .withHeader("Content-Type", "application/json")
                 .withBody("{"
                     + "\"success\": true,"
                     + "\"data\": [{\"name\": \"Acme Corp\"}],"
-                    + "\"connector_id\": \"salesforce\","
-                    + "\"operation\": \"getAccounts\""
+                    + "\"blocked\": false"
                     + "}")));
 
         ConnectorResponse response = axonflow.queryConnector(ConnectorQuery.builder()