wrap up rest endpoint implementations

Author: Crim

src/main/java/org/sourcelab/kafka/connect/apiclient/ApiClient.java

@@ -8,6 +8,7 @@
 import org.sourcelab.kafka.connect.apiclient.request.delete.DeleteConnector;
 import org.sourcelab.kafka.connect.apiclient.request.dto.ConnectorPlugin;
 import org.sourcelab.kafka.connect.apiclient.request.dto.ConnectorPluginConfigDefinition;
+import org.sourcelab.kafka.connect.apiclient.request.dto.ConnectorPluginConfigValidationResults;
 import org.sourcelab.kafka.connect.apiclient.request.dto.ConnectorStatus;
 import org.sourcelab.kafka.connect.apiclient.request.dto.NewConnectorDefinition;
 import org.sourcelab.kafka.connect.apiclient.request.dto.Task;
@@ -253,7 +254,7 @@ public Collection<ConnectorPlugin> getConnectorPlugins() {
      * @param configDefinition Defines the configuration to validate.
      * @return Results of the validation.
      */
-    public String validateConnectorPluginConfig(final ConnectorPluginConfigDefinition configDefinition) {
+    public ConnectorPluginConfigValidationResults validateConnectorPluginConfig(final ConnectorPluginConfigDefinition configDefinition) {
         return submitRequest(
             new PutConnectorPluginConfigValidate(configDefinition.getName(), configDefinition.getConfig())
         );

src/main/java/org/sourcelab/kafka/connect/apiclient/request/dto/ConnectorPluginConfigValidationResults.java

@@ -0,0 +1,184 @@
+package org.sourcelab.kafka.connect.apiclient.request.dto;
+
+import java.util.ArrayList;
+import java.util.Collection;
+
+/**
+ * Represents results from the Connector Plugin Config Validation API end point.
+ */
+public final class ConnectorPluginConfigValidationResults {
+    private String name;
+    private int errorCount;
+    private Collection<String> groups = new ArrayList<>();
+    private Collection<Config> configs = new ArrayList<>();
+
+    public String getName() {
+        return name;
+    }
+
+    public int getErrorCount() {
+        return errorCount;
+    }
+
+    public Collection<String> getGroups() {
+        return groups;
+    }
+
+    public Collection<Config> getConfigs() {
+        return configs;
+    }
+
+    @Override
+    public String toString() {
+        return "ConnectorPluginConfigValidationResults{"
+            + "name='" + name + '\''
+            + ", errorCount=" + errorCount
+            + ", groups=" + groups
+            + ", configs=" + configs
+            + '}';
+    }
+
+    /**
+     * Defines a config item.
+     */
+    private final static class Config {
+        private Definition definition;
+        private Value value;
+
+        public Definition getDefinition() {
+            return definition;
+        }
+
+        public Value getValue() {
+            return value;
+        }
+
+        @Override
+        public String toString() {
+            return "Config{"
+                + "definition=" + definition
+                + ", value=" + value
+                + '}';
+        }
+
+        /**
+         * Represents the Definition of a config item.
+         */
+        private final static class Definition {
+            private String name;
+            private String type;
+            private boolean required = false;
+            private String defaultValue;
+            private String importance;
+            private String documentation;
+            private String group;
+            private String width;
+            private String displayName;
+            private Collection<String> dependents = new ArrayList<>();
+            private int order;
+
+            public String getName() {
+                return name;
+            }
+
+            public String getType() {
+                return type;
+            }
+
+            public boolean isRequired() {
+                return required;
+            }
+
+            public String getDefaultValue() {
+                return defaultValue;
+            }
+
+            public String getImportance() {
+                return importance;
+            }
+
+            public String getDocumentation() {
+                return documentation;
+            }
+
+            public String getGroup() {
+                return group;
+            }
+
+            public String getWidth() {
+                return width;
+            }
+
+            public String getDisplayName() {
+                return displayName;
+            }
+
+            public Collection<String> getDependents() {
+                return dependents;
+            }
+
+            public int getOrder() {
+                return order;
+            }
+
+            @Override
+            public String toString() {
+                return "Definition{"
+                    + "name='" + name + '\''
+                    + ", type='" + type + '\''
+                    + ", required=" + required
+                    + ", defaultValue='" + defaultValue + '\''
+                    + ", importance='" + importance + '\''
+                    + ", documentation='" + documentation + '\''
+                    + ", group='" + group + '\''
+                    + ", width='" + width + '\''
+                    + ", displayName='" + displayName + '\''
+                    + ", dependents=" + dependents
+                    + ", order=" + order
+                    + '}';
+            }
+        }
+
+        /**
+         * Defines a config item value.
+         */
+        private final static class Value {
+            private String name;
+            private String value;
+            private Collection<String> recommendedValues = new ArrayList<>();
+            private Collection<String> errors = new ArrayList<>();
+            private boolean visible = true;
+
+            public String getName() {
+                return name;
+            }
+
+            public String getValue() {
+                return value;
+            }
+
+            public Collection<String> getRecommendedValues() {
+                return recommendedValues;
+            }
+
+            public Collection<String> getErrors() {
+                return errors;
+            }
+
+            public boolean isVisible() {
+                return visible;
+            }
+
+            @Override
+            public String toString() {
+                return "Value{"
+                    + "name='" + name + '\''
+                    + ", value='" + value + '\''
+                    + ", recommendedValues=" + recommendedValues
+                    + ", errors=" + errors
+                    + ", visible=" + visible
+                    + '}';
+            }
+        }
+    }
+}

src/main/java/org/sourcelab/kafka/connect/apiclient/request/put/PutConnectorPluginConfigValidate.java

@@ -2,14 +2,14 @@
 
 import com.sun.xml.internal.rngom.util.Uri;
 import org.sourcelab.kafka.connect.apiclient.request.JacksonFactory;
-import org.sourcelab.kafka.connect.apiclient.request.dto.ConnectorDefinition;
+import org.sourcelab.kafka.connect.apiclient.request.dto.ConnectorPluginConfigValidationResults;
 
 import java.io.IOException;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.Map;
 
-public class PutConnectorPluginConfigValidate implements PutRequest<String> {
+public class PutConnectorPluginConfigValidate implements PutRequest<ConnectorPluginConfigValidationResults> {
     private final String connectorPluginName;
     private final Map<String, String> config;
 
@@ -35,8 +35,7 @@ public Object getRequestBody() {
     }
 
     @Override
-    public String parseResponse(final String responseStr) throws IOException {
-        //return JacksonFactory.newInstance().readValue(responseStr, ConnectorDefinition.class);
-        return responseStr;
+    public ConnectorPluginConfigValidationResults parseResponse(final String responseStr) throws IOException {
+        return JacksonFactory.newInstance().readValue(responseStr, ConnectorPluginConfigValidationResults.class);
     }
 }