f3ee93dc76a99a059e3f391cc23ca0b08581f400
2 # Copyright 2019 EveryUP Srl
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 sf_t3d
.decorators
import login_required
19 from django
.http
import HttpResponse
23 import authosm
.utils
as osmutils
24 from lib
.osm
.osmclient
.clientv2
import Client
26 logging
.basicConfig(level
=logging
.DEBUG
)
27 log
= logging
.getLogger('k8sclusterhandler/view.py')
32 user
= osmutils
.get_user(request
)
33 project_id
= user
.project_id
34 result
= {'project_id': project_id
}
35 raw_content_types
= request
.META
.get('HTTP_ACCEPT', '*/*').split(',')
36 if 'application/json' not in raw_content_types
:
37 return __response_handler(request
, result
, 'k8scluster_list.html')
39 result_client
= client
.k8sc_list(user
.get_token())
41 result
['k8sc'] = result_client
['data'] if result_client
and result_client
['error'] is False else []
43 return __response_handler(request
, result
, 'k8scluster_list.html')
48 user
= osmutils
.get_user(request
)
49 project_id
= user
.project_id
50 result
= {'project_id': project_id
}
55 "name": request
.POST
.get('name'),
56 "credentials": yaml
.load(request
.POST
.get('credentials')),
57 "vim_account": request
.POST
.get('vim_account'),
58 "k8s_version": request
.POST
.get('k8s_version'),
59 "nets": yaml
.load(request
.POST
.get('nets')),
62 # new_k8sc['vim_account'] = get_vim_account_id(new_k8sc['vim_account'])
64 except Exception as e
:
65 return __response_handler(request
, {'status': 400, 'code': 'BAD_REQUEST', 'detail': e
.message
}, url
=None, status
=400)
66 result
= client
.k8sc_create(user
.get_token(), new_k8sc
)
68 return __response_handler(request
, result
['data'], url
=None, status
=result
['data']['status'] if 'status' in result
['data'] else 500)
70 return __response_handler(request
, result
, 'k8sc:list', to_redirect
=True)
74 def update(request
, k8sc_id
=None):
75 user
= osmutils
.get_user(request
)
77 update_k8sc_dict
= request
.POST
.dict()
79 res
= client
.k8sc_update(user
.get_token(), k8sc_id
, update_k8sc_dict
)
80 except Exception as e
:
82 return __response_handler(request
, res
, 'k8sc:list', to_redirect
=True)
86 def show(request
, k8sc_id
=None):
87 user
= osmutils
.get_user(request
)
88 project_id
= user
.project_id
90 result_client
= client
.k8sc_get(user
.get_token(), k8sc_id
)
92 return __response_handler(request
, result_client
)
96 def delete(request
, k8sc_id
=None):
97 user
= osmutils
.get_user(request
)
100 del_res
= client
.k8sc_delete(user
.get_token(), k8sc_id
)
101 except Exception as e
:
103 return __response_handler(request
, del_res
, 'k8sc:list', to_redirect
=True)
106 def __response_handler(request
, data_res
, url
=None, to_redirect
=None, *args
, **kwargs
):
107 raw_content_types
= request
.META
.get('HTTP_ACCEPT', '*/*').split(',')
108 if 'application/json' in raw_content_types
or url
is None:
109 return HttpResponse(json
.dumps(data_res
), content_type
="application/json", *args
, **kwargs
)
111 return redirect(url
, *args
, **kwargs
)
113 return render(request
, url
, data_res
)