1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
|
# Copyright (c) 2017 Wind River Systems, Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
import logging
from django.core.cache import cache
from keystoneauth1.identity import v2 as keystone_v2
from keystoneauth1.identity import v3 as keystone_v3
from keystoneauth1 import session
from newton.pub.msapi import extsys
logger = logging.getLogger(__name__)
class VimDriverUtils(object):
@staticmethod
def get_vim_info(vimid):
# get vim info from local cache firstly
# if cache miss, get it from ESR service
vim = extsys.get_vim_by_id(vimid)
return vim
@staticmethod
def delete_vim_info(vimid):
return extsys.delete_vim_by_id(vimid)
@staticmethod
def get_query_part(request):
query = ""
full_path = request.get_full_path()
if '?' in full_path:
_, query = request.get_full_path().split('?')
return query
@staticmethod
def get_session(vim, tenantid=None, tenantname=None, auth_state=None):
"""
get session object and optionally preload auth_state
"""
auth = None
#tenantid takes precedence over tenantname
if not tenantid:
#input tenant name takes precedence over the default one from AAI data store
tenant_name = tenantname if tenantname else vim['tenant']
if tenantid:
if '/v2' in vim["url"]:
auth = keystone_v2.Password(auth_url=vim["url"],
username=vim["userName"],
password=vim["password"],
tenant_id=tenantid)
elif '/v3' in vim["url"]:
auth = keystone_v3.Password(auth_url=vim["url"],
username=vim["userName"],
password=vim["password"],
user_domain_name=vim["domain"],
project_id=tenantid)
#elif '/identity' in vim["url"]:
else:
auth = keystone_v3.Password(auth_url=vim["url"]+"/v3",
username=vim["userName"],
password=vim["password"],
user_domain_name=vim["domain"],
project_id=tenantid)
elif tenant_name:
if '/v2' in vim["url"]:
auth = keystone_v2.Password(auth_url=vim["url"],
username=vim["userName"],
password=vim["password"],
tenant_name=tenant_name)
elif '/v3' in vim["url"]:
auth = keystone_v3.Password(auth_url=vim["url"],
username=vim["userName"],
password=vim["password"],
project_name=tenant_name,
user_domain_name=vim["domain"],
project_domain_name=vim["domain"])
#elif '/identity' in vim["url"]:
else:
auth = keystone_v3.Password(auth_url=vim["url"]+"/v3",
username=vim["userName"],
password=vim["password"],
project_name=tenant_name,
user_domain_name=vim["domain"],
project_domain_name=vim["domain"])
else:
#something wrong
return None
#preload auth_state which was acquired in last requests
if auth_state:
auth.set_auth_state(auth_state)
return session.Session(auth=auth)
@staticmethod
def get_auth_state(vim, session):
auth = session._auth_required(None, 'fetch a token')
if not auth:
return None
#trigger the authenticate request
session.get_auth_headers(auth)
# norm_expires = utils.normalize_time(auth.expires)
#return a string dump of json object with token and resp_data of authentication request
return auth.get_auth_state()
# return auth.get_auth_ref(session)
@staticmethod
def get_token_cache(token):
'''
get auth_state and metadata fromm cache
:param token:
:return:
'''
return cache.get(token), cache.get("meta_%s" % token)
@staticmethod
def update_token_cache(vim, session, token, auth_state, metadata=None):
'''
cache the auth_state as well as metadata_catalog
:param vim:
:param session:
:param token:
:param auth_state:
:param matadata:
:return:
'''
if metadata == None: #do not update token any more
return token
metadata_key = "meta_%s" % token
if not cache.get(token):
# store the auth_state, memcached
# set expiring in 1 hour
cache.set(token, auth_state, 3600)
cache.set(metadata_key, metadata, 3600)
return token
@staticmethod
def replace_a_key(dict_obj, keypair, reverse=False):
old_key, new_key = None, None
if reverse:
old_key, new_key = keypair[1], keypair[0]
else:
old_key, new_key = keypair[0], keypair[1]
v = dict_obj.pop(old_key, None)
if v:
dict_obj[new_key] = v
@staticmethod
def replace_key_by_mapping(dict_obj, mapping, reverse=False):
for k in mapping:
VimDriverUtils.replace_a_key(dict_obj, k, reverse)
|
