add NetApp mapping view interface

delfin/drivers/netapp/dataontap/cluster_mode.py

@@ -91,3 +91,16 @@ def get_capabilities(context, filters=None):
 
     def get_latest_perf_timestamp(self, context):
         return self.netapp_handler.get_latest_perf_timestamp()
+
+    def list_storage_host_initiators(self, context):
+        return self.netapp_handler.\
+            list_storage_host_initiators(self.storage_id)
+
+    def list_port_groups(self, context):
+        return self.netapp_handler.list_port_groups(self.storage_id)
+
+    def list_masking_views(self, context):
+        return self.netapp_handler.list_masking_views(self.storage_id)
+
+    def list_storage_hosts(self, context):
+        return self.netapp_handler.list_storage_hosts(self.storage_id)

delfin/drivers/netapp/dataontap/constants.py

@@ -67,6 +67,9 @@
 FLOAT_PATTERN = r"\d\.\d"
 IP_PATTERN = re.compile(r'(([01]{0,1}\d{0,1}\d|2[0-4]\d|25[0-5])\.){3}'
                         r'([01]{0,1}\d{0,1}\d|2[0-4]\d|25[0-5])$')
+IQN_PATTERN = re.compile('^[i][q][n].')
+WWN_PATTERN = re.compile('^(([a-z|0-9]){2}:){7}(([a-z|0-9]){2})')
+INITIATOR_KEY = 'loggedin'
 CLUSTER_SHOW_COMMAND = "cluster identity show"
 VERSION_SHOW_COMMAND = "version"
 STORAGE_STATUS_COMMAND = "system health status show"
@@ -118,6 +121,17 @@
 CONTROLLER_IP_COMMAND = "network interface show -fields " \
                         "curr-node,address -role node-mgmt"
 
+HOST_COMMAND = "igroup show -instance"
+
+PORT_GROUP_COMMAND = "portset show -instance"
+LIF_COMMAND = "network interface show -instance"
+
+FC_INITIATOR_COMMAND = "fcp initiator show -instance"
+
+ISCSI_INITIATOR_COMMAND = "iscsi initiator show -instance"
+
+LUN_MAPPING_COMMAND = 'lun mapping show -instance'
+
 SECURITY_STYLE = {
     'mixed': constants.NASSecurityMode.MIXED,
     'ntfs': constants.NASSecurityMode.NTFS,
@@ -640,3 +654,16 @@
     "readIops": READ_IOPS_DESCRIPTION,
     "writeIops": WRITE_IOPS_DESCRIPTION,
 }
+
+HOST_OS_TYPE_MAP = {
+    'solaris': constants.HostOSTypes.SOLARIS,
+    'windows': constants.HostOSTypes.WINDOWS,
+    'hpux': constants.HostOSTypes.HP_UX,
+    'aix': constants.HostOSTypes.AIX,
+    'linux': constants.HostOSTypes.LINUX,
+    'netware': constants.HostOSTypes.UNKNOWN,
+    'vmware': constants.HostOSTypes.VMWARE_ESX,
+    'openvms': constants.HostOSTypes.OPEN_VMS,
+    'xen': constants.HostOSTypes.XEN_SERVER,
+    'hyper_v': constants.HostOSTypes.UNKNOWN
+}

delfin/drivers/netapp/dataontap/mapping_handler.py

@@ -0,0 +1,247 @@
+# Copyright 2021 The SODA Authors.
+#
+# Licensed 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.
+from delfin.common import constants
+from delfin.drivers.netapp.dataontap import constants as constant
+from delfin.drivers.utils.tools import Tools
+
+
+class MappingHandler(object):
+
+    @staticmethod
+    def format_initiators(initiator_list, initiator_info, storage_id,
+                          protocol_type, is_default=False):
+        initiator_map_list = []
+        Tools.split_value_map_list(
+            initiator_info, initiator_map_list, is_mapping=True, split=':')
+        if not is_default and protocol_type ==\
+                constants.InitiatorType.FC:
+            MappingHandler.get_fc_initiator(
+                initiator_list, initiator_map_list, storage_id)
+        elif not is_default and protocol_type ==\
+                constants.InitiatorType.ISCSI:
+            MappingHandler.get_iscsi_initiator(
+                initiator_list, initiator_map_list, storage_id)
+        if is_default:
+            MappingHandler.get_initiator_from_host(
+                initiator_list, initiator_map_list, storage_id)
+        return initiator_list
+
+    @staticmethod
+    def duplicate_removal(initiator_list, initiator_model):
+        is_same = False
+        for initiator in initiator_list:
+            if initiator['native_storage_host_initiator_id'] \
+                    == initiator_model['native_storage_host_initiator_id']:
+                is_same = True
+                break
+        if not is_same:
+            initiator_list.append(initiator_model)
+
+    @staticmethod
+    def get_iscsi_initiator(initiator_list, initiator_map_list, storage_id):
+        for initiator_map in initiator_map_list:
+            if 'IgroupName' in initiator_map \
+                    and initiator_map.get('IgroupName') == '-':
+                initiator_id = \
+                    initiator_map.get('InitiatorName').replace(' ', '')
+                initiator_model = {
+                    'native_storage_host_initiator_id': initiator_id,
+                    'native_storage_host_id': None,
+                    'name': initiator_id,
+                    'alias': initiator_map.get('InitiatorAlias'),
+                    'type': constants.InitiatorType.ISCSI,
+                    'status': constants.InitiatorStatus.ONLINE,
+                    'wwn': initiator_id,
+                    'storage_id': storage_id,
+                }
+                MappingHandler.duplicate_removal(
+                    initiator_list, initiator_model)
+
+    @staticmethod
+    def get_fc_initiator(initiator_list, initiator_map_list, storage_id):
+        for initiator_map in initiator_map_list:
+            if 'IgroupName' in initiator_map \
+                    and initiator_map.get('IgroupName') == '-':
+                initiator_id = \
+                    initiator_map.get('InitiatorWWPN').replace(' ', '')
+                initiator_model = {
+                    'native_storage_host_initiator_id': initiator_id,
+                    'native_storage_host_id': None,
+                    'name': initiator_id,
+                    'alias': initiator_map.get('InitiatorWWPNAlias'),
+                    'type': constants.InitiatorType.FC,
+                    'status': constants.InitiatorStatus.ONLINE,
+                    'wwn': initiator_map.get('InitiatorWWPN'),
+                    'storage_id': storage_id,
+                }
+                MappingHandler.duplicate_removal(
+                    initiator_list, initiator_model)
+
+    @staticmethod
+    def get_initiator_type(protocol_type, initiator_name):
+        if protocol_type != 'mixed':
+            return constant.NETWORK_PORT_TYPE.get(protocol_type)
+        else:
+            if constant.IQN_PATTERN.search(initiator_name):
+                return constants.PortType.ISCSI
+            elif constant.WWN_PATTERN.search(initiator_name):
+                return constants.PortType.FC
+            return None
+
+    @staticmethod
+    def format_initiator(data_map, initiator_id, storage_id):
+        initiator_id = initiator_id.split('(')[0]
+        protocol_type = \
+            MappingHandler.get_initiator_type(
+                data_map.get('Protocol'), initiator_id)
+        host_id = '%s_%s' % (data_map.get('VserverName'),
+                             data_map.get('IgroupName'))
+        initiator_model = {
+            'native_storage_host_initiator_id': initiator_id,
+            'native_storage_host_id': host_id,
+            'name': initiator_id,
+            'type': protocol_type,
+            'status': constants.InitiatorStatus.ONLINE,
+            'storage_id': storage_id,
+            'wwn': initiator_id
+        }
+        return initiator_model
+
+    @staticmethod
+    def get_initiator_from_host(
+            initiator_list, initiator_map_list, storage_id):
+        for initiator_map in initiator_map_list:
+            if 'IgroupName' in initiator_map:
+                initiator_id = \
+                    initiator_map.get('Initiators').replace(' ', '')
+                if initiator_map.get('Initiators') != '-':
+                    initiator_list.append(
+                        MappingHandler.format_initiator(
+                            initiator_map, initiator_id, storage_id))
+                for key in initiator_map:
+                    if constant.INITIATOR_KEY in key and key != '-':
+                        initiator_list.append(
+                            MappingHandler.format_initiator(
+                                initiator_map, key, storage_id))
+
+    @staticmethod
+    def format_host(initiator_info, storage_id):
+        initiator_map_list, initiator_list = [], []
+        Tools.split_value_map_list(initiator_info,
+                                   initiator_map_list,
+                                   split=':')
+        for initiator_map in initiator_map_list:
+            if 'IgroupName' in initiator_map:
+                host_id = '%s_%s' % (initiator_map.get('VserverName'),
+                                     initiator_map.get('IgroupName'))
+                initiator_model = {
+                    'native_storage_host_id': host_id,
+                    'name': initiator_map.get('IgroupName'),
+                    'os_type':
+                        constant.HOST_OS_TYPE_MAP.get(
+                            initiator_map.get('OSType')),
+                    'status': constants.HostStatus.NORMAL,
+                    'storage_id': storage_id,
+                }
+                initiator_list.append(initiator_model)
+        return initiator_list
+
+    @staticmethod
+    def format_port_group(port_set_info, lif_info, storage_id):
+        port_map_list, port_group_list = [], []
+        lif_map_list, port_group_relation_list = [], []
+        Tools.split_value_map_list(port_set_info, port_map_list, split=':')
+        Tools.split_value_map_list(lif_info, lif_map_list, split=':')
+        for port_map in port_map_list:
+            if 'PortsetName' in port_map:
+                port_group_id = "%s-%s-%s" % \
+                                (port_map.get('VserverName'),
+                                 port_map.get('PortsetName'),
+                                 port_map.get('Protocol'))
+                ports = \
+                    port_map.get('LIFOrTPGName').replace(' ', '').split(',')
+                ports_str = ''
+                for lif_map in lif_map_list:
+                    if 'LogicalInterfaceName' in lif_map:
+                        if lif_map.get('LogicalInterfaceName') in ports:
+                            port_id = "%s_%s" % \
+                                      (lif_map['CurrentNode'],
+                                       lif_map['CurrentPort'])
+                            port_group_relation = {
+                                'storage_id': storage_id,
+                                'native_port_group_id': port_group_id,
+                                'native_port_id': port_id
+                            }
+                            port_group_relation_list.append(
+                                port_group_relation)
+                            if ports_str:
+                                ports_str = \
+                                    "{0},{1}".format(ports_str, port_id)
+                            else:
+                                ports_str = "{0}".format(port_id)
+
+                port_group_model = {
+                    'native_port_group_id': port_group_id,
+                    'name': port_map.get('PortsetName'),
+                    'ports': ports_str,
+                    'storage_id': storage_id,
+                }
+                port_group_list.append(port_group_model)
+        result = {
+            'port_groups': port_group_list,
+            'port_grp_port_rels': port_group_relation_list
+        }
+        return result
+
+    @staticmethod
+    def format_mapping_view(mapping_info, volume_info, storage_id, host_list):
+        mapping_map_list, mapping_view_list, volume_map_list = [], [], []
+        Tools.split_value_map_list(mapping_info, mapping_map_list, split=":")
+        Tools.split_value_map_list(volume_info, volume_map_list, split=":")
+        for mapping_map in mapping_map_list:
+            if 'LUNPath' in mapping_map:
+                host_id = '%s_%s' % (mapping_map.get('VserverName'),
+                                     mapping_map.get('IgroupName'))
+                native_masking_view_id = \
+                    '%s_%s_%s_%s' % (mapping_map.get('LUNNode'),
+                                     mapping_map.get('VserverName'),
+                                     mapping_map.get('IgroupName'),
+                                     mapping_map.get('LUNName'))
+                name = '%s_%s' % (mapping_map.get('IgroupName'),
+                                  mapping_map.get('LUNName'))
+                port_group_id = "%s-%s-%s" % \
+                                (mapping_map.get('VserverName'),
+                                 mapping_map.get('PortsetBindingIgroup'),
+                                 mapping_map.get('IgroupProtocolType'))
+                native_volume_id = None
+                for volume_map in volume_map_list:
+                    if 'LUNName' in volume_map:
+                        if volume_map.get('LUNName') == \
+                                mapping_map.get('LUNName') \
+                                and volume_map.get('VserverName') == \
+                                mapping_map.get('VserverName') \
+                                and volume_map.get('LUNPath') == \
+                                mapping_map.get('LUNPath'):
+                            native_volume_id = volume_map['SerialNumber']
+                mapping_view = {
+                    'native_masking_view_id':
+                        native_masking_view_id,
+                    'name': name,
+                    'native_port_group_id': port_group_id,
+                    'native_storage_host_id': host_id,
+                    'native_volume_id': native_volume_id,
+                    'storage_id': storage_id,
+                }
+                mapping_view_list.append(mapping_view)
+        return mapping_view_list