SIMAP Updater

from simap_connector.service.telemetry.worker._Worker import WorkerTypeEnum

from simap_connector.service.telemetry.TelemetryPool import SynthesizerWorker, TelemetryPool

from .AllowedLinks import ALLOWED_LINKS_PER_CONTROLLER, LINKS_CAPACITY

from .MockSimaps import delete_mock_simap, set_mock_simap

# from .MockSimaps import delete_mock_simap, set_mock_simap

from .ObjectCache import CachedEntities, ObjectCache

from .SimapClient import SimapClient

from .Tools import get_device_endpoint, get_link_endpoint, get_connection_endpoints_and_links #, get_service_endpoint

            return False

        domain_name = topology_names.pop()  # trans-pkt/agg-net/e2e-net

        set_mock_simap(self._simap_client, domain_name)

        # set_mock_simap(self._simap_client, domain_name)

        #domain_topo = self._simap_client.network(domain_name)

        #domain_topo.update()

            return

        domain_name = topology_names.pop()  # trans-pkt/agg-net/e2e-net

        delete_mock_simap(self._simap_client, domain_name)

        # delete_mock_simap(self._simap_client, domain_name)

        #domain_topo = self._simap_client.network(domain_name)

        #domain_topo.update()

            LOGGER.warning('Connection {:s} not found in cache'.format(connection_uuid))

            return None

        MSG = 'Processing Connection: {:s}'

        LOGGER.info(MSG.format(grpc_message_to_json_string(connection)))

        # NOTE: Actual Connection event object does not include service_id.

        _, link_uuids = get_connection_endpoints_and_links(connection_uuid)