2 # Copyright 2018 CNIT - Consorzio Nazionale Interuniversitario per le Telecomunicazioni
4 # Licensed under the Apache License, Version 2.0 (the "License");
5 # you may not use this file except in compliance with the License.
6 # You may obtain a copy of the License at
8 # http://www.apache.org/licenses/LICENSE-2.0
10 # Unless required by applicable law or agreed to in writing, software
11 # distributed under the License is distributed on an BASIS,
12 # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 # See the License for the specific language governing permissions and
14 # limitations under the License.
17 from django
.shortcuts
import render
, redirect
18 from django
.http
import HttpResponse
, JsonResponse
22 from lib
.osm
.osmclient
.clientv2
import Client
23 from lib
.osm
.osm_rdcl_parser
import OsmParser
24 import authosm
.utils
as osmutils
25 from sf_t3d
.decorators
import login_required
27 logging
.basicConfig(level
=logging
.DEBUG
)
28 log
= logging
.getLogger('instancehandler/view.py')
32 def list(request
, type=None):
33 user
= osmutils
.get_user(request
)
34 project_id
= user
.project_id
36 result
= {'type': type, 'project_id': project_id
}
37 if "OSM_ERROR" in request
.session
:
38 result
['alert_error'] = request
.session
["OSM_ERROR"]
39 del request
.session
["OSM_ERROR"]
40 raw_content_types
= request
.META
.get('HTTP_ACCEPT', '*/*').split(',')
41 if 'application/json' not in raw_content_types
:
42 return __response_handler(request
, result
, 'instance_list.html')
45 instance_list
= client
.ns_list(user
.get_token())
47 instance_list
= client
.vnf_list(user
.get_token())
49 instance_list
= client
.pdu_list(user
.get_token())
51 instance_list
= client
.nsi_list(user
.get_token())
53 result
['instances'] = instance_list
['data'] if instance_list
and instance_list
['error'] is False else []
55 return __response_handler(request
, result
, 'instance_list.html')
58 def create(request
, type=None):
60 config_vim_account_id
= {}
61 user
= osmutils
.get_user(request
)
68 "nsName": request
.POST
.get('nsName', 'WithoutName'),
69 "nsDescription": request
.POST
.get('nsDescription', ''),
70 "nsdId": request
.POST
.get('nsdId', ''),
71 "vimAccountId": request
.POST
.get('vimAccountId', ''),
73 if 'ssh_key' in request
.POST
and request
.POST
.get('ssh_key') != '':
74 ns_data
["ssh_keys"] = [request
.POST
.get('ssh_key')]
76 if 'config' in request
.POST
:
77 ns_config
= yaml
.load(request
.POST
.get('config'))
78 if isinstance(ns_config
, dict):
79 if "vim-network-name" in ns_config
:
80 ns_config
["vld"] = ns_config
.pop("vim-network-name")
81 if "vld" in ns_config
:
83 for vld
in ns_config
["vld"]:
84 if vld
.get("vim-network-name"):
85 if isinstance(vld
["vim-network-name"], dict):
86 vim_network_name_dict
= {}
87 for vim_account
, vim_net
in vld
["vim-network-name"].items():
88 vim_network_name_dict
[ns_data
["vimAccountId"]] = vim_net
89 vld
["vim-network-name"] = vim_network_name_dict
90 ns_data
["vld"] = ns_config
["vld"]
91 if "vnf" in ns_config
:
92 for vnf
in ns_config
["vnf"]:
93 if vnf
.get("vim_account"):
94 vnf
["vimAccountId"] = ns_data
["vimAccountId"]
96 ns_data
["vnf"] = ns_config
["vnf"]
97 if "additionalParamsForNs" in ns_config
:
98 ns_data
["additionalParamsForNs"] = ns_config
["additionalParamsForNs"]
99 if "additionalParamsForVnf" in ns_config
:
100 ns_data
["additionalParamsForVnf"] = ns_config
["additionalParamsForVnf"]
101 if "wimAccountId" in ns_config
:
102 ns_data
["wimAccountId"] = ns_config
["wimAccountId"]
104 except Exception as e
:
105 request
.session
["OSM_ERROR"] = "Error creating the NS; Invalid parameters provided."
106 return __response_handler(request
, {}, 'instances:list', to_redirect
=True, type='ns', )
107 result
= client
.ns_create(user
.get_token(), ns_data
)
108 return __response_handler(request
, result
, 'instances:list', to_redirect
=True, type='ns')
113 "nsiName": request
.POST
.get('nsiName', 'WithoutName'),
114 "nsiDescription": request
.POST
.get('nsiDescription', ''),
115 "nstId": request
.POST
.get('nstId', ''),
116 "vimAccountId": request
.POST
.get('vimAccountId', ''),
119 if 'ssh_key' in request
.POST
and request
.POST
.get('ssh_key') != '':
120 nsi_data
["ssh_keys"] = [request
.POST
.get('ssh_key')]
121 except Exception as e
:
122 request
.session
["OSM_ERROR"] = "Error creating the NSI; Invalid parameters provided."
123 return __response_handler(request
, {}, 'instances:list', to_redirect
=True, type=type)
124 result
= client
.nsi_create(user
.get_token(), nsi_data
)
125 return __response_handler(request
, result
, 'instances:list', to_redirect
=True, type=type)
128 interface_param_name
= request
.POST
.getlist('interfaces_name')
129 interface_param_ip
= request
.POST
.getlist('interfaces_ip')
130 interface_param_mgmt
= request
.POST
.getlist('interfaces_mgmt')
131 interface_param_netname
= request
.POST
.getlist('interfaces_vimnetname')
134 "name": request
.POST
.get('name'),
135 "type": request
.POST
.get('pdu_type'),
136 "vim_accounts": request
.POST
.getlist('pdu_vim_accounts'),
137 "description": request
.POST
.get('description'),
140 for i
in (0,len(interface_param_name
)-1):
141 pdu_payload
['interfaces'].append({
142 'name': interface_param_name
[i
],
143 'mgmt': True if interface_param_mgmt
[i
] == 'true' else False,
144 'ip-address': interface_param_ip
[i
],
145 'vim-network-name': interface_param_netname
[i
]
147 result
= client
.pdu_create(user
.get_token(), pdu_payload
)
149 return __response_handler(request
, result
['data'], url
=None,
150 status
=result
['data']['status'] if 'status' in result
['data'] else 500)
152 return __response_handler(request
, {}, url
=None, status
=200)
155 def ns_operations(request
, instance_id
=None, type=None):
156 user
= osmutils
.get_user(request
)
157 project_id
= user
.project_id
159 result
= {'type': type, 'project_id': project_id
, 'instance_id': instance_id
}
160 raw_content_types
= request
.META
.get('HTTP_ACCEPT', '*/*').split(',')
161 if 'application/json' not in raw_content_types
:
162 return __response_handler(request
, result
, 'instance_operations_list.html')
165 op_list
= client
.ns_op_list(user
.get_token(), instance_id
)
167 op_list
= client
.nsi_op_list(user
.get_token(), instance_id
)
168 result
['operations'] = op_list
['data'] if op_list
and op_list
['error'] is False else []
170 return __response_handler(request
, result
, 'instance_operations_list.html')
173 def ns_operation(request
, op_id
, instance_id
=None, type=None):
174 user
= osmutils
.get_user(request
)
176 result
= client
.ns_op(user
.get_token(), op_id
)
177 return __response_handler(request
, result
['data'])
181 def action(request
, instance_id
=None, type=None):
182 user
= osmutils
.get_user(request
)
184 # result = client.ns_action(instance_id, action_payload)
185 primitive_param_keys
= request
.POST
.getlist('primitive_params_name')
186 primitive_param_value
= request
.POST
.getlist('primitive_params_value')
188 "vnf_member_index": request
.POST
.get('vnf_member_index'),
189 "primitive": request
.POST
.get('primitive'),
190 "primitive_params": {k
: v
for k
, v
in zip(primitive_param_keys
, primitive_param_value
) if len(k
) > 0}
193 result
= client
.ns_action(user
.get_token(), instance_id
, action_payload
)
196 return __response_handler(request
, result
['data'], url
=None,
197 status
=result
['data']['status'] if 'status' in result
['data'] else 500)
199 return __response_handler(request
, {}, url
=None, status
=200)
203 def delete(request
, instance_id
=None, type=None):
204 force
= bool(request
.GET
.get('force', False))
206 user
= osmutils
.get_user(request
)
209 result
= client
.ns_delete(user
.get_token(), instance_id
, force
)
211 result
= client
.pdu_delete(user
.get_token(), instance_id
)
213 result
= client
.nsi_delete(user
.get_token(), instance_id
, force
)
216 return __response_handler(request
, result
['data'], url
=None,
217 status
=result
['data']['status'] if 'status' in result
['data'] else 500)
219 return __response_handler(request
, {}, url
=None, status
=200)
222 def show_topology(request
, instance_id
=None, type=None):
223 user
= osmutils
.get_user(request
)
224 project_id
= user
.project_id
225 raw_content_types
= request
.META
.get('HTTP_ACCEPT', '*/*').split(',')
226 if 'application/json' in raw_content_types
:
228 nsr_object
= {'nsr': {}, 'vnfr': {}, 'vnfd': {}}
231 nsr_resp
= client
.ns_get(user
.get_token(), instance_id
)
232 nsr_object
['nsr'] = nsr_resp
['data']
233 if 'constituent-vnfr-ref' in nsr_object
['nsr'] :
234 for vnfr_id
in nsr_object
['nsr']['constituent-vnfr-ref']:
235 vnfr_resp
= client
.vnf_get(user
.get_token(), vnfr_id
)
236 vnfr
= vnfr_resp
['data']
237 nsr_object
['vnfr'][vnfr
['id']] = vnfr
238 if vnfr
['vnfd-id'] not in nsr_object
['vnfd']:
239 vnfd_resp
= client
.vnfd_get(user
.get_token(), vnfr
['vnfd-id'])
240 nsr_object
['vnfd'][vnfr
['vnfd-id']] = vnfd_resp
['vnfd:vnfd-catalog']['vnfd'][0]
244 result
= test
.nsr_to_graph(nsr_object
)
245 return __response_handler(request
, result
)
247 result
= {'type': type, 'project_id': project_id
, 'instance_id': instance_id
}
248 return __response_handler(request
, result
, 'instance_topology_view.html')
252 def show(request
, instance_id
=None, type=None):
254 user
= osmutils
.get_user(request
)
255 project_id
= user
.project_id
258 result
= client
.ns_get(user
.get_token(), instance_id
)
260 result
= client
.vnf_get(user
.get_token(), instance_id
)
262 result
= client
.pdu_get(user
.get_token(), instance_id
)
264 result
= client
.nsi_get(user
.get_token(), instance_id
)
266 return __response_handler(request
, result
)
270 def export_metric(request
, instance_id
=None, type=None):
271 metric_data
= request
.POST
.dict()
272 user
= osmutils
.get_user(request
)
273 project_id
= user
.project_id
275 keys
= ["collection_period",
281 metric_data
= dict(filter(lambda i
: i
[0] in keys
and len(i
[1]) > 0, metric_data
.items()))
283 result
= client
.ns_metric_export(user
.get_token(), instance_id
, metric_data
)
287 return __response_handler(request
, result
['data'], url
=None,
288 status
=result
['data']['status'] if 'status' in result
['data'] else 500)
290 return __response_handler(request
, {}, url
=None, status
=200)
294 def create_alarm(request
, instance_id
=None, type=None):
295 metric_data
= request
.POST
.dict()
297 user
= osmutils
.get_user(request
)
298 project_id
= user
.project_id
301 keys
= ["threshold_value",
310 metric_data
= dict(filter(lambda i
: i
[0] in keys
and len(i
[1]) > 0, metric_data
.items()))
312 result
= client
.ns_alarm_create(user
.get_token(), instance_id
, metric_data
)
315 return __response_handler(request
, result
['data'], url
=None,
316 status
=result
['data']['status'] if 'status' in result
['data'] else 500)
318 return __response_handler(request
, {}, url
=None, status
=200)
321 def __response_handler(request
, data_res
, url
=None, to_redirect
=None, *args
, **kwargs
):
322 raw_content_types
= request
.META
.get('HTTP_ACCEPT', '*/*').split(',')
323 if not to_redirect
and ('application/json' in raw_content_types
or url
is None):
324 return HttpResponse(json
.dumps(data_res
), content_type
="application/json", *args
, **kwargs
)
326 return redirect(url
, *args
, **kwargs
)
328 return render(request
, url
, data_res
)