diff --git a/src/interdomain/service/topology_abstractor/DltRecordSender.py b/src/interdomain/service/topology_abstractor/DltRecordSender.py index b49af3310c863bd76d86e2d0925bef9115914015..0a2019a78014546e01cae7e7350d8021fc0eaafa 100644 --- a/src/interdomain/service/topology_abstractor/DltRecordSender.py +++ b/src/interdomain/service/topology_abstractor/DltRecordSender.py @@ -66,7 +66,8 @@ class DltRecordSender: for dlt_record_uuid in self.dlt_record_uuids: topology_id,dlt_record = self.dlt_record_uuid_to_data[dlt_record_uuid] if isinstance(dlt_record, Device): - device_id = self.context_client.SetDevice(dlt_record) # Se retriggerea el Evento. + #device_id = self.context_client.SetDevice(dlt_record) # This causes events to be triggered infinitely. + device_id = dlt_record.device_id.device_uuid.uuid #LOGGER.debug('DEVICE_ID: ({:s})'.format(grpc_message_to_json_string(device_id))) if self.dlt_connector_client is None: continue dlt_device_id = DltDeviceId() @@ -74,21 +75,24 @@ class DltRecordSender: dlt_device_id.device_id.CopyFrom(device_id) # pylint: disable=no-member self.dlt_connector_client.RecordDevice(dlt_device_id) elif isinstance(dlt_record, Link): - link_id = self.context_client.SetLink(dlt_record) + #link_id = self.context_client.SetLink(dlt_record) + link_id = dlt_record.link_id.link_uuid.uuid if self.dlt_connector_client is None: continue dlt_link_id = DltLinkId() dlt_link_id.topology_id.CopyFrom(topology_id) # pylint: disable=no-member dlt_link_id.link_id.CopyFrom(link_id) # pylint: disable=no-member self.dlt_connector_client.RecordLink(dlt_link_id) elif isinstance(dlt_record, Service): - service_id = self.context_client.SetService(dlt_record) + #service_id = self.context_client.SetService(dlt_record) + service_id = dlt_record.service_id.service_uuid.uuid if self.dlt_connector_client is None: continue dlt_service_id = DltServiceId() dlt_service_id.topology_id.CopyFrom(topology_id) # pylint: disable=no-member dlt_service_id.service_id.CopyFrom(service_id) # pylint: disable=no-member self.dlt_connector_client.RecordService(dlt_service_id) elif isinstance(dlt_record, Slice): - slice_id = self.context_client.SetSlice(dlt_record) + #slice_id = self.context_client.SetSlice(dlt_record) + slice_id = dlt_record.slice_id.slice_uuid.uuid if self.dlt_connector_client is None: continue dlt_slice_id = DltSliceId() dlt_slice_id.topology_id.CopyFrom(topology_id) # pylint: disable=no-member