172ee45d499ac45af07a889e57d26e4b02bc833f
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
18 OSM package API handling
25 #from os.path import basename
26 from osmclient
.common
.exceptions
import ClientException
27 from osmclient
.common
.exceptions
import NotFound
28 from osmclient
.common
import utils
32 class Package(object):
33 def __init__(self
, http
=None, client
=None):
37 def get_key_val_from_pkg(self
, descriptor_file
):
38 return utils
.get_key_val_from_pkg(descriptor_file
)
40 def upload(self
, filename
):
41 pkg_type
= utils
.get_key_val_from_pkg(filename
)
43 raise ClientException("Cannot determine package type")
44 if pkg_type
['type'] == 'nsd':
45 endpoint
= '/nsd/v1/ns_descriptors_content'
47 endpoint
= '/vnfpkgm/v1/vnf_packages_content'
48 #endpoint = '/nsds' if pkg_type['type'] == 'nsd' else '/vnfds'
49 #print 'Endpoint: {}'.format(endpoint)
50 headers
= self
._client
._headers
51 headers
['Content-Type'] = 'application/gzip'
52 #headers['Content-Type'] = 'application/binary'
53 # Next three lines are to be removed in next version
54 #headers['Content-Filename'] = basename(filename)
55 #file_size = stat(filename).st_size
56 #headers['Content-Range'] = 'bytes 0-{}/{}'.format(file_size - 1, file_size)
57 headers
["Content-File-MD5"] = utils
.md5(filename
)
58 http_header
= ['{}: {}'.format(key
,val
)
59 for (key
,val
) in headers
.items()]
60 self
._http
.set_http_header(http_header
)
61 http_code
, resp
= self
._http
.post_cmd(endpoint
=endpoint
, filename
=filename
)
62 #print 'HTTP CODE: {}'.format(http_code)
63 #print 'RESP: {}'.format(resp)
64 if http_code
in (200, 201, 202, 204):
66 resp
= json
.loads(resp
)
67 if not resp
or 'id' not in resp
:
68 raise ClientException('unexpected response from server - {}'.format(
75 msg
= json
.loads(resp
)
78 raise ClientException("failed to delete ns {} - {}".format(name
, msg
))