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
29 def __init__(self
, http
=None, client
=None):
32 self
._logger
= logging
.getLogger("osmclient")
33 self
._apiName
= "/pdu"
34 self
._apiVersion
= "/v1"
35 self
._apiResource
= "/pdu_descriptors"
36 self
._apiBase
= "{}{}{}".format(
37 self
._apiName
, self
._apiVersion
, self
._apiResource
40 def list(self
, filter=None):
41 self
._logger
.debug("")
42 self
._client
.get_token()
45 filter_string
= "?{}".format(filter)
46 _
, resp
= self
._http
.get2_cmd("{}{}".format(self
._apiBase
, filter_string
))
48 return json
.loads(resp
)
52 self
._logger
.debug("")
53 self
._client
.get_token()
54 if utils
.validate_uuid4(name
):
55 for pdud
in self
.list():
56 if name
== pdud
["_id"]:
59 for pdud
in self
.list():
60 if "name" in pdud
and name
== pdud
["name"]:
62 raise NotFound("pdud {} not found".format(name
))
64 def get_individual(self
, name
):
65 self
._logger
.debug("")
67 # It is redundant, since the previous one already gets the whole pdudInfo
68 # The only difference is that a different primitive is exercised
70 _
, resp
= self
._http
.get2_cmd("{}/{}".format(self
._apiBase
, pdud
["_id"]))
72 raise NotFound("pdu '{}' not found".format(name
))
73 # print(yaml.safe_dump(resp))
75 return json
.loads(resp
)
76 raise NotFound("pdu '{}' not found".format(name
))
78 def delete(self
, name
, force
=False):
79 self
._logger
.debug("")
83 querystring
= "?FORCE=True"
84 http_code
, resp
= self
._http
.delete_cmd(
85 "{}/{}{}".format(self
._apiBase
, pdud
["_id"], querystring
)
87 # print('HTTP CODE: {}'.format(http_code))
88 # print('RESP: {}'.format(resp))
90 print("Deletion in progress")
91 elif http_code
== 204:
97 # msg = json.loads(resp)
100 raise ClientException("failed to delete pdu {} - {}".format(name
, msg
))
102 def create(self
, pdu
, update_endpoint
=None):
103 self
._logger
.debug("")
104 self
._client
.get_token()
105 headers
= self
._client
._headers
106 headers
["Content-Type"] = "application/yaml"
108 "{}: {}".format(key
, val
) for (key
, val
) in list(headers
.items())
110 self
._http
.set_http_header(http_header
)
112 http_code
, resp
= self
._http
.put_cmd(
113 endpoint
=update_endpoint
, postfields_dict
=pdu
116 endpoint
= self
._apiBase
117 # endpoint = '{}{}'.format(self._apiBase,ow_string)
118 http_code
, resp
= self
._http
.post_cmd(
119 endpoint
=endpoint
, postfields_dict
=pdu
121 # print('HTTP CODE: {}'.format(http_code))
122 # print('RESP: {}'.format(resp))
123 # if http_code in (200, 201, 202, 204):
125 resp
= json
.loads(resp
)
126 if not resp
or "id" not in resp
:
127 raise ClientException("unexpected response from server: {}".format(resp
))
130 # msg = "Error {}".format(http_code)
133 # msg = "{} - {}".format(msg, json.loads(resp))
135 # msg = "{} - {}".format(msg, resp)
136 # raise ClientException("failed to create/update pdu - {}".format(msg))
138 def update(self
, name
, filename
):
139 self
._logger
.debug("")
140 pdud
= self
.get(name
)
141 endpoint
= "{}/{}".format(self
._apiBase
, pdud
["_id"])
142 self
.create(filename
=filename
, update_endpoint
=endpoint
)