trying to trigger APIs

Author: bernardodemarco

plugins/iac/nimble/src/main/java/org/apache/cloudstack/tosca/orchestrator/ToscaOrchestrator.java

@@ -16,8 +16,12 @@
 // under the License.
 package org.apache.cloudstack.tosca.orchestrator;
 
+import com.cloud.api.ApiDispatcher;
 import com.cloud.exception.InvalidParameterValueException;
 import com.cloud.utils.UuidUtils;
+import com.cloud.utils.component.ComponentContext;
+import org.apache.cloudstack.api.command.user.vmgroup.CreateVMGroupCmd;
+import org.apache.cloudstack.context.CallContext;
 import org.apache.cloudstack.persistence.iactemplatesprofile.IacResourceTypeVO;
 import org.apache.cloudstack.tosca.model.ToscaNodeTemplate;
 import org.apache.cloudstack.tosca.model.ToscaNodeType;
@@ -49,6 +53,9 @@ public class ToscaOrchestrator {
     @Inject
     private ToscaParser toscaParser;
 
+    @Inject
+    private ApiDispatcher apiDispatcher;
+
     private Map<String, ToscaNodeType> toscaProfile;
 
     private ExecutorService executorPool;
@@ -133,6 +140,7 @@ private CompletableFuture<String> buildNodeProvisioningTask(ToscaNodeTemplate no
     }
 
     private CompletableFuture<String> provisionNode(ToscaNodeTemplate nodeTemplate) {
+        CallContext callerContext = CallContext.current();
         String currentLogContextId = ThreadContext.get("logcontextid");
         String newTaskLogContextId = UuidUtils.first(UUID.randomUUID().toString());
         logger.info("Submitting new task with [logcontextid] equal to [{}] for handling the provisioning of the following node: [{}].", newTaskLogContextId, nodeTemplate.getName());
@@ -144,6 +152,7 @@ private CompletableFuture<String> provisionNode(ToscaNodeTemplate nodeTemplate)
             int randomInt = random.nextInt((4000 - 500) + 1) + 500;
             logger.debug("sleeping for randomInt: [{}] ms", randomInt);
             try {
+                dispatchProvisioningCommand(callerContext, randomInt);
                 Thread.sleep(randomInt);
             } catch (InterruptedException e) {
                 throw new RuntimeException(e);
@@ -155,6 +164,26 @@ private CompletableFuture<String> provisionNode(ToscaNodeTemplate nodeTemplate)
         }, executorPool);
     }
 
+    private void dispatchProvisioningCommand(CallContext ctx, int randomInt) {
+        logger.debug("Constructing provisioning command");
+        CallContext.register(ctx, null);
+        CreateVMGroupCmd cmd = new CreateVMGroupCmd();
+        cmd = ComponentContext.inject(cmd);
+        Map<String, String> params = Map.of(
+                "domainid", "1",
+                "account", "admin",
+                "name", "instance-group-" + randomInt
+        );
+        try {
+            apiDispatcher.dispatch(cmd, params, false);
+            logger.info(cmd.getResponseObject());
+        } catch (Exception e) {
+
+        } finally {
+            CallContext.unregister();
+        }
+    }
+
     public void configureExecutorPool(int poolSize) {
         logger.info("Configuring TOSCA's fixed executor thread pool with [{}] threads.", poolSize);
         executorPool = Executors.newFixedThreadPool(poolSize);

plugins/iac/nimble/src/main/java/org/apache/cloudstack/tosca/orchestrator/cmdbuilders/InstanceGroupCommandBuilder.java

@@ -0,0 +1,36 @@
+// Licensed to the Apache Software Foundation (ASF) under one
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information
+// regarding copyright ownership.  The ASF licenses this file
+// to you 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 org.apache.cloudstack.tosca.orchestrator.cmdbuilders;
+
+import com.cloud.utils.component.ComponentContext;
+import org.apache.cloudstack.api.BaseCmd;
+import org.apache.cloudstack.api.command.user.vmgroup.CreateVMGroupCmd;
+import org.apache.cloudstack.tosca.model.ToscaNodeTemplate;
+
+public class InstanceGroupCommandBuilder implements NodeCommandBuilder {
+    @Override
+    public BaseCmd buildProvisioningCommand(ToscaNodeTemplate toscaNodeTemplate) {
+        CreateVMGroupCmd cmd = new CreateVMGroupCmd();
+        cmd = ComponentContext.inject(cmd);
+        return null;
+    }
+
+    @Override
+    public BaseCmd buildRollbackCommand(ToscaNodeTemplate toscaNodeTemplate) {
+        return null;
+    }
+}

plugins/iac/nimble/src/main/java/org/apache/cloudstack/tosca/orchestrator/cmdbuilders/NodeCommandBuilder.java

@@ -0,0 +1,9 @@
+package org.apache.cloudstack.tosca.orchestrator.cmdbuilders;
+
+import org.apache.cloudstack.api.BaseCmd;
+import org.apache.cloudstack.tosca.model.ToscaNodeTemplate;
+
+public interface NodeCommandBuilder {
+    BaseCmd buildProvisioningCommand(ToscaNodeTemplate toscaNodeTemplate);
+    BaseCmd buildRollbackCommand(ToscaNodeTemplate toscaNodeTemplate);
+}