feat: Added support to DataStoreApi specification

src/main/java/org/opendatamesh/dpds/datastoreapi/v1/DataStoreApiDefinitionConverter.java

@@ -0,0 +1,36 @@
+package org.opendatamesh.dpds.datastoreapi.v1;
+
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApi;
+import org.opendatamesh.dpds.datastoreapi.v1.parser.DataStoreApiParser;
+import org.opendatamesh.dpds.extensions.DefinitionConverter;
+
+import java.io.IOException;
+
+public class DataStoreApiDefinitionConverter implements DefinitionConverter<DataStoreApi> {
+
+    private static final String SPECIFICATION = "datastoreapi";
+    private static final String VERSION = "^1(\\.\\d+){0,2}$";
+    private final DataStoreApiParser parser;
+
+    public DataStoreApiDefinitionConverter(DataStoreApiParser parser) {
+        this.parser = parser;
+    }
+
+    @Override
+    public boolean supports(String specification, String specificationVersion) {
+        return SPECIFICATION.equalsIgnoreCase(specification) &&
+                specificationVersion.matches(VERSION);
+    }
+
+    @Override
+    public DataStoreApi deserialize(ObjectMapper defaultMapper, JsonNode jsonNode) throws IOException {
+        return parser.deserialize(jsonNode);
+    }
+
+    @Override
+    public JsonNode serialize(ObjectMapper defaultMapper, DataStoreApi value) throws IOException {
+        return parser.serialize(value);
+    }
+}

src/main/java/org/opendatamesh/dpds/datastoreapi/v1/DataStoreApiDefinitionVisitor.java

@@ -0,0 +1,10 @@
+package org.opendatamesh.dpds.datastoreapi.v1;
+
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApi;
+import org.opendatamesh.dpds.extensions.DefinitionVisitor;
+
+public abstract class DataStoreApiDefinitionVisitor extends DefinitionVisitor<DataStoreApi> {
+    protected DataStoreApiDefinitionVisitor() {
+        super(DataStoreApi.class);
+    }
+}

src/main/java/org/opendatamesh/dpds/datastoreapi/v1/extensions/DataStoreApiStandardDefinitionConverter.java

@@ -0,0 +1,14 @@
+package org.opendatamesh.dpds.datastoreapi.v1.extensions;
+
+import com.fasterxml.jackson.core.JacksonException;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.opendatamesh.dpds.model.core.ComponentBase;
+
+public interface DataStoreApiStandardDefinitionConverter<T extends ComponentBase> {
+    boolean supports(String specification, String specificationVersion);
+
+    T deserialize(ObjectMapper defaultMapper, JsonNode jsonNode) throws JacksonException;
+
+    JsonNode serialize(ObjectMapper defaultMapper, T value) throws JacksonException;
+}

src/main/java/org/opendatamesh/dpds/datastoreapi/v1/extensions/visitorimpl/DataStoreApiConnectionProtocolObjectImpl.java

@@ -0,0 +1,31 @@
+package org.opendatamesh.dpds.datastoreapi.v1.extensions.visitorimpl;
+
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApiJdbcConnectionObject;
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApiOdbcConnectionObject;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiConnectionProtocolObjectVisitor;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiJdbcConnectionObjectVisitor;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiOdbcConnectionObjectVisitor;
+
+public class DataStoreApiConnectionProtocolObjectImpl extends ExtensionVisitor implements DataStoreApiConnectionProtocolObjectVisitor {
+    public DataStoreApiConnectionProtocolObjectImpl(ExtensionVisitor parent) {
+        super(parent);
+    }
+
+    @Override
+    public void visit(DataStoreApiJdbcConnectionObject jdbc) {
+        extensionHandler.handleComponentBaseExtension(jdbc, DataStoreApiJdbcConnectionObject.class);
+        DataStoreApiJdbcConnectionObjectVisitor visitor = new DataStoreApiJdbcConnectionObjectImpl(this);
+        if(jdbc.getDriverDocs() != null){
+            visitor.visit(jdbc.getDriverDocs());
+        }
+    }
+
+    @Override
+    public void visit(DataStoreApiOdbcConnectionObject odbc) {
+        extensionHandler.handleComponentBaseExtension(odbc, DataStoreApiOdbcConnectionObject.class);
+        DataStoreApiOdbcConnectionObjectVisitor visitor = new DataStoreApiOdbcConnectionObjectImpl(this);
+        if(odbc.getDriverDocs() != null){
+            visitor.visit(odbc.getDriverDocs());
+        }
+    }
+}

src/main/java/org/opendatamesh/dpds/datastoreapi/v1/extensions/visitorimpl/DataStoreApiDatabaseServiceVisitorImpl.java

@@ -0,0 +1,26 @@
+package org.opendatamesh.dpds.datastoreapi.v1.extensions.visitorimpl;
+
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApiServerInfo;
+import org.opendatamesh.dpds.datastoreapi.v1.model.DatastoreApiVariableObject;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiDatabaseServiceVisitor;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiServerInfoVisitor;
+
+public class DataStoreApiDatabaseServiceVisitorImpl extends ExtensionVisitor implements DataStoreApiDatabaseServiceVisitor {
+    public DataStoreApiDatabaseServiceVisitorImpl(ExtensionVisitor parent) {
+        super(parent);
+    }
+
+    @Override
+    public void visit(DataStoreApiServerInfo serverInfo) {
+        extensionHandler.handleComponentBaseExtension(serverInfo, DataStoreApiServerInfo.class);
+        DataStoreApiServerInfoVisitor visitor = new DataStoreApiServerInfoVisitorImpl(this);
+        if (serverInfo.getConnectionProtocols() != null) {
+            visitor.visit(serverInfo.getConnectionProtocols());
+        }
+    }
+
+    @Override
+    public void visit(DatastoreApiVariableObject variableObject) {
+        extensionHandler.handleComponentBaseExtension(variableObject, DatastoreApiVariableObject.class);
+    }
+}

src/main/java/org/opendatamesh/dpds/datastoreapi/v1/extensions/visitorimpl/DataStoreApiExtensionVisitorImpl.java

@@ -0,0 +1,51 @@
+package org.opendatamesh.dpds.datastoreapi.v1.extensions.visitorimpl;
+
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApiDatabaseService;
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApiInfo;
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApiSchema;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiDatabaseServiceVisitor;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiInfoVisitor;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiSchemaVisitor;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiVisitor;
+
+public class DataStoreApiExtensionVisitorImpl extends ExtensionVisitor implements DataStoreApiVisitor {
+
+    public DataStoreApiExtensionVisitorImpl(ExtensionHandler extensionHandler) {
+        super(null);
+        this.extensionHandler = extensionHandler;
+    }
+
+
+    @Override
+    public void visit(DataStoreApiInfo info) {
+        extensionHandler.handleComponentBaseExtension(info, DataStoreApiInfo.class);
+        DataStoreApiInfoVisitor visitor = new DataStoreApiInfoVisitorImpl(this);
+        if (info.getContact() != null) {
+            visitor.visit(info.getContact());
+        }
+        if (info.getLicense() != null) {
+            visitor.visit(info.getLicense());
+        }
+    }
+
+    @Override
+    public void visit(DataStoreApiDatabaseService databaseService) {
+        extensionHandler.handleComponentBaseExtension(databaseService, DataStoreApiDatabaseService.class);
+        DataStoreApiDatabaseServiceVisitor visitor = new DataStoreApiDatabaseServiceVisitorImpl(this);
+        if (databaseService.getServerInfo() != null) {
+            visitor.visit(databaseService.getServerInfo());
+        }
+        if (databaseService.getVariables() != null) {
+            databaseService.getVariables().forEach((key, value) -> visitor.visit(value));
+        }
+    }
+
+    @Override
+    public void visit(DataStoreApiSchema schema) {
+        extensionHandler.handleComponentBaseExtension(schema, DataStoreApiSchema.class);
+        DataStoreApiSchemaVisitor visitor = new DataStoreApiSchemaVisitorImpl(this);
+        if (schema.getTables() != null) {
+            schema.getTables().forEach(visitor::visit);
+        }
+    }
+}

src/main/java/org/opendatamesh/dpds/datastoreapi/v1/extensions/visitorimpl/DataStoreApiExternalResourceObjectVisitorImpl.java

@@ -0,0 +1,15 @@
+package org.opendatamesh.dpds.datastoreapi.v1.extensions.visitorimpl;
+
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApiExternalResourceObject;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiStandardDefinitionObjectVisitor;
+
+public class DataStoreApiExternalResourceObjectVisitorImpl extends ExtensionVisitor implements DataStoreApiStandardDefinitionObjectVisitor {
+    public DataStoreApiExternalResourceObjectVisitorImpl(ExtensionVisitor parent) {
+        super(parent);
+    }
+
+    @Override
+    public void visit(DataStoreApiExternalResourceObject externalResourceObject) {
+        extensionHandler.handleComponentBaseExtension(externalResourceObject, DataStoreApiExternalResourceObject.class);
+    }
+}

src/main/java/org/opendatamesh/dpds/datastoreapi/v1/extensions/visitorimpl/DataStoreApiInfoVisitorImpl.java

@@ -0,0 +1,22 @@
+package org.opendatamesh.dpds.datastoreapi.v1.extensions.visitorimpl;
+
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApiContact;
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApiLicense;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiInfoVisitor;
+
+public class DataStoreApiInfoVisitorImpl extends ExtensionVisitor implements DataStoreApiInfoVisitor {
+
+    public DataStoreApiInfoVisitorImpl(ExtensionVisitor parent) {
+        super(parent);
+    }
+
+    @Override
+    public void visit(DataStoreApiContact contact) {
+        extensionHandler.handleComponentBaseExtension(contact, DataStoreApiContact.class);
+    }
+
+    @Override
+    public void visit(DataStoreApiLicense license) {
+        extensionHandler.handleComponentBaseExtension(license, DataStoreApiLicense.class);
+    }
+}

src/main/java/org/opendatamesh/dpds/datastoreapi/v1/extensions/visitorimpl/DataStoreApiJdbcConnectionObjectImpl.java

@@ -0,0 +1,16 @@
+package org.opendatamesh.dpds.datastoreapi.v1.extensions.visitorimpl;
+
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApiExternalResourceObject;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiJdbcConnectionObjectVisitor;
+
+public class DataStoreApiJdbcConnectionObjectImpl extends ExtensionVisitor implements DataStoreApiJdbcConnectionObjectVisitor {
+
+    public DataStoreApiJdbcConnectionObjectImpl(ExtensionVisitor parent) {
+        super(parent);
+    }
+
+    @Override
+    public void visit(DataStoreApiExternalResourceObject externalResourceObject) {
+        extensionHandler.handleComponentBaseExtension(externalResourceObject, DataStoreApiExternalResourceObject.class);
+    }
+}

src/main/java/org/opendatamesh/dpds/datastoreapi/v1/extensions/visitorimpl/DataStoreApiOdbcConnectionObjectImpl.java

@@ -0,0 +1,15 @@
+package org.opendatamesh.dpds.datastoreapi.v1.extensions.visitorimpl;
+
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApiExternalResourceObject;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiOdbcConnectionObjectVisitor;
+
+public class DataStoreApiOdbcConnectionObjectImpl extends ExtensionVisitor implements DataStoreApiOdbcConnectionObjectVisitor {
+    public DataStoreApiOdbcConnectionObjectImpl(ExtensionVisitor parent) {
+        super(parent);
+    }
+
+    @Override
+    public void visit(DataStoreApiExternalResourceObject externalResourceObject) {
+        extensionHandler.handleComponentBaseExtension(externalResourceObject, DataStoreApiExternalResourceObject.class);
+    }
+}

src/main/java/org/opendatamesh/dpds/datastoreapi/v1/extensions/visitorimpl/DataStoreApiSchemaVisitorImpl.java

@@ -0,0 +1,21 @@
+package org.opendatamesh.dpds.datastoreapi.v1.extensions.visitorimpl;
+
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApiStandardDefinitionObject;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiSchemaVisitor;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiStandardDefinitionObjectVisitor;
+
+public class DataStoreApiSchemaVisitorImpl extends ExtensionVisitor implements DataStoreApiSchemaVisitor {
+    public DataStoreApiSchemaVisitorImpl(ExtensionVisitor parent) {
+        super(parent);
+    }
+
+    @Override
+    public void visit(DataStoreApiStandardDefinitionObject standardDefinitionObject) {
+        extensionHandler.handleComponentBaseExtension(standardDefinitionObject, DataStoreApiStandardDefinitionObject.class);
+        extensionHandler.handleStandardObjectDefinition(standardDefinitionObject);
+        DataStoreApiStandardDefinitionObjectVisitor visitor = new DataStoreApiExternalResourceObjectVisitorImpl(this);
+        if (standardDefinitionObject.getExternalDocs() != null) {
+            visitor.visit(standardDefinitionObject.getExternalDocs());
+        }
+    }
+}

src/main/java/org/opendatamesh/dpds/datastoreapi/v1/extensions/visitorimpl/DataStoreApiServerInfoVisitorImpl.java

@@ -0,0 +1,23 @@
+package org.opendatamesh.dpds.datastoreapi.v1.extensions.visitorimpl;
+
+import org.opendatamesh.dpds.datastoreapi.v1.model.DataStoreApiConnectionProtocolObject;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiConnectionProtocolObjectVisitor;
+import org.opendatamesh.dpds.datastoreapi.v1.visitor.DataStoreApiServerInfoVisitor;
+
+public class DataStoreApiServerInfoVisitorImpl extends ExtensionVisitor implements DataStoreApiServerInfoVisitor {
+    public DataStoreApiServerInfoVisitorImpl(ExtensionVisitor parent) {
+        super(parent);
+    }
+
+    @Override
+    public void visit(DataStoreApiConnectionProtocolObject connectionProtocolObject) {
+        extensionHandler.handleComponentBaseExtension(connectionProtocolObject, DataStoreApiConnectionProtocolObject.class);
+        DataStoreApiConnectionProtocolObjectVisitor visitor = new DataStoreApiConnectionProtocolObjectImpl(this);
+        if(connectionProtocolObject.getJdbc() != null){
+            visitor.visit(connectionProtocolObject.getJdbc());
+        }
+        if(connectionProtocolObject.getOdbc() != null){
+            visitor.visit(connectionProtocolObject.getOdbc());
+        }
+    }
+}