1 # Copyright (C) 2018 Verizon. All Rights Reserved
3 # Licensed under the Apache License, Version 2.0 (the "License");
4 # you may not use this file except in compliance with the License.
5 # You may obtain a copy of the License at
7 # http://www.apache.org/licenses/LICENSE-2.0
9 # Unless required by applicable law or agreed to in writing, software
10 # distributed under the License is distributed on an "AS IS" BASIS,
11 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 # See the License for the specific language governing permissions and
13 # limitations under the License.
20 from requests.auth import HTTPBasicAuth
21 from rest_framework import status
23 from lcm.nf import const
24 from lcm.pub.database.models import SubscriptionModel
25 from lcm.pub.database.models import (
26 VmInstModel, NetworkInstModel,
27 PortInstModel, StorageInstModel, VNFCInstModel
29 from lcm.pub.utils.timeutil import now_time
30 from lcm.pub.utils.enumutil import enum
32 logger = logging.getLogger(__name__)
34 NOTIFY_TYPE = enum(lCM_OP_OCC="VnfLcmOperationOccurrenceNotification",
35 CREATION="VnfIdentifierCreationNotification",
36 DELETION="VnfIdentifierDeletionNotification")
39 class NotificationsUtil(object):
43 def send_notification(self, notification):
44 logger.info("Send Notifications to the callbackUri")
46 "operationState": "operation_states",
47 "operation": "operation_types"
49 subscriptions_filter = {v + "__contains": notification[k] for k, v in filters.iteritems()}
51 subscriptions = SubscriptionModel.objects.filter(**subscriptions_filter)
52 if not subscriptions.exists():
53 logger.info("No subscriptions created for the filters %s" % notification)
55 logger.info("Start sending notifications")
56 for subscription in subscriptions:
58 notification["subscriptionId"] = subscription.subscription_id
59 notification['_links']['subscription'] = {
60 'href': '/api/vnflcm/v1/subscriptions/%s' % subscription.subscription_id
62 callbackUri = subscription.callback_uri
63 auth_info = json.loads(subscription.auth_info)
64 if auth_info["authType"] != const.OAUTH2_CLIENT_CREDENTIALS:
66 self.post_notification(callbackUri, auth_info, notification)
67 except Exception as e:
68 logger.error("Failed to post notification: %s", e.message)
70 def post_notification(self, callbackUri, auth_info, notification):
71 params = auth_info.get("paramsBasic", {})
72 username = params.get("userName")
73 password = params.get("password")
74 logger.info("Sending notification to %s", callbackUri)
75 resp = requests.post(callbackUri,
77 auth=HTTPBasicAuth(username, password))
78 if resp.status_code != status.HTTP_204_NO_CONTENT:
79 raise Exception("Notify %s failed: %s" % (callbackUri, resp.text))
82 def set_affected_vnfcs(affected_vnfcs, nfinstid, changetype):
83 vnfcs = VNFCInstModel.objects.filter(instid=nfinstid)
87 vm = VmInstModel.objects.filter(vmid=vnfc.vmid)
90 'vimConnectionId': vm[0].vimid,
91 'resourceId': vm[0].resourceid,
92 'resourceProviderId': vm[0].vmname, # TODO: is resourceName mapped to resourceProviderId?
93 'vimLevelResourceType': 'vm'
95 affected_vnfcs.append({
96 'id': vnfc.vnfcinstanceid,
98 'changeType': changetype,
99 'computeResource': vm_resource
101 logger.debug("affected_vnfcs=%s", affected_vnfcs)
102 return affected_vnfcs
105 def set_affected_vls(affected_vls, nfinstid, changetype):
106 networks = NetworkInstModel.objects.filter(instid=nfinstid)
107 for network in networks:
109 'vimConnectionId': network.vimid,
110 'resourceId': network.resourceid,
111 'resourceProviderId': network.name, # TODO: is resourceName mapped to resourceProviderId?
112 'vimLevelResourceType': 'network'
114 affected_vls.append({
115 'id': network.networkid,
116 'virtualLinkDescId': network.nodeId,
117 'changeType': changetype,
118 'networkResource': network_resource
120 logger.debug("affected_vls=%s", affected_vls)
123 def set_ext_connectivity(ext_connectivity, nfinstid):
124 ext_connectivity_map = {}
125 ports = PortInstModel.objects.filter(instid=nfinstid)
127 if port.networkid not in ext_connectivity_map:
128 ext_connectivity_map[port.networkid] = []
129 ext_connectivity_map[port.networkid].append({
130 'id': port.portid, # TODO: port.portid or port.nodeid?
132 'vimConnectionId': port.vimid,
133 'resourceId': port.resourceid,
134 'resourceProviderId': port.name, # TODO: is resourceName mapped to resourceProviderId?
135 'vimLevelResourceType': 'port'
137 'cpInstanceId': port.portid # TODO: port.cpinstanceid is not initiated when create port resource.
139 for network_id, ext_link_ports in ext_connectivity_map.items():
140 networks = NetworkInstModel.objects.filter(networkid=network_id)
141 net_name = networks[0].name if networks else network_id
143 'vimConnectionId': ext_link_ports[0]['resourceHandle']['vimConnectionId'],
144 'resourceId': network_id,
145 'resourceProviderId': net_name, # TODO: is resourceName mapped to resourceProviderId?
146 'vimLevelResourceType': 'network'
148 ext_connectivity.append({
150 'resourceHandle': network_resource,
151 'extLinkPorts': ext_link_ports
153 logger.debug("ext_connectivity=%s", ext_connectivity)
156 def set_affected_vss(affected_vss, nfinstid, changetype):
157 vss = StorageInstModel.objects.filter(instid=nfinstid)
159 affected_vss.append({
161 'virtualStorageDescId': vs.nodeId,
162 'changeType': changetype,
164 'vimConnectionId': vs.vimid,
165 'resourceId': vs.resourceid,
166 'resourceProviderId': vs.name, # TODO: is resourceName mapped to resourceProviderId?
167 'vimLevelResourceType': 'volume'
170 logger.debug("affected_vss=%s", affected_vss)
173 def get_notification_status(operation_state):
174 if operation_state == const.OPERATION_STATE_TYPE.STARTING:
175 return const.LCM_NOTIFICATION_STATUS.START
176 return const.LCM_NOTIFICATION_STATUS.RESULT
179 def prepare_notification(nfinstid, jobid, operation, operation_state):
180 logger.info('Start to prepare notification')
181 notification_content = {
182 'id': str(uuid.uuid4()), # shall be the same if sent multiple times due to multiple subscriptions.
183 'notificationType': NOTIFY_TYPE.lCM_OP_OCC,
184 # set 'subscriptionId' after filtering for subscribers
185 'timeStamp': now_time(),
186 'notificationStatus': get_notification_status(operation_state),
187 'operationState': operation_state,
188 'vnfInstanceId': nfinstid,
189 'operation': operation,
190 'isAutomaticInvocation': False,
191 'vnfLcmOpOccId': jobid,
193 'affectedVirtualLinks': [],
194 'affectedVirtualStorages': [],
195 'changedExtConnectivity': [],
199 'href': '%s/vnf_instances/%s' % (const.URL_PREFIX, nfinstid)
202 'href': '%s/vnf_lcm_op_occs/%s' % (const.URL_PREFIX, jobid)
206 return notification_content
209 def prepare_notification_data(nfinstid, jobid, changetype, operation):
210 data = prepare_notification(nfinstid=nfinstid,
213 operation_state=const.OPERATION_STATE_TYPE.COMPLETED)
215 set_affected_vnfcs(data['affectedVnfcs'], nfinstid, changetype)
216 set_affected_vls(data['affectedVirtualLinks'], nfinstid, changetype)
217 set_affected_vss(data['affectedVirtualStorages'], nfinstid, changetype)
218 set_ext_connectivity(data['changedExtConnectivity'], nfinstid)
220 logger.debug('Notification content: %s' % data)
224 def prepare_vnf_identifier_notification(notify_type, nfinstid):
226 "id": str(uuid.uuid4()), # shall be the same if sent multiple times due to multiple subscriptions.
227 "notificationType": notify_type,
228 "timeStamp": now_time(),
229 "vnfInstanceId": nfinstid,
232 'href': '%s/vnf_instances/%s' % (const.URL_PREFIX, nfinstid)
237 logger.debug('Vnf Identifier Notification: %s' % data)