Implemented DeleteAllServersCommand and DeleteAllTagsCommand

Apicurio · Jan 7, 2025 · 78eec39 · 78eec39
1 parent 6360e99
commit 78eec39
Show file tree

Hide file tree

Showing 5 changed files with 378 additions and 1 deletion.
diff --git a/src/main/java/io/apicurio/datamodels/cmd/CommandFactory.java b/src/main/java/io/apicurio/datamodels/cmd/CommandFactory.java
@@ -17,6 +17,8 @@
 import io.apicurio.datamodels.cmd.commands.DeleteAllResponsesCommand;
 import io.apicurio.datamodels.cmd.commands.DeleteAllSecurityRequirementsCommand;
 import io.apicurio.datamodels.cmd.commands.DeleteAllSecuritySchemesCommand;
+import io.apicurio.datamodels.cmd.commands.DeleteAllServersCommand;
+import io.apicurio.datamodels.cmd.commands.DeleteAllTagsCommand;
 import io.apicurio.datamodels.cmd.commands.DeleteContactCommand;
 import io.apicurio.datamodels.cmd.commands.DeleteExtensionCommand;
 import io.apicurio.datamodels.cmd.commands.DeleteLicenseCommand;
@@ -143,4 +145,19 @@ public static final ICommand createDeleteAllSecuritySchemesCommand() {
         return new DeleteAllSecuritySchemesCommand();
     }
 
+    public static final ICommand createDeleteAllTagsCommand() {
+        return new DeleteAllTagsCommand();
+    }
+
+    public static final ICommand createDeleteAllDocumentServersCommand(OpenApiDocument document) {
+        return new DeleteAllServersCommand(document);
+    }
+    public static final ICommand createDeleteAllPathItemServersCommand(OpenApiPathItem pathItem) {
+        return new DeleteAllServersCommand(pathItem);
+    }
+    public static final ICommand createDeleteAllOperationServersCommand(OpenApiOperation operation) {
+        return new DeleteAllServersCommand(operation);
+    }
+
+
 }
diff --git a/src/main/java/io/apicurio/datamodels/cmd/commands/DeleteAllServersCommand.java b/src/main/java/io/apicurio/datamodels/cmd/commands/DeleteAllServersCommand.java
@@ -0,0 +1,286 @@
+package io.apicurio.datamodels.cmd.commands;
+
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import io.apicurio.datamodels.Library;
+import io.apicurio.datamodels.cmd.AbstractCommand;
+import io.apicurio.datamodels.models.Document;
+import io.apicurio.datamodels.models.Node;
+import io.apicurio.datamodels.models.Operation;
+import io.apicurio.datamodels.models.Server;
+import io.apicurio.datamodels.models.openapi.OpenApiPathItem;
+import io.apicurio.datamodels.models.openapi.OpenApiServer;
+import io.apicurio.datamodels.models.openapi.v30.OpenApi30Document;
+import io.apicurio.datamodels.models.openapi.v30.OpenApi30Operation;
+import io.apicurio.datamodels.models.openapi.v30.OpenApi30PathItem;
+import io.apicurio.datamodels.models.openapi.v30.OpenApi30Server;
+import io.apicurio.datamodels.models.openapi.v31.OpenApi31Document;
+import io.apicurio.datamodels.models.openapi.v31.OpenApi31Operation;
+import io.apicurio.datamodels.models.openapi.v31.OpenApi31PathItem;
+import io.apicurio.datamodels.models.openapi.v31.OpenApi31Server;
+import io.apicurio.datamodels.models.visitors.CombinedVisitorAdapter;
+import io.apicurio.datamodels.paths.NodePath;
+import io.apicurio.datamodels.paths.NodePathUtil;
+import io.apicurio.datamodels.util.LoggerUtil;
+import io.apicurio.datamodels.util.ModelTypeUtil;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * A command used to delete all servers from a document.
+ * 
+ * @author [email protected]
+ */
+public class DeleteAllServersCommand extends AbstractCommand {
+
+    public NodePath _parentPath;
+    public List<ObjectNode> _oldServers;
+
+    public DeleteAllServersCommand() {
+    }
+
+    public DeleteAllServersCommand(Node parent) {
+        this._parentPath = Library.createNodePath(parent);
+    }
+
+    /**
+     * @see io.apicurio.datamodels.cmd.ICommand#execute(Document)
+     */
+    @Override
+    public void execute(Document document) {
+        LoggerUtil.info("[DeleteAllServersCommand] Executing.");
+        this._oldServers = new ArrayList<>();
+
+        Node parent = NodePathUtil.resolveNodePath(this._parentPath, document);
+        if (this.isNullOrUndefined(parent)) {
+            return;
+        }
+
+        // Save the old servers (if any)
+        List<? extends Server> servers = getServers(parent);
+        if (!this.isNullOrUndefined(servers)) {
+            servers.forEach( server -> {
+                this._oldServers.add(Library.writeNode(server));
+            });
+        }
+        clearServers(parent);
+    }
+
+    private List<? extends Server> getServers(Node parent) {
+        GetServersVisitor viz = new GetServersVisitor();
+        parent.accept(viz);
+        return viz._servers;
+    }
+
+    private void clearServers(Node parent) {
+        ClearServersVisitor viz = new ClearServersVisitor();
+        parent.accept(viz);
+    }
+
+    /**
+     * @see io.apicurio.datamodels.cmd.ICommand#undo(Document)
+     */
+    @Override
+    public void undo(Document document) {
+        LoggerUtil.info("[DeleteAllServersCommand] Reverting.");
+        if (this._oldServers.isEmpty()) {
+            return;
+        }
+
+        Node parent = NodePathUtil.resolveNodePath(this._parentPath, document);
+        if (this.isNullOrUndefined(parent)) {
+            return;
+        }
+
+        for (ObjectNode oldServer : this._oldServers) {
+            OpenApiServer server = createServer(parent);
+            Library.readNode(oldServer, server);
+            addServer(parent, server);
+        }
+    }
+
+    private OpenApiServer createServer(Node parent) {
+        CreateServerVisitor viz = new CreateServerVisitor();
+        parent.accept(viz);
+        return (OpenApiServer) viz._server;
+    }
+
+    private void addServer(Node parent, OpenApiServer server) {
+        AddServerVisitor viz = new AddServerVisitor(server);
+        parent.accept(viz);
+    }
+
+    private abstract class ServersParentVisitor extends CombinedVisitorAdapter {
+        @Override
+        public void visitDocument(Document node) {
+            if (ModelTypeUtil.isOpenApi30Model(node)) {
+                visitOpenApi30Document((OpenApi30Document) node);
+            } else if (ModelTypeUtil.isOpenApi31Model(node)) {
+                visitOpenApi31Document((OpenApi31Document) node);
+            }
+        }
+
+        @Override
+        public void visitPathItem(OpenApiPathItem node) {
+            if (ModelTypeUtil.isOpenApi30Model(node)) {
+                visitOpenApi30PathItem((OpenApi30PathItem) node);
+            } else if (ModelTypeUtil.isOpenApi31Model(node)) {
+                visitOpenApi31PathItem((OpenApi31PathItem) node);
+            }
+        }
+
+        @Override
+        public void visitOperation(Operation node) {
+            if (ModelTypeUtil.isOpenApi30Model(node)) {
+                visitOpenApi30Operation((OpenApi30Operation) node);
+            } else if (ModelTypeUtil.isOpenApi31Model(node)) {
+                visitOpenApi31Operation((OpenApi31Operation) node);
+            }
+        }
+
+        abstract void visitOpenApi31Document(OpenApi31Document node);
+        abstract void visitOpenApi30Document(OpenApi30Document node);
+        abstract void visitOpenApi31PathItem(OpenApi31PathItem node);
+        abstract void visitOpenApi30PathItem(OpenApi30PathItem node);
+        abstract void visitOpenApi31Operation(OpenApi31Operation node);
+        abstract void visitOpenApi30Operation(OpenApi30Operation node);
+    }
+
+    private class GetServersVisitor extends ServersParentVisitor {
+        List<? extends Server> _servers;
+
+        @Override
+        void visitOpenApi31Document(OpenApi31Document node) {
+            this._servers = node.getServers();
+        }
+
+        @Override
+        void visitOpenApi30Document(OpenApi30Document node) {
+            this._servers = node.getServers();
+        }
+
+        @Override
+        void visitOpenApi31PathItem(OpenApi31PathItem node) {
+            this._servers = node.getServers();
+        }
+
+        @Override
+        void visitOpenApi30PathItem(OpenApi30PathItem node) {
+            this._servers = node.getServers();
+        }
+
+        @Override
+        void visitOpenApi31Operation(OpenApi31Operation node) {
+            this._servers = node.getServers();
+        }
+
+        @Override
+        void visitOpenApi30Operation(OpenApi30Operation node) {
+            this._servers = node.getServers();
+        }
+    }
+
+    private class ClearServersVisitor extends ServersParentVisitor {
+        @Override
+        void visitOpenApi31Document(OpenApi31Document node) {
+            node.clearServers();
+        }
+
+        @Override
+        void visitOpenApi30Document(OpenApi30Document node) {
+            node.clearServers();
+        }
+
+        @Override
+        void visitOpenApi31PathItem(OpenApi31PathItem node) {
+            node.clearServers();
+        }
+
+        @Override
+        void visitOpenApi30PathItem(OpenApi30PathItem node) {
+            node.clearServers();
+        }
+
+        @Override
+        void visitOpenApi31Operation(OpenApi31Operation node) {
+            node.clearServers();
+        }
+
+        @Override
+        void visitOpenApi30Operation(OpenApi30Operation node) {
+            node.clearServers();
+        }
+    }
+
+    private class CreateServerVisitor extends ServersParentVisitor {
+        Server _server;
+
+        @Override
+        void visitOpenApi31Document(OpenApi31Document node) {
+            this._server = node.createServer();
+        }
+
+        @Override
+        void visitOpenApi30Document(OpenApi30Document node) {
+            this._server = node.createServer();
+        }
+
+        @Override
+        void visitOpenApi31PathItem(OpenApi31PathItem node) {
+            this._server = node.createServer();
+        }
+
+        @Override
+        void visitOpenApi30PathItem(OpenApi30PathItem node) {
+            this._server = node.createServer();
+        }
+
+        @Override
+        void visitOpenApi31Operation(OpenApi31Operation node) {
+            this._server = node.createServer();
+        }
+
+        @Override
+        void visitOpenApi30Operation(OpenApi30Operation node) {
+            this._server = node.createServer();
+        }
+    }
+
+    private class AddServerVisitor extends ServersParentVisitor {
+        private final OpenApiServer _server;
+
+        public AddServerVisitor(OpenApiServer server) {
+            this._server = server;
+        }
+
+        @Override
+        void visitOpenApi31Document(OpenApi31Document node) {
+            node.addServer((OpenApi31Server) this._server);
+        }
+
+        @Override
+        void visitOpenApi30Document(OpenApi30Document node) {
+            node.addServer((OpenApi30Server) this._server);
+        }
+
+        @Override
+        void visitOpenApi31PathItem(OpenApi31PathItem node) {
+            node.addServer((OpenApi31Server) this._server);
+        }
+
+        @Override
+        void visitOpenApi30PathItem(OpenApi30PathItem node) {
+            node.addServer((OpenApi30Server) this._server);
+        }
+
+        @Override
+        void visitOpenApi31Operation(OpenApi31Operation node) {
+            node.addServer((OpenApi31Server) this._server);
+        }
+
+        @Override
+        void visitOpenApi30Operation(OpenApi30Operation node) {
+            node.addServer((OpenApi30Server) this._server);
+        }
+    }
+}
diff --git a/src/main/java/io/apicurio/datamodels/cmd/commands/DeleteAllTagsCommand.java b/src/main/java/io/apicurio/datamodels/cmd/commands/DeleteAllTagsCommand.java
@@ -0,0 +1,65 @@
+package io.apicurio.datamodels.cmd.commands;
+
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import io.apicurio.datamodels.Library;
+import io.apicurio.datamodels.cmd.AbstractCommand;
+import io.apicurio.datamodels.models.Document;
+import io.apicurio.datamodels.models.Tag;
+import io.apicurio.datamodels.models.openapi.OpenApiDocument;
+import io.apicurio.datamodels.models.openapi.OpenApiTag;
+import io.apicurio.datamodels.util.LoggerUtil;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * A command used to delete all tags from a document.
+ * @author [email protected]
+ */
+public class DeleteAllTagsCommand extends AbstractCommand {
+
+    public List<ObjectNode> _oldTags;
+
+    public DeleteAllTagsCommand() {
+    }
+
+    /**
+     * @see io.apicurio.datamodels.cmd.ICommand#execute(Document)
+     */
+    @Override
+    public void execute(Document document) {
+        LoggerUtil.info("[DeleteAllTagsCommand] Executing.");
+
+        OpenApiDocument doc = (OpenApiDocument) document;
+
+        this._oldTags = new ArrayList<>();
+        // Save the old tags (if any)
+        List<? extends Tag> tags = doc.getTags();
+        if (!this.isNullOrUndefined(tags)) {
+            tags.forEach( tag -> {
+                this._oldTags.add(Library.writeNode(tag));
+            });
+        }
+        doc.clearTags();
+    }
+
+    /**
+     * @see io.apicurio.datamodels.cmd.ICommand#undo(Document)
+     */
+    @Override
+    public void undo(Document document) {
+        LoggerUtil.info("[DeleteAllTagsCommand] Reverting.");
+        if (this._oldTags.isEmpty()) {
+            return;
+        }
+
+        OpenApiDocument doc = (OpenApiDocument) document;
+
+        this._oldTags.forEach( oldTag -> {
+            OpenApiTag tag = doc.createTag();
+            Library.readNode(oldTag, tag);
+            doc.addTag(tag);
+        });
+    }
+
+}
diff --git a/src/main/ts/src/io/apicurio/datamodels/util/CommandUtil.ts b/src/main/ts/src/io/apicurio/datamodels/util/CommandUtil.ts
@@ -21,6 +21,8 @@ import {DeleteAllPropertiesCommand} from "../cmd/commands/DeleteAllPropertiesCom
 import {DeleteAllResponsesCommand} from "../cmd/commands/DeleteAllResponsesCommand";
 import {DeleteAllSecurityRequirementsCommand} from "../cmd/commands/DeleteAllSecurityRequirementsCommand";
 import {DeleteAllSecuritySchemesCommand} from "../cmd/commands/DeleteAllSecuritySchemesCommand";
+import {DeleteAllServersCommand} from "../cmd/commands/DeleteAllServersCommand";
+import {DeleteAllTagsCommand} from "../cmd/commands/DeleteAllTagsCommand";
 import {DeleteContactCommand} from "../cmd/commands/DeleteContactCommand";
 import {DeleteExtensionCommand} from "../cmd/commands/DeleteExtensionCommand";
 import {DeleteLicenseCommand} from "../cmd/commands/DeleteLicenseCommand";
@@ -58,6 +60,8 @@ const commandSuppliers: { [key: string]: Supplier } = {
     "DeleteAllResponsesCommand": () => { return new DeleteAllResponsesCommand(); },
     "DeleteAllSecurityRequirementsCommand": () => { return new DeleteAllSecurityRequirementsCommand(); },
     "DeleteAllSecuritySchemesCommand": () => { return new DeleteAllSecuritySchemesCommand(); },
+    "DeleteAllServersCommand": () => { return new DeleteAllServersCommand(); },
+    "DeleteAllTagsCommand": () => { return new DeleteAllTagsCommand(); },
     "DeleteContactCommand": () => { return new DeleteContactCommand(); },
     "DeleteExtensionCommand": () => { return new DeleteExtensionCommand(); },
     "DeleteLicenseCommand": () => { return new DeleteLicenseCommand(); },