ec54c95b609836e4e402c1e3ae16bbf7ab00b3d0
1 # Copyright 2018 Telefonica
5 # Licensed under the Apache License, Version 2.0 (the "License"); you may
6 # not use this file except in compliance with the License. You may obtain
7 # a copy of the License at
9 # http://www.apache.org/licenses/LICENSE-2.0
11 # Unless required by applicable law or agreed to in writing, software
12 # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
13 # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
14 # License for the specific language governing permissions and limitations
21 from osmclient
.common
.exceptions
import NotFound
22 from osmclient
.common
.exceptions
import ClientException
23 from osmclient
.common
import utils
26 from os
.path
import basename
33 def __init__(self
, http
=None, client
=None):
36 self
._logger
= logging
.getLogger('osmclient')
37 self
._apiName
= '/vnfpkgm'
38 self
._apiVersion
= '/v1'
39 self
._apiResource
= '/vnf_packages'
40 self
._apiBase
= '{}{}{}'.format(self
._apiName
,
41 self
._apiVersion
, self
._apiResource
)
42 #self._apiBase='/vnfds'
44 def list(self
, filter=None):
45 self
._logger
.debug("")
46 self
._client
.get_token()
49 filter_string
= '?{}'.format(filter)
50 resp
= self
._http
.get_cmd('{}{}'.format(self
._apiBase
,filter_string
))
56 self
._logger
.debug("")
57 self
._client
.get_token()
58 if utils
.validate_uuid4(name
):
59 for vnfd
in self
.list():
60 if name
== vnfd
['_id']:
63 for vnfd
in self
.list():
64 if 'name' in vnfd
and name
== vnfd
['name']:
66 raise NotFound("vnfd {} not found".format(name
))
68 def get_individual(self
, name
):
69 self
._logger
.debug("")
71 # It is redundant, since the previous one already gets the whole vnfpkginfo
72 # The only difference is that a different primitive is exercised
73 resp
= self
._http
.get_cmd('{}/{}'.format(self
._apiBase
, vnfd
['_id']))
74 #print(yaml.safe_dump(resp))
77 raise NotFound("vnfd {} not found".format(name
))
79 def get_thing(self
, name
, thing
, filename
):
80 self
._logger
.debug("")
82 headers
= self
._client
._headers
83 headers
['Accept'] = 'application/binary'
84 http_code
, resp
= self
._http
.get2_cmd('{}/{}/{}'.format(self
._apiBase
, vnfd
['_id'], thing
))
85 #print('HTTP CODE: {}'.format(http_code))
86 #print('RESP: {}'.format(resp))
87 if http_code
in (200, 201, 202, 204):
95 msg
= json
.loads(resp
)
98 raise ClientException("failed to get {} from {} - {}".format(thing
, name
, msg
))
100 def get_descriptor(self
, name
, filename
):
101 self
._logger
.debug("")
102 self
.get_thing(name
, 'vnfd', filename
)
104 def get_package(self
, name
, filename
):
105 self
._logger
.debug("")
106 self
.get_thing(name
, 'package_content', filename
)
108 def get_artifact(self
, name
, artifact
, filename
):
109 self
._logger
.debug("")
110 self
.get_thing(name
, 'artifacts/{}'.format(artifact
), filename
)
112 def delete(self
, name
, force
=False):
113 self
._logger
.debug("")
114 self
._client
.get_token()
115 vnfd
= self
.get(name
)
118 querystring
= '?FORCE=True'
119 http_code
, resp
= self
._http
.delete_cmd('{}/{}{}'.format(self
._apiBase
,
120 vnfd
['_id'], querystring
))
121 #print('HTTP CODE: {}'.format(http_code))
122 #print('RESP: {}'.format(resp))
124 print('Deletion in progress')
125 elif http_code
== 204:
131 msg
= json
.loads(resp
)
134 raise ClientException("failed to delete vnfd {} - {}".format(name
, msg
))
136 def create(self
, filename
, overwrite
=None, update_endpoint
=None):
137 self
._logger
.debug("")
138 self
._client
.get_token()
139 mime_type
= magic
.from_file(filename
, mime
=True)
140 if mime_type
is None:
141 raise ClientException(
142 "failed to guess MIME type for file '{}'".format(filename
))
143 headers
= self
._client
._headers
144 headers
['Content-Filename'] = basename(filename
)
145 if mime_type
in ['application/yaml', 'text/plain', 'application/json']:
146 headers
['Content-Type'] = 'text/plain'
147 elif mime_type
in ['application/gzip', 'application/x-gzip']:
148 headers
['Content-Type'] = 'application/gzip'
149 #headers['Content-Type'] = 'application/binary'
150 # Next three lines are to be removed in next version
151 #headers['Content-Filename'] = basename(filename)
152 #file_size = stat(filename).st_size
153 #headers['Content-Range'] = 'bytes 0-{}/{}'.format(file_size - 1, file_size)
155 raise ClientException(
156 "Unexpected MIME type for file {}: MIME type {}".format(
159 headers
["Content-File-MD5"] = utils
.md5(filename
)
160 http_header
= ['{}: {}'.format(key
,val
)
161 for (key
,val
) in list(headers
.items())]
162 self
._http
.set_http_header(http_header
)
164 http_code
, resp
= self
._http
.put_cmd(endpoint
=update_endpoint
, filename
=filename
)
168 ow_string
= '?{}'.format(overwrite
)
169 self
._apiResource
= '/vnf_packages_content'
170 self
._apiBase
= '{}{}{}'.format(self
._apiName
,
171 self
._apiVersion
, self
._apiResource
)
172 endpoint
= '{}{}'.format(self
._apiBase
,ow_string
)
173 http_code
, resp
= self
._http
.post_cmd(endpoint
=endpoint
, filename
=filename
)
174 #print('HTTP CODE: {}'.format(http_code))
175 #print('RESP: {}'.format(resp))
176 if http_code
in (200, 201, 202):
178 resp
= json
.loads(resp
)
179 if not resp
or 'id' not in resp
:
180 raise ClientException('unexpected response from server: '.format(
183 elif http_code
== 204:
186 msg
= "Error {}".format(http_code
)
189 msg
= "{} - {}".format(msg
, json
.loads(resp
))
191 msg
= "{} - {}".format(msg
, resp
)
192 raise ClientException("failed to create/update vnfd - {}".format(msg
))
194 def update(self
, name
, filename
):
195 self
._logger
.debug("")
196 self
._client
.get_token()
197 vnfd
= self
.get(name
)
198 endpoint
= '{}/{}/package_content'.format(self
._apiBase
, vnfd
['_id'])
199 self
.create(filename
=filename
, update_endpoint
=endpoint
)