add destinations, destinationSpecifications, and destinationImplementations resources to API (#49)

* add destinationsHandler

* add destinationSpecificationsHandler

* add destinationImplementationsHandler

Author: cgardens

dataline-api/src/main/openapi/config.yaml

@@ -872,7 +872,7 @@ components:
       required:
       - destinations
       properties:
-        sources:
+        destinations:
           type: array
           items:
             $ref: "#/components/schemas/DestinationImplementationRead"

dataline-config/src/main/resources/json/DestinationConnectionImplementation.json

@@ -4,13 +4,22 @@
   "title": "DestinationConnectionImplementation",
   "description": "information required for connection to a destination.",
   "type": "object",
-  "required": ["destinationSpecificationId", "destinationImplementationId", "configuration"],
+  "required": [
+    "destinationSpecificationId",
+    "workspaceId",
+    "destinationImplementationId",
+    "configuration"
+  ],
   "additionalProperties": false,
   "properties": {
     "destinationSpecificationId": {
       "type": "string",
       "format": "uuid"
     },
+    "workspaceId": {
+      "type": "string",
+      "format": "uuid"
+    },
     "destinationImplementationId": {
       "type": "string",
       "format": "uuid"

dataline-server/src/main/java/io/dataline/server/apis/ConfigurationApi.java

@@ -3,6 +3,7 @@
 import io.dataline.api.model.*;
 import io.dataline.config.persistence.ConfigPersistence;
 import io.dataline.config.persistence.DefaultConfigPersistence;
+import io.dataline.server.handlers.*;
 import io.dataline.server.handlers.SourceImplementationsHandler;
 import io.dataline.server.handlers.SourceSpecificationsHandler;
 import io.dataline.server.handlers.SourcesHandler;
@@ -17,16 +18,24 @@ public class ConfigurationApi implements io.dataline.api.V1Api {
   private final SourcesHandler sourcesHandler;
   private final SourceSpecificationsHandler sourceSpecificationsHandler;
   private final SourceImplementationsHandler sourceImplementationsHandler;
+  private final DestinationsHandler destinationsHandler;
+  private final DestinationSpecificationsHandler destinationSpecificationsHandler;
+  private final DestinationImplementationsHandler destinationImplementationsHandler;
 
   public ConfigurationApi() {
     // todo: configure with env variable.
     ConfigPersistence configPersistence = new DefaultConfigPersistence("../data/config/");
+    final IntegrationSchemaValidation integrationSchemaValidation =
+        new IntegrationSchemaValidation(configPersistence);
     workspacesHandler = new WorkspacesHandler(configPersistence);
     sourcesHandler = new SourcesHandler(configPersistence);
     sourceSpecificationsHandler = new SourceSpecificationsHandler(configPersistence);
     sourceImplementationsHandler =
-        new SourceImplementationsHandler(
-            configPersistence, new IntegrationSchemaValidation(configPersistence));
+        new SourceImplementationsHandler(configPersistence, integrationSchemaValidation);
+    destinationsHandler = new DestinationsHandler(configPersistence);
+    destinationSpecificationsHandler = new DestinationSpecificationsHandler(configPersistence);
+    destinationImplementationsHandler =
+        new DestinationImplementationsHandler(configPersistence, integrationSchemaValidation);
   }
 
   // WORKSPACE
@@ -67,16 +76,17 @@ public SourceSpecificationRead getSourceSpecification(
   }
 
   // SOURCE IMPLEMENTATION
+
   @Override
   public SourceImplementationRead createSourceImplementation(
       @Valid SourceImplementationCreate sourceImplementationCreate) {
     return sourceImplementationsHandler.createSourceImplementation(sourceImplementationCreate);
   }
 
   @Override
-  public SourceImplementationRead getSourceImplementation(
-      @Valid SourceImplementationIdRequestBody sourceImplementationIdRequestBody) {
-    return sourceImplementationsHandler.getSourceImplementation(sourceImplementationIdRequestBody);
+  public SourceImplementationRead updateSourceImplementation(
+      @Valid SourceImplementationUpdate sourceImplementationUpdate) {
+    return sourceImplementationsHandler.updateSourceImplementation(sourceImplementationUpdate);
   }
 
   @Override
@@ -87,15 +97,15 @@ public SourceImplementationReadList listSourceImplementationsForWorkspace(
   }
 
   @Override
-  public SourceImplementationTestConnectionRead testConnectionToSourceImplementation(
+  public SourceImplementationRead getSourceImplementation(
       @Valid SourceImplementationIdRequestBody sourceImplementationIdRequestBody) {
-    return null;
+    return sourceImplementationsHandler.getSourceImplementation(sourceImplementationIdRequestBody);
   }
 
   @Override
-  public SourceImplementationRead updateSourceImplementation(
-      @Valid SourceImplementationUpdate sourceImplementationUpdate) {
-    return sourceImplementationsHandler.updateSourceImplementation(sourceImplementationUpdate);
+  public SourceImplementationTestConnectionRead testConnectionToSourceImplementation(
+      @Valid SourceImplementationIdRequestBody sourceImplementationIdRequestBody) {
+    return null;
   }
 
   @Override
@@ -104,38 +114,56 @@ public SourceImplementationDiscoverSchemaRead discoverSchemaForSourceImplementat
     return null;
   }
 
+  // DESTINATION
+
   @Override
-  public ConnectionRead createConnection(@Valid ConnectionCreate connectionCreate) {
-    return null;
+  public DestinationReadList listDestinations() {
+    return destinationsHandler.listDestinations();
+  }
+
+  @Override
+  public DestinationRead getDestination(@Valid DestinationIdRequestBody destinationIdRequestBody) {
+    return destinationsHandler.getDestination(destinationIdRequestBody);
+  }
+
+  // DESTINATION SPECIFICATION
+
+  @Override
+  public DestinationSpecificationRead getDestinationSpecification(
+      @Valid DestinationIdRequestBody destinationIdRequestBody) {
+    return destinationSpecificationsHandler.getDestinationSpecification(destinationIdRequestBody);
   }
 
+  // DESTINATION IMPLEMENTATION
   @Override
   public DestinationImplementationRead createDestinationImplementation(
       @Valid DestinationImplementationCreate destinationImplementationCreate) {
-    return null;
+    return destinationImplementationsHandler.createDestinationImplementation(
+        destinationImplementationCreate);
   }
 
   @Override
-  public ConnectionRead getConnection(@Valid ConnectionIdRequestBody connectionIdRequestBody) {
-    return null;
+  public DestinationImplementationRead updateDestinationImplementation(
+      @Valid DestinationImplementationUpdate destinationImplementationUpdate) {
+    return destinationImplementationsHandler.updateDestinationImplementation(
+        destinationImplementationUpdate);
   }
 
   @Override
-  public DestinationRead getDestination(@Valid DestinationIdRequestBody destinationIdRequestBody) {
-    return null;
+  public DestinationImplementationReadList listDestinationImplementationsForWorkspace(
+      @Valid WorkspaceIdRequestBody workspaceIdRequestBody) {
+    return destinationImplementationsHandler.listDestinationImplementationsForWorkspace(
+        workspaceIdRequestBody);
   }
 
   @Override
   public DestinationImplementationRead getDestinationImplementation(
       @Valid DestinationImplementationIdRequestBody destinationImplementationIdRequestBody) {
-    return null;
+    return destinationImplementationsHandler.getDestinationImplementation(
+        destinationImplementationIdRequestBody);
   }
 
-  @Override
-  public DestinationSpecificationRead getDestinationSpecification(
-      @Valid DestinationIdRequestBody destinationIdRequestBody) {
-    return null;
-  }
+  // CONNECTION
 
   @Override
   public ConnectionReadList listConnectionsForWorkspace(
@@ -144,13 +172,12 @@ public ConnectionReadList listConnectionsForWorkspace(
   }
 
   @Override
-  public DestinationImplementationReadList listDestinationImplementationsForWorkspace(
-      @Valid WorkspaceIdRequestBody workspaceIdRequestBody) {
+  public ConnectionRead getConnection(@Valid ConnectionIdRequestBody connectionIdRequestBody) {
     return null;
   }
 
   @Override
-  public DestinationReadList listDestinations() {
+  public ConnectionRead createConnection(@Valid ConnectionCreate connectionCreate) {
     return null;
   }
 
@@ -163,10 +190,4 @@ public ConnectionSyncRead syncConnection(@Valid ConnectionIdRequestBody connecti
   public ConnectionRead updateConnection(@Valid ConnectionUpdate connectionUpdate) {
     return null;
   }
-
-  @Override
-  public DestinationImplementationRead updateDestinationImplementation(
-      @Valid DestinationImplementationUpdate destinationImplementationUpdate) {
-    return null;
-  }
 }