update

from common.method_wrappers.Decorator import MetricsPool, safe_and_metered_rpc_method

from common.proto.e2eorchestrator_pb2 import E2EOrchestratorRequest, E2EOrchestratorReply

from common.proto.context_pb2 import (

    Empty, Connection, EndPointId, Link, LinkId, TopologyDetails, Topology, Context, Service, ServiceId, ServiceTypeEnum,

    ServiceStatusEnum)

    Empty, Connection, EndPointId, Link, LinkId, TopologyDetails, Topology, Context, Service, ServiceId,

    ServiceTypeEnum, ServiceStatusEnum)

from common.proto.e2eorchestrator_pb2_grpc import E2EOrchestratorServiceServicer

from context.client.ContextClient import ContextClient

from service.client.ServiceClient import ServiceClient

            message_json = json.loads(message)

            # LOGGER.info("message_json: {}".format(message_json))

            # Link creation

            if 'link_id' in message_json:

                link = Link(**message_json)

                # service_client.UpdateService(service)

                connection.send(grpc_message_to_json_string(link))

            # Link removal

            elif 'link_uuid' in message_json:

                LOGGER.info('REMOVING VIRTUAL LINK')

                link_id = LinkId(**message_json)

                service_id.context_id.context_uuid.uuid = DEFAULT_CONTEXT_NAME

                # service_client.DeleteService(service_id)

                connection.send(grpc_message_to_json_string(link_id))

                context_client.RemoveLink(link_id)

            # Topology received

            else:

                LOGGER.info('TOPOLOGY')

                topology_details = TopologyDetails(**message_json)