Feat/volume groups

meta/runtime.yml

@@ -71,3 +71,4 @@ action_groups:
   - ntnx_ndb_slas_info
   - ntnx_ndb_databases
   - ntnx_ndb_clusters_info
+  - ntnx_volume_groups

plugins/module_utils/prism/iscsi_clients.py

@@ -0,0 +1,54 @@
+# This file is part of Ansible
+# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
+from __future__ import absolute_import, division, print_function
+
+__metaclass__ = type
+
+from copy import deepcopy
+
+
+class Clients:
+    @classmethod
+    def get_spec(cls, iscsi_client, chap_auth=False):
+        payload = cls._get_default_spec()
+        spec, error = cls._build_spec_iscsi_client(payload, iscsi_client, chap_auth)
+        if error:
+            return None, error
+        return spec, None
+
+    @staticmethod
+    def _get_default_spec():
+        return deepcopy({"enabledAuthentications": "NONE"})
+
+    @staticmethod
+    def _build_spec_iscsi_client(payload, iscsi_client, chap_auth):
+
+        if iscsi_client.get("uuid"):
+            payload["extId"] = iscsi_client["uuid"]
+        elif iscsi_client.get("iscsi_iqn"):
+            payload["iscsiInitiatorName"] = iscsi_client["iscsi_iqn"]
+        elif iscsi_client.get("iscsi_ip"):
+            payload["iscsiInitiatorNetworkId"] = {
+                "$objectType": "common.v1.config.IPAddressOrFQDN",
+                "$reserved": {
+                    "$fqObjectType": "common.v1.r0.a3.config.IPAddressOrFQDN"
+                },
+                "$unknownFields": {},
+                "ipv4": {
+                    "$objectType": "common.v1.config.IPv4Address",
+                    "$reserved": {
+                        "$fqObjectType": "common.v1.r0.a3.config.IPv4Address"
+                    },
+                    "$unknownFields": {},
+                    "value": iscsi_client["iscsi_ip"],
+                },
+            }
+        if iscsi_client.get("client_password"):
+            if chap_auth:
+                payload["clientSecret"] = iscsi_client["client_password"]
+
+                payload["enabledAuthentications"] = "CHAP"
+            else:
+                error = "parameters are required together: CHAP_auth, client_password"
+                return None, error
+        return payload, None

plugins/module_utils/prism/vdisks.py

@@ -0,0 +1,55 @@
+# This file is part of Ansible
+# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
+from __future__ import absolute_import, division, print_function
+
+__metaclass__ = type
+
+from copy import deepcopy
+
+from .groups import get_entity_uuid
+
+
+class VDisks:
+    @classmethod
+    def get_spec(cls, module, vdisk):
+        payload = cls._get_default_spec()
+        spec, error = cls._build_spec_vdisk(module, payload, vdisk)
+        if error:
+            return None, error
+        return spec, None
+
+    @staticmethod
+    def _get_default_spec():
+        return deepcopy(
+            {
+                "diskSizeBytes": None,
+                "diskDataSourceReference": {
+                    "$objectType": "common.v1.config.EntityReference",
+                    "$reserved": {
+                        "$fqObjectType": "common.v1.r0.a3.config.EntityReference"
+                    },
+                    "$unknownFields": {},
+                    "extId": None,
+                    "entityType": "STORAGE_CONTAINER",
+                },
+            }
+        )
+
+    @staticmethod
+    def _build_spec_vdisk(module, payload, vdisk):
+
+        disk_size_bytes = vdisk["size_gb"] * 1024 * 1024 * 1024
+
+        payload["diskSizeBytes"] = disk_size_bytes
+        uuid, error = get_entity_uuid(
+            vdisk["storage_container"],
+            module,
+            key="container_name",
+            entity_type="storage_container",
+        )
+        if error:
+            return None, error
+
+        payload["diskDataSourceReference"]["extId"] = uuid
+
+        return payload, None

plugins/module_utils/prism/volume_groups.py

@@ -0,0 +1,156 @@
+# This file is part of Ansible
+# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
+from __future__ import absolute_import, division, print_function
+
+__metaclass__ = type
+
+from copy import deepcopy
+
+from .clusters import get_cluster_uuid
+from .prism import Prism
+from .vms import get_vm_uuid
+
+
+class VolumeGroup(Prism):
+    __BASEURL__ = "/api/storage/v4.0.a2/config"
+
+    def __init__(self, module):
+        resource_type = "/volume-groups"
+        super(VolumeGroup, self).__init__(module, resource_type=resource_type)
+        self.build_spec_methods = {
+            "name": self._build_spec_name,
+            "desc": self._build_spec_desc,
+            "cluster": self._build_spec_cluster,
+            "target_prefix": self._build_spec_target_prefix,
+            "target_password": self._build_spec_target_password,
+            "load_balance": self._build_spec_load_balance,
+            "flash_mode": self._build_spec_flash_mode,
+        }
+
+    def create_vdisk(self, spec, volume_group_uuid, method="POST", endpoint="disks"):
+
+        resp = self.update(spec, volume_group_uuid, method=method, endpoint=endpoint)
+        resp["task_uuid"] = resp["data"]["extId"][-36:]
+        return resp
+
+    def attach_vm(
+        self, spec, volume_group_uuid, method="POST", endpoint="$actions/attach-vm"
+    ):
+
+        resp = self.update(spec, volume_group_uuid, method=method, endpoint=endpoint)
+        resp["task_uuid"] = resp["data"]["extId"][-36:]
+        return resp
+
+    def attach_iscsi_client(
+        self,
+        spec,
+        volume_group_uuid,
+        method="POST",
+        endpoint="/$actions/attach-iscsi-client",
+    ):
+
+        resp = self.update(spec, volume_group_uuid, method=method, endpoint=endpoint)
+        resp["task_uuid"] = resp["data"]["extId"][-36:]
+        return resp
+
+    def detach_vm(self, volume_group_uuid, vm, method="POST"):
+        vm_uuid = vm["extId"]
+        endpoint = "$actions/detach-vm/{0}".format(vm_uuid)
+        resp = self.update(uuid=volume_group_uuid, method=method, endpoint=endpoint)
+        resp["task_uuid"] = resp["data"]["extId"][-36:]
+        return resp
+
+    def detach_iscsi_client(self, volume_group_uuid, client, method="POST"):
+        client_uuid = client["extId"]
+        endpoint = "$actions/detach-iscsi-client/{0}".format(client_uuid)
+        resp = self.update(uuid=volume_group_uuid, method=method, endpoint=endpoint)
+        resp["task_uuid"] = resp["data"]["extId"][-36:]
+        return resp
+
+    def _get_default_spec(self):
+        return deepcopy(
+            {
+                "name": "",
+                "loadBalanceVmAttachments": False,
+                "sharingStatus": "SHARED",
+                "clusterReference": None,
+                "usageType": "USER",
+            }
+        )
+
+    def _build_spec_name(self, payload, value):
+        payload["name"] = value
+        return payload, None
+
+    def _build_spec_desc(self, payload, value):
+        payload["description"] = value
+        return payload, None
+
+    def _build_spec_target_prefix(self, payload, value):
+        payload["iscsiTargetPrefix"] = value
+        return payload, None
+
+    def _build_spec_target_password(self, payload, value):
+        payload["targetSecret"] = value
+        payload["enabledAuthentications"] = "CHAP"
+        return payload, None
+
+    def _build_spec_load_balance(self, payload, value):
+        payload["loadBalanceVmAttachments"] = value
+        return payload, None
+
+    def _build_spec_flash_mode(self, payload, value):
+
+        if value:
+            payload["storageFeatures"] = {
+                "$objectType": "storage.v4.config.StorageFeatures",
+                "$reserved": {
+                    "$fqObjectType": "storage.v4.r0.a2.config.StorageFeatures"
+                },
+                "$unknownFields": {},
+                "flashMode": {
+                    "$objectType": "storage.v4.config.FlashMode",
+                    "$reserved": {"$fqObjectType": "storage.v4.r0.a2.config.FlashMode"},
+                    "$unknownFields": {},
+                    "isEnabled": True,
+                },
+            }
+        return payload, None
+
+    def _build_spec_cluster(self, payload, param):
+        uuid, err = get_cluster_uuid(param, self.module)
+        if err:
+            return None, err
+        payload["clusterReference"] = uuid
+        return payload, None
+
+    def get_vm_spec(self, vm):
+        uuid, error = get_vm_uuid(vm, self.module)
+        if error:
+            return None, error
+        spec = {"extId": uuid}
+        return spec, None
+
+    def get_client_spec(self, client):
+        spec = {"extId": client["uuid"]}
+        return spec, None
+
+
+# Helper functions
+
+
+def get_volume_group_uuid(config, module):
+    if "name" in config:
+        service_group = VolumeGroup(module)
+        name = config["name"]
+        uuid = service_group.get_uuid(name)
+        if not uuid:
+            error = "Volume Group {0} not found.".format(name)
+            return None, error
+    elif "uuid" in config:
+        uuid = config["uuid"]
+    else:
+        error = "Config {0} doesn't have name or uuid key".format(config)
+        return None, error
+
+    return uuid, None