Commit aee95791 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

NBI component - VNTM Recommendation: 

- Corrected log levels
- Corrected management of request_keys
parent ff3aa501

src/nbi/service/vntm_recommend/Namespaces.py

+12 −10
Original line number Diff line number Diff line
@@ -37,23 +37,24 @@ class VntRecommServerNamespace(Namespace): 


    def on_connect(self, auth):

        MSG = '[on_connect] Client connect: sid={:s}, auth={:s}'

        LOGGER.info(MSG.format(str(request.sid), str(auth)))

        LOGGER.debug(MSG.format(str(request.sid), str(auth)))

        join_room(SIO_ROOM, namespace=SIO_NAMESPACE)



    def on_disconnect(self, reason):

        MSG = '[on_disconnect] Client disconnect: sid={:s}, reason={:s}'

        LOGGER.info(MSG.format(str(request.sid), str(reason)))

        LOGGER.debug(MSG.format(str(request.sid), str(reason)))

        leave_room(SIO_ROOM, namespace=SIO_NAMESPACE)



    def on_vlink_created(self, data):

        MSG = '[on_vlink_created] begin: sid={:s}, data={:s}'

        LOGGER.info(MSG.format(str(request.sid), str(data)))

        LOGGER.debug(MSG.format(str(request.sid), str(data)))



        data = json.loads(data)

        request_key = data.pop('_request_key')



        request_key = str(data.pop('_request_key')).encode('utf-8')

        vntm_reply = json.dumps({'event': 'vlink_created', 'data': data}).encode('utf-8')

        LOGGER.info('[on_vlink_created] vntm_reply={:s}'.format(str(vntm_reply)))

        LOGGER.debug('[on_vlink_created] request_key={:s}/{:s}'.format(str(type(request_key)), str(request_key)))

        LOGGER.debug('[on_vlink_created] vntm_reply={:s}/{:s}'.format(str(type(vntm_reply)), str(vntm_reply)))



        self.kafka_producer.send(

            KafkaTopic.VNTMANAGER_RESPONSE.value, key=request_key, value=vntm_reply

        )
@@ -61,13 +62,14 @@ class VntRecommServerNamespace(Namespace): 


    def on_vlink_removed(self, data):

        MSG = '[on_vlink_removed] begin: sid={:s}, data={:s}'

        LOGGER.info(MSG.format(str(request.sid), str(data)))

        LOGGER.debug(MSG.format(str(request.sid), str(data)))



        data = json.loads(data)

        request_key = data.pop('_request_key')



        request_key = str(data.pop('_request_key')).encode('utf-8')

        vntm_reply = json.dumps({'event': 'vlink_removed', 'data': data}).encode('utf-8')

        LOGGER.info('[on_vlink_removed] vntm_reply={:s}'.format(str(vntm_reply)))

        LOGGER.debug('[on_vlink_removed] request_key={:s}/{:s}'.format(str(type(request_key)), str(request_key)))

        LOGGER.debug('[on_vlink_removed] vntm_reply={:s}/{:s}'.format(str(type(vntm_reply)), str(vntm_reply)))



        self.kafka_producer.send(

            KafkaTopic.VNTMANAGER_RESPONSE.value, key=request_key, value=vntm_reply

        )