Commit 7f1e6dd1 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

E2E Orchestrator component: 

- Corrected vnt recommendations message formatting
parent 055dae1e

src/e2e_orchestrator/service/subscriptions/dispatchers/recommendation/ClientNamespace.py

+2 −2
Original line number Diff line number Diff line
@@ -54,7 +54,7 @@ class ClientNamespace(socketio.ClientNamespace): 
        reply['_request_key'] = request_key

        try:

            reply['result'] = result.result()

            event = reply['result']['event']

            event = reply['result'].pop('event')

        except Exception as e:

            reply['error'] = str(e)

            #reply['stacktrace'] = str(e)
@@ -87,7 +87,7 @@ class ClientNamespace(socketio.ClientNamespace): 
        reply['_request_key'] = request_key

        try:

            reply['result'] = result.result()

            event = reply['result']['event']

            event = reply['result'].pop('event')

        except Exception as e:

            reply['error'] = str(e)

            #reply['stacktrace'] = str(e)

src/e2e_orchestrator/service/subscriptions/dispatchers/recommendation/Dispatcher.py

+4 −3
Original line number Diff line number Diff line
@@ -43,12 +43,13 @@ class RecommendationDispatcher(_Dispatcher): 


            service_client = ServiceClient()

            service_id = service_client.CreateService(Service(**vlink_optical_service_add))

            vlink_optical_service['service_id']['service_uuid']['uuid'] = service_id.service_uuid.uuid

            service_uuid = service_id.service_uuid.uuid

            vlink_optical_service['service_id']['service_uuid']['uuid'] = service_uuid

            service_id = service_client.UpdateService(Service(**vlink_optical_service))



            result = {'event': 'vlink_created'}

            result = {'event': 'vlink_created', 'vlink_uuid': service_uuid}

        elif request.action == RecommendationAction.VLINK_REMOVE:

            vlink_service_uuid = request.data['link_id']['link_uuid']['uuid']

            vlink_service_uuid = request.data['link_uuid']['uuid']

            context_id = json_context_id(DEFAULT_CONTEXT_NAME)

            vlink_optical_service_id = json_service_id(vlink_service_uuid, context_id=context_id)