From aee95791928d204725e01723885edce8c62aaf02 Mon Sep 17 00:00:00 2001
From: gifrerenom <lluis.gifre@cttc.es>
Date: Tue, 18 Mar 2025 16:23:55 +0000
Subject: [PATCH] NBI component - VNTM Recommendation:
- Corrected log levels
- Corrected management of request_keys
---
src/nbi/service/vntm_recommend/Namespaces.py | 22 +++++++++++---------
1 file changed, 12 insertions(+), 10 deletions(-)
diff --git a/src/nbi/service/vntm_recommend/Namespaces.py b/src/nbi/service/vntm_recommend/Namespaces.py
index a7660f859..b19550fae 100644
--- a/src/nbi/service/vntm_recommend/Namespaces.py
+++ b/src/nbi/service/vntm_recommend/Namespaces.py
@@ -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
)
--
GitLab