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 NST (Network Slice Template) API handling
21 from osmclient
.common
.exceptions
import NotFound
22 from osmclient
.common
.exceptions
import ClientException
23 from osmclient
.common
import utils
28 #from os.path import basename
32 def __init__(self
, http
=None, client
=None):
35 self
._logger
= logging
.getLogger('osmclient')
36 self
._apiName
= '/nst'
37 self
._apiVersion
= '/v1'
38 self
._apiResource
= '/netslice_templates'
39 self
._apiBase
= '{}{}{}'.format(self
._apiName
,
40 self
._apiVersion
, self
._apiResource
)
42 def list(self
, filter=None):
43 self
._logger
.debug("")
44 self
._client
.get_token()
47 filter_string
= '?{}'.format(filter)
48 _
, resp
= self
._http
.get2_cmd('{}{}'.format(self
._apiBase
, filter_string
))
49 #print(yaml.safe_dump(resp))
51 return json
.loads(resp
)
55 self
._logger
.debug("")
56 self
._client
.get_token()
57 if utils
.validate_uuid4(name
):
58 for nst
in self
.list():
59 if name
== nst
['_id']:
62 for nst
in self
.list():
63 if 'name' in nst
and name
== nst
['name']:
65 raise NotFound("nst {} not found".format(name
))
67 def get_individual(self
, name
):
68 self
._logger
.debug("")
70 # It is redundant, since the previous one already gets the whole nstinfo
71 # The only difference is that a different primitive is exercised
73 _
, resp
= self
._http
.get2_cmd('{}/{}'.format(self
._apiBase
, nst
['_id']))
74 #print(yaml.safe_dump(resp))
76 return json
.loads(resp
)
78 raise NotFound("nst '{}' not found".format(name
))
79 raise NotFound("nst '{}' not found".format(name
))
81 def get_thing(self
, name
, thing
, filename
):
82 self
._logger
.debug("")
84 headers
= self
._client
._headers
85 headers
['Accept'] = 'application/binary'
87 http_code
, resp
= self
._http
.get2_cmd('{}/{}/{}'.format(self
._apiBase
, nst
['_id'], thing
))
89 raise NotFound("nst '{} 'not found".format(name
))
90 #print('HTTP CODE: {}'.format(http_code))
91 #print('RESP: {}'.format(resp))
92 #if http_code in (200, 201, 202, 204):
95 return json
.loads(resp
)
100 # msg = json.loads(resp)
103 # raise ClientException("failed to get {} from {} - {}".format(thing, name, msg))
105 def get_descriptor(self
, name
, filename
):
106 self
._logger
.debug("")
107 self
.get_thing(name
, 'nst', filename
)
109 def get_package(self
, name
, filename
):
110 self
._logger
.debug("")
111 self
.get_thing(name
, 'nst_content', filename
)
113 def get_artifact(self
, name
, artifact
, filename
):
114 self
._logger
.debug("")
115 self
.get_thing(name
, 'artifacts/{}'.format(artifact
), filename
)
117 def delete(self
, name
, force
=False):
118 self
._logger
.debug("")
122 querystring
= '?FORCE=True'
123 http_code
, resp
= self
._http
.delete_cmd('{}/{}{}'.format(self
._apiBase
,
124 nst
['_id'], querystring
))
125 #print('HTTP CODE: {}'.format(http_code))
126 #print('RESP: {}'.format(resp))
128 print('Deletion in progress')
129 elif http_code
== 204:
135 # resp = json.loads(resp)
138 raise ClientException("failed to delete nst {} - {}".format(name
, msg
))
140 def create(self
, filename
, overwrite
=None, update_endpoint
=None):
141 self
._logger
.debug("")
142 self
._client
.get_token()
143 mime_type
= magic
.from_file(filename
, mime
=True)
144 if mime_type
is None:
145 raise ClientException(
146 "failed to guess MIME type for file '{}'".format(filename
))
147 headers
= self
._client
._headers
148 if mime_type
in ['application/yaml', 'text/plain']:
149 headers
['Content-Type'] = 'application/yaml'
150 elif mime_type
in ['application/gzip', 'application/x-gzip']:
151 headers
['Content-Type'] = 'application/gzip'
152 #headers['Content-Type'] = 'application/binary'
153 # Next three lines are to be removed in next version
154 #headers['Content-Filename'] = basename(filename)
155 #file_size = stat(filename).st_size
156 #headers['Content-Range'] = 'bytes 0-{}/{}'.format(file_size - 1, file_size)
158 raise ClientException(
159 "Unexpected MIME type for file {}: MIME type {}".format(
162 headers
["Content-File-MD5"] = utils
.md5(filename
)
163 http_header
= ['{}: {}'.format(key
,val
)
164 for (key
,val
) in list(headers
.items())]
165 self
._http
.set_http_header(http_header
)
167 http_code
, resp
= self
._http
.put_cmd(endpoint
=update_endpoint
, filename
=filename
)
171 ow_string
= '?{}'.format(overwrite
)
172 self
._apiResource
= '/netslice_templates_content'
173 self
._apiBase
= '{}{}{}'.format(self
._apiName
,
174 self
._apiVersion
, self
._apiResource
)
175 endpoint
= '{}{}'.format(self
._apiBase
,ow_string
)
176 http_code
, resp
= self
._http
.post_cmd(endpoint
=endpoint
, filename
=filename
)
177 #print('HTTP CODE: {}'.format(http_code))
178 #print('RESP: {}'.format(resp))
179 # if http_code in (200, 201, 202, 204):
181 resp
= json
.loads(resp
)
182 if not resp
or 'id' not in resp
:
183 raise ClientException('unexpected response from server - {}'.format(resp
))
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 nst - {}".format(msg))
194 def update(self
, name
, filename
):
195 self
._logger
.debug("")
197 endpoint
= '{}/{}/nst_content'.format(self
._apiBase
, nst
['_id'])
198 self
.create(filename
=filename
, update_endpoint
=endpoint
)