(WIP) Implementing resource cloudtemple_compute_virtual_controller

Cloud-Temple · Oct 31, 2023 · 10c5b62 · 10c5b62
1 parent b488cef
commit 10c5b62
Show file tree

Hide file tree

Showing 3 changed files with 88 additions and 18 deletions.
diff --git a/internal/client/compute_virtual_controller.go b/internal/client/compute_virtual_controller.go
@@ -45,3 +45,72 @@ func (v *VirtualControllerClient) List(
 
 	return out, nil
 }
+
+type CreateVirtualControllerRequest struct {
+	VirtualMachineId     string `json:"virtualMachineId"`
+	Type                 string `json:"type"`
+	SubType              string `json:"subType,omitempty"`
+	IsoPath              string `json:"isoPath,omitempty"`
+	ContentLibraryItemId string `json:"contentLibraryitemId,omitempty"`
+}
+
+func (n *VirtualControllerClient) Create(ctx context.Context, req *CreateVirtualControllerRequest) (string, error) {
+	r := n.c.newRequest("POST", "/api/compute/v1/vcenters/virtual_controllers")
+	r.obj = req
+	return n.c.doRequestAndReturnActivity(ctx, r)
+}
+
+func (v *VirtualControllerClient) Read(ctx context.Context, id string) (*VirtualController, error) {
+	r := v.c.newRequest("GET", "/api/compute/v1/vcenters/virtual_controllers/%s", id)
+	resp, err := v.c.doRequest(ctx, r)
+	if err != nil {
+		return nil, err
+	}
+	defer closeResponseBody(resp)
+	found, err := requireNotFoundOrOK(resp, 403)
+	if err != nil || !found {
+		return nil, err
+	}
+
+	var out VirtualController
+	if err := decodeBody(resp, &out); err != nil {
+		return nil, err
+	}
+
+	return &out, nil
+}
+
+type MountVirtualControllerRequest struct {
+	ID                   string `json:"id"`
+	IsoPath              string `json:"isoPath,omitempty"`
+	ContentLibraryItemId string `json:"contentLibraryitemId,omitempty"`
+}
+
+func (n *VirtualControllerClient) Mount(ctx context.Context, req *MountVirtualControllerRequest) (string, error) {
+	r := n.c.newRequest("PATCH", "/api/compute/v1/vcenters/virtual_controllers/cdrom/mount")
+	r.obj = req
+	return n.c.doRequestAndReturnActivity(ctx, r)
+}
+
+func (n *VirtualControllerClient) Unmount(ctx context.Context, id string) (string, error) {
+	r := n.c.newRequest("PATCH", "/api/compute/v1/vcenters/virtual_controllers/cdrom/unmount")
+	r.obj = map[string]string{"id": id}
+	return n.c.doRequestAndReturnActivity(ctx, r)
+}
+
+func (n *VirtualControllerClient) Connect(ctx context.Context, id string) (string, error) {
+	r := n.c.newRequest("PATCH", "/api/compute/v1/vcenters/virtual_controllers/cdrom/connect")
+	r.obj = map[string]string{"id": id}
+	return n.c.doRequestAndReturnActivity(ctx, r)
+}
+
+func (n *VirtualControllerClient) Disconnect(ctx context.Context, id string) (string, error) {
+	r := n.c.newRequest("PATCH", "/api/compute/v1/vcenters/virtual_controllers/cdrom/disconnect")
+	r.obj = map[string]string{"id": id}
+	return n.c.doRequestAndReturnActivity(ctx, r)
+}
+
+func (n *VirtualControllerClient) Delete(ctx context.Context, id string) (string, error) {
+	r := n.c.newRequest("DELETE", "/api/compute/v1/vcenters/virtual_controllers/%s", id)
+	return n.c.doRequestAndReturnActivity(ctx, r)
+}
diff --git a/internal/provider/provider.go b/internal/provider/provider.go
@@ -121,6 +121,7 @@ func New(version string) func() *schema.Provider {
 			ResourcesMap: map[string]*schema.Resource{
 				"cloudtemple_backup_sla_policy_assignment": documentResource(resourceBackupSLAPolicyAssignment(), "backup_read", "backup_write", "activity_read"),
 				"cloudtemple_compute_network_adapter":      documentResource(resourceNetworkAdapter(), "compute_write", "compute_read", "activity_read"),
+				"cloudtemple_compute_virtual_controller":   documentResource(resourceVirtualController(), "compute_write", "compute_read", "activity_read"),
 				"cloudtemple_compute_virtual_disk":         documentResource(resourceVirtualDisk(), "compute_write", "compute_read", "compute_management_read", "compute_management_write", "activity_read"),
 				"cloudtemple_compute_virtual_machine":      documentResource(resourceVirtualMachine(), "compute_write", "compute_read", "activity_read", "tag_read", "tag_write"),
 				"cloudtemple_iam_personal_access_token":    documentResource(resourcePersonalAccessToken(), "iam_offline_access"),

diff --git a/internal/provider/resource_compute_virtual_controller.go b/internal/provider/resource_compute_virtual_controller.go
@@ -115,23 +115,23 @@ func computeVirtualControllerCreate(ctx context.Context, d *schema.ResourceData,
 	// 	return diag.Errorf("the virtual controller could not be connected: %s", err)
 	// }
 
-	if d.Get("mounted").(bool) {
-		activityId, err = c.Compute().VirtualController().Mount(ctx, &client.MountVirtualControllerRequest{
-			ID:                   d.Id(),
-			IsoPath:              d.Get("iso_path").(string),
-			ContentLibraryItemId: d.Get("content_library_item_id").(string),
-		})
-		if err != nil {
-			return diag.Errorf("failed to mount virtual controller: %s", err)
-		}
-		_, err := c.Activity().WaitForCompletion(ctx, activityId, getWaiterOptions(ctx))
-		if err != nil {
-			return diag.Errorf("failed to mount virtual controller, %s", err)
-		}
-	}
-	if err != nil {
-		return diag.Errorf("the virtual controller could not be mounted: %s", err)
-	}
+	// if d.Get("mounted").(bool) {
+	// 	activityId, err = c.Compute().VirtualController().Mount(ctx, &client.MountVirtualControllerRequest{
+	// 		ID:                   d.Id(),
+	// 		IsoPath:              d.Get("iso_path").(string),
+	// 		ContentLibraryItemId: d.Get("content_library_item_id").(string),
+	// 	})
+	// 	if err != nil {
+	// 		return diag.Errorf("failed to mount virtual controller: %s", err)
+	// 	}
+	// 	_, err := c.Activity().WaitForCompletion(ctx, activityId, getWaiterOptions(ctx))
+	// 	if err != nil {
+	// 		return diag.Errorf("failed to mount virtual controller, %s", err)
+	// 	}
+	// }
+	// if err != nil {
+	// 	return diag.Errorf("the virtual controller could not be mounted: %s", err)
+	// }
 
 	return computeVirtualControllerUpdate(ctx, d, meta)
 }
@@ -175,7 +175,7 @@ func computeVirtualControllerUpdate(ctx context.Context, d *schema.ResourceData,
 	if d.HasChange("mounted") {
 		var activityId string
 		var err error
-		if d.Get("mounted") == true {
+		if d.Get("mounted").(bool) {
 			activityId, err = c.Compute().VirtualController().Mount(ctx, &client.MountVirtualControllerRequest{
 				ID:                   d.Id(),
 				IsoPath:              d.Get("iso_path").(string),