X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2ims%2Fservice%2Fcommand%2Fregistration_handler.py;h=0c6bbefd3923a17d39df72fc13684147a037fdff;hb=c34ab47848138150a1456be2fa9f82d7260e37b8;hp=40cd3901ef92d4501fad7ba56d91221cac35afa2;hpb=9ee90ffa2414326c26fd10edc59bf315204254e2;p=pti%2Fo2.git diff --git a/o2ims/service/command/registration_handler.py b/o2ims/service/command/registration_handler.py index 40cd390..0c6bbef 100644 --- a/o2ims/service/command/registration_handler.py +++ b/o2ims/service/command/registration_handler.py @@ -42,7 +42,7 @@ def registry_to_smo( ocloud = uow.oclouds.get(data.id) if ocloud is None: return - logger.debug('O-Cloud Global UUID: {}'.format(ocloud.globalcloudId)) + logger.debug('O-Cloud Global UUID: {}'.format(ocloud.globalCloudId)) ocloud_dict = ocloud.serialize() if data.notificationEventType == NotificationEventEnum.CREATE: register_smo(uow, ocloud_dict) @@ -68,15 +68,24 @@ def register_smo(uow, ocloud_data): @retry((ConnectionRefusedError), tries=2, delay=2) def call_smo(reg_data: dict): + smo_token = conf.DEFAULT.smo_token_data + smo_token_info = { + 'iss': 'o2ims', + 'aud': 'smo', + 'smo_token_payload': smo_token, + 'smo_token_type': 'jwt', + 'smo_token_expiration': '', + 'smo_token_algo': 'RS256' + } + callback_data = json.dumps({ - 'consumerSubscriptionId': reg_data['globalcloudId'], - 'notificationEventType': 'CREATE', - 'objectRef': config.get_api_url(), - 'postObjectState': reg_data + 'globalCloudId': reg_data['globalCloudId'], + 'oCloudId': reg_data['oCloudId'], + 'IMS_EP': config.get_api_url(), + 'smo_token_data': smo_token_info }) logger.info('URL: {}, data: {}'.format( conf.DEFAULT.smo_register_url, callback_data)) - o = urlparse(conf.DEFAULT.smo_register_url) conn = http.client.HTTPConnection(o.netloc) headers = {'Content-type': 'application/json'}