feat: add connector methods and fix DynamicPolicy type (#30)

Add getConnector and getConnectorHealth methods for connector
management. Also fix DynamicPolicy type to match API response format
(type/conditions/actions/priority instead of category/tier/config).

Changes:
- Add getConnector(id) to retrieve connector details
- Add getConnectorHealth(id) for health check
- Add ConnectorHealthStatus type
- Fix DynamicPolicy class to use type/conditions/actions/priority
- Add DynamicPolicyAction class for action definitions
- Update ListDynamicPoliciesOptions to filter by type

Author: saurabhjain1592

CHANGELOG.md

@@ -9,6 +9,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Added
 
+- **Get Connector**: `getConnector(id)` to retrieve details for a specific connector
+- **Connector Health Check**: `getConnectorHealth(id)` to check health status of an installed connector
+- **ConnectorHealthStatus type**: New type for connector health responses
 - **Orchestrator Health Check**: `orchestratorHealthCheck()` to verify Orchestrator service health
 - **Uninstall Connector**: `uninstallConnector()` to remove installed MCP connectors
 

pom.xml

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

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

@@ -615,6 +615,62 @@ public void uninstallConnector(String connectorName) {
         }, "uninstallConnector");
     }
 
+    /**
+     * Gets details for a specific connector by ID.
+     *
+     * @param connectorId the connector ID
+     * @return the connector info
+     */
+    public ConnectorInfo getConnector(String connectorId) {
+        Objects.requireNonNull(connectorId, "connectorId cannot be null");
+
+        return retryExecutor.execute(() -> {
+            String path = "/api/v1/connectors/" + connectorId;
+            Request httpRequest = buildOrchestratorRequest("GET", path, null);
+            try (Response response = httpClient.newCall(httpRequest).execute()) {
+                return parseResponse(response, ConnectorInfo.class);
+            }
+        }, "getConnector");
+    }
+
+    /**
+     * Asynchronously gets details for a specific connector by ID.
+     *
+     * @param connectorId the connector ID
+     * @return a future containing the connector info
+     */
+    public CompletableFuture<ConnectorInfo> getConnectorAsync(String connectorId) {
+        return CompletableFuture.supplyAsync(() -> getConnector(connectorId), asyncExecutor);
+    }
+
+    /**
+     * Gets the health status of an installed connector.
+     *
+     * @param connectorId the connector ID
+     * @return the health status
+     */
+    public ConnectorHealthStatus getConnectorHealth(String connectorId) {
+        Objects.requireNonNull(connectorId, "connectorId cannot be null");
+
+        return retryExecutor.execute(() -> {
+            String path = "/api/v1/connectors/" + connectorId + "/health";
+            Request httpRequest = buildOrchestratorRequest("GET", path, null);
+            try (Response response = httpClient.newCall(httpRequest).execute()) {
+                return parseResponse(response, ConnectorHealthStatus.class);
+            }
+        }, "getConnectorHealth");
+    }
+
+    /**
+     * Asynchronously gets the health status of an installed connector.
+     *
+     * @param connectorId the connector ID
+     * @return a future containing the health status
+     */
+    public CompletableFuture<ConnectorHealthStatus> getConnectorHealthAsync(String connectorId) {
+        return CompletableFuture.supplyAsync(() -> getConnectorHealth(connectorId), asyncExecutor);
+    }
+
     /**
      * Queries an MCP connector.
      *
@@ -1330,11 +1386,8 @@ private String buildDynamicPolicyQueryString(String basePath, ListDynamicPolicie
         StringBuilder path = new StringBuilder(basePath);
         StringBuilder query = new StringBuilder();
 
-        if (options.getCategory() != null) {
-            appendQueryParam(query, "category", options.getCategory().getValue());
-        }
-        if (options.getTier() != null) {
-            appendQueryParam(query, "tier", options.getTier().getValue());
+        if (options.getType() != null) {
+            appendQueryParam(query, "type", options.getType());
         }
         if (options.getEnabled() != null) {
             appendQueryParam(query, "enabled", options.getEnabled().toString());

src/main/java/com/getaxonflow/sdk/types/ConnectorHealthStatus.java

@@ -0,0 +1,129 @@
+/*
+ * Copyright 2025 AxonFlow
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.getaxonflow.sdk.types;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+
+import java.util.Collections;
+import java.util.Map;
+import java.util.Objects;
+
+/**
+ * Health status of an installed MCP connector.
+ */
+@JsonIgnoreProperties(ignoreUnknown = true)
+public final class ConnectorHealthStatus {
+
+    @JsonProperty("healthy")
+    private final Boolean healthy;
+
+    @JsonProperty("latency")
+    private final Long latency;
+
+    @JsonProperty("details")
+    private final Map<String, String> details;
+
+    @JsonProperty("timestamp")
+    private final String timestamp;
+
+    @JsonProperty("error")
+    private final String error;
+
+    public ConnectorHealthStatus(
+            @JsonProperty("healthy") Boolean healthy,
+            @JsonProperty("latency") Long latency,
+            @JsonProperty("details") Map<String, String> details,
+            @JsonProperty("timestamp") String timestamp,
+            @JsonProperty("error") String error) {
+        this.healthy = healthy != null ? healthy : false;
+        this.latency = latency != null ? latency : 0L;
+        this.details = details != null ? Collections.unmodifiableMap(details) : Collections.emptyMap();
+        this.timestamp = timestamp != null ? timestamp : "";
+        this.error = error;
+    }
+
+    /**
+     * Returns whether the connector is healthy.
+     *
+     * @return true if healthy
+     */
+    public Boolean isHealthy() {
+        return healthy;
+    }
+
+    /**
+     * Returns the connection latency in nanoseconds.
+     *
+     * @return latency in nanoseconds
+     */
+    public Long getLatency() {
+        return latency;
+    }
+
+    /**
+     * Returns additional health check details.
+     *
+     * @return immutable map of health details
+     */
+    public Map<String, String> getDetails() {
+        return details;
+    }
+
+    /**
+     * Returns the timestamp of the health check.
+     *
+     * @return ISO 8601 timestamp string
+     */
+    public String getTimestamp() {
+        return timestamp;
+    }
+
+    /**
+     * Returns the error message if unhealthy.
+     *
+     * @return error message or null if healthy
+     */
+    public String getError() {
+        return error;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        ConnectorHealthStatus that = (ConnectorHealthStatus) o;
+        return Objects.equals(healthy, that.healthy) &&
+               Objects.equals(latency, that.latency) &&
+               Objects.equals(timestamp, that.timestamp) &&
+               Objects.equals(error, that.error);
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(healthy, latency, timestamp, error);
+    }
+
+    @Override
+    public String toString() {
+        return "ConnectorHealthStatus{" +
+               "healthy=" + healthy +
+               ", latency=" + latency +
+               ", timestamp='" + timestamp + '\'' +
+               ", error='" + error + '\'' +
+               '}';
+    }
+}