Merge branch 'develop' of https://labs.etsi.org/rep/tfs/controller into... (5cbd46dc) · Commits · TFS / controller

src/device/service/drivers/openconfig/templates/Acl.py

+33 −31

Original line number	Diff line number	Diff line
		@@ -20,7 +20,7 @@ from .Tools import add_value_from_tag
		LOGGER = logging.getLogger(__name__)

		XPATH_ACL_SET = "//ocacl:acl/ocacl:acl-sets/ocacl:acl-set"
		XPATH_A_ACL_ENTRY = ".//ocacl:acl-entries/ocacl:ecl-entry"
		XPATH_A_ACL_ENTRY = ".//ocacl:acl-entries/ocacl:acl-entry"
		XPATH_A_IPv4 = ".//ocacl:ipv4/ocacl:config"
		XPATH_A_TRANSPORT = ".//ocacl:transport/ocacl:config"
		XPATH_A_ACTIONS = ".//ocacl:actions/ocacl:config"
		@@ -34,29 +34,31 @@ def parse(xml_data : ET.Element) -> List[Tuple[str, Dict[str, Any]]]:

		response = []
		acl = {}
		name = {}

		for xml_acl in xml_data.xpath(XPATH_ACL_SET, namespaces=NAMESPACES):
		#LOGGER.info('xml_acl = {:s}'.format(str(ET.tostring(xml_acl))))

		acl_name = xml_acl.find('ocacl:name', namespaces=NAMESPACES)
		if acl_name is None or acl_name.text is None: continue
		add_value_from_tag(acl, 'name', acl_name)
		add_value_from_tag(name, 'name', acl_name)

		acl_type = xml_acl.find('ocacl:type', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'type', acl_type)

		for xml_acl_entries in xml_acl.xpath(XPATH_A_ACL_ENTRY, namespaces=NAMESPACES):

		acl_id = xml_acl_entries.find('ocacl:sequence_id', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'sequence_id', acl_id)
		acl_id = xml_acl_entries.find('ocacl:sequence-id', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'sequence-id', acl_id)
		LOGGER.info('xml_acl_id = {:s}'.format(str(ET.tostring(acl_id))))

		for xml_ipv4 in xml_acl_entries.xpath(XPATH_A_IPv4, namespaces=NAMESPACES):

		ipv4_source = xml_ipv4.find('ocacl:source_address', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'source_address' , ipv4_source)
		ipv4_source = xml_ipv4.find('ocacl:source-address', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'source-address' , ipv4_source)

		ipv4_destination = xml_ipv4.find('ocacl:destination_address', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'destination_address' , ipv4_destination)
		ipv4_destination = xml_ipv4.find('ocacl:destination-address', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'destination-address' , ipv4_destination)

		ipv4_protocol = xml_ipv4.find('ocacl:protocol', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'protocol' , ipv4_protocol)
		@@ -64,30 +66,30 @@ def parse(xml_data : ET.Element) -> List[Tuple[str, Dict[str, Any]]]:
		ipv4_dscp = xml_ipv4.find('ocacl:dscp', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'dscp' , ipv4_dscp)

		ipv4_hop_limit = xml_ipv4.find('ocacl:hop_limit', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'hop_limit' , ipv4_hop_limit)
		ipv4_hop_limit = xml_ipv4.find('ocacl:hop-limit', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'hop-limit' , ipv4_hop_limit)

		for xml_transport in xml_acl_entries.xpath(XPATH_A_TRANSPORT, namespaces=NAMESPACES):

		transport_source = xml_transport.find('ocacl:source_port', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'source_port' ,transport_source)
		transport_source = xml_transport.find('ocacl:source-port', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'source-port' ,transport_source)

		transport_destination = xml_transport.find('ocacl:destination_port', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'destination_port' ,transport_destination)
		transport_destination = xml_transport.find('ocacl:destination-port', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'destination-port' ,transport_destination)

		transport_tcp_flags = xml_transport.find('ocacl:tcp_flags', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'tcp_flags' ,transport_tcp_flags)
		transport_tcp_flags = xml_transport.find('ocacl:tcp-flags', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'tcp-flags' ,transport_tcp_flags)

		for xml_action in xml_acl_entries.xpath(XPATH_A_ACTIONS, namespaces=NAMESPACES):

		action = xml_action.find('ocacl:forwarding_action', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'forwarding_action' ,action)
		action = xml_action.find('ocacl:forwarding-action', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'forwarding-action' ,action)

		log_action = xml_action.find('ocacl:log_action', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'log_action' ,log_action)
		log_action = xml_action.find('ocacl:log-action', namespaces=NAMESPACES)
		add_value_from_tag(acl, 'log-action' ,log_action)

		resource_key = '/acl/acl-set[{:s}][{:s}]/acl-entry[{:s}]'.format(
		acl['name'], acl['type'], acl['sequence-id'])
		name['name'], acl['type'], acl['sequence-id'])
		response.append((resource_key,acl))

		for xml_interface in xml_data.xpath(XPATH_INTERFACE, namespaces=NAMESPACES):
		@@ -99,25 +101,25 @@ def parse(xml_data : ET.Element) -> List[Tuple[str, Dict[str, Any]]]:

		for xml_ingress in xml_interface.xpath(XPATH_I_INGRESS, namespaces=NAMESPACES):

		i_name = xml_ingress.find('ocacl:set_name_ingress', namespaces=NAMESPACES)
		add_value_from_tag(interface, 'ingress_set_name' , i_name)
		i_name = xml_ingress.find('ocacl:set-name-ingress', namespaces=NAMESPACES)
		add_value_from_tag(interface, 'ingress-set-name' , i_name)

		i_type = xml_ingress.find('ocacl:type_ingress', namespaces=NAMESPACES)
		add_value_from_tag(interface, 'ingress_type' , i_type)
		i_type = xml_ingress.find('ocacl:type-ingress', namespaces=NAMESPACES)
		add_value_from_tag(interface, 'ingress-type' , i_type)

		resource_key = '/acl/interfaces/ingress[{:s}][{:s}]'.format(
		acl['name'], acl['type'])
		name['name'], acl['type'])
		response.append((resource_key,interface))

		for xml_egress in xml_interface.xpath(XPATH_I_EGRESS, namespaces=NAMESPACES):

		e_name = xml_egress.find('ocacl:set_name_egress', namespaces=NAMESPACES)
		add_value_from_tag(interface, 'egress_set_name' , e_name)
		e_name = xml_egress.find('ocacl:set-name-egress', namespaces=NAMESPACES)
		add_value_from_tag(interface, 'egress-set-name' , e_name)

		e_type = xml_egress.find('ocacl:type_egress', namespaces=NAMESPACES)
		add_value_from_tag(interface, 'egress_type' , e_type)
		e_type = xml_egress.find('ocacl:type-egress', namespaces=NAMESPACES)
		add_value_from_tag(interface, 'egress-type' , e_type)

		resource_key = '/acl/interfaces/egress[{:s}][{:s}]'.format(
		acl['name'], acl['type'])
		name['name'], acl['type'])
		response.append((resource_key,interface))
		return response

src/device/service/drivers/openconfig/templates/NetworkInstances.py

+17 −0

Original line number	Diff line number	Diff line
		@@ -23,6 +23,8 @@ XPATH_NETWORK_INSTANCES = "//ocni:network-instances/ocni:network-instance"
		XPATH_NI_PROTOCOLS = ".//ocni:protocols/ocni:protocol"
		XPATH_NI_TABLE_CONNECTS = ".//ocni:table-connections/ocni:table-connection"

		XPATH_NI_INTERFACE = ".//ocni:interfaces/ocni:interface"

		XPATH_NI_IIP_AP = ".//ocni:inter-instance-policies/ocni:apply-policy"
		XPATH_NI_IIP_AP_IMPORT = ".//ocni:config/ocni:import-policy"
		XPATH_NI_IIP_AP_EXPORT = ".//ocni:config/ocni:export-policy"
		@@ -136,6 +138,21 @@ def parse(xml_data : ET.Element) -> List[Tuple[str, Dict[str, Any]]]:
		table_connection['address_family'])
		response.append((resource_key, table_connection))

		for xml_interface in xml_network_instance.xpath(XPATH_NI_INTERFACE, namespaces=NAMESPACES):
		LOGGER.info('xml_interfaces = {:s}'.format(str(ET.tostring(xml_interface))))

		interface = {}
		name_iface = xml_interface.find('ocni:config/ocni:interface', namespaces=NAMESPACES)
		if name_iface is None or name_iface.text is None: continue
		add_value_from_tag(interface, 'name_iface', name_iface)

		name_subiface = xml_interface.find('ocni:config/ocni:subinterface', namespaces=NAMESPACES)
		add_value_from_tag(interface, 'name_subiface', name_subiface)

		resource_key = '/network_instance[{:s}]/interface[{:s}]'.format(
		network_instance['name'], interface['name_iface'])
		response.append((resource_key, interface))

		for xml_iip_ap in xml_network_instance.xpath(XPATH_NI_IIP_AP, namespaces=NAMESPACES):
		#LOGGER.info('xml_iip_ap = {:s}'.format(str(ET.tostring(xml_iip_ap))))

src/webui/service/device/routes.py

+10 −0

Original line number	Diff line number	Diff line
		@@ -165,6 +165,16 @@ def inventory(device_uuid: str):
		context_client.close()
		return render_template('device/inventory.html', device=device_obj)

		@device.route('logical/<path:device_uuid>', methods=['GET', 'POST'])
		def logical(device_uuid: str):
		context_client.connect()
		device_obj = get_device(context_client, device_uuid, rw_copy=False)
		if device_obj is None:
		flash('Device({:s}) not found'.format(str(device_uuid)), 'danger')
		device_obj = Device()
		context_client.close()
		return render_template('device/logical.html', device=device_obj)

		@device.get('<path:device_uuid>/delete')
		def delete(device_uuid):
		try:

src/webui/service/templates/device/home.html

+9 −0

Original line number	Diff line number	Diff line
		@@ -51,6 +51,7 @@
		<th scope="col">Config Rules</th>
		<th scope="col"></th>
		<th scope="col"></th>
		<th scope="col"></th>
		</tr>
		</thead>
		<tbody>
		@@ -83,6 +84,14 @@
		</svg>
		</a>
		</td>
		<td>
		<a href="{{ url_for('device.logical', device_uuid=device.device_id.device_uuid.uuid) }}">
		<svg xmlns="http://www.w3.org/2000/svg" width="16" height="16" fill="currentColor" class="bi bi-info-circle" viewBox="0 0 16 16">
		<path d="M8 15A7 7 0 1 1 8 1a7 7 0 0 1 0 14m0 1A8 8 0 1 0 8 0a8 8 0 0 0 0 16"/>
		<path d="m8.93 6.588-2.29.287-.082.38.45.083c.294.07.352.176.288.469l-.738 3.468c-.194.897.105 1.319.808 1.319.545 0 1.178-.252 1.465-.598l.088-.416c-.2.176-.492.246-.686.246-.275 0-.375-.193-.304-.533zM9 4.5a1 1 0 1 1-2 0 1 1 0 0 1 2 0"/>
		</svg>
		</a>
		</td>
		</tr>
		{% endfor %}
		{% else %}

src/webui/service/templates/device/logical.html

0 → 100644

+397 −0

File added.

Preview size limit exceeded, changes collapsed.

Admin message