blob: cc9aa6584fe515c6136ba153174b21c860d750d6 [file] [log] [blame]
rajalakshmi-ganesanab426722013-02-08 15:49:15 +05301# Copyright 2013 OpenStack Foundation
2# All Rights Reserved.
3#
4# Licensed under the Apache License, Version 2.0 (the "License"); you may
5# not use this file except in compliance with the License. You may obtain
6# a copy of the License at
7#
8# http://www.apache.org/licenses/LICENSE-2.0
9#
10# Unless required by applicable law or agreed to in writing, software
11# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
12# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
13# License for the specific language governing permissions and limitations
14# under the License.
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053015
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053016from lxml import etree
17
Mate Lakat23a58a32013-08-23 02:06:22 +010018from tempest.common import http
vponomaryov960eeb42014-02-22 18:25:25 +020019from tempest.common import rest_client
Matthew Treinish684d8992014-01-30 16:27:40 +000020from tempest import config
Haiwei Xuaad85db2014-03-05 05:17:39 +090021from tempest.services.compute.xml import common
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053022
Matthew Treinish684d8992014-01-30 16:27:40 +000023CONF = config.CONF
24
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053025XMLNS = "http://docs.openstack.org/identity/api/v3"
26
27
vponomaryov960eeb42014-02-22 18:25:25 +020028class EndPointClientXML(rest_client.RestClient):
29 TYPE = "xml"
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053030
Andrea Frittoli8bbdb162014-01-06 11:06:13 +000031 def __init__(self, auth_provider):
32 super(EndPointClientXML, self).__init__(auth_provider)
Matthew Treinish684d8992014-01-30 16:27:40 +000033 self.service = CONF.identity.catalog_type
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053034 self.endpoint_url = 'adminURL'
Andrea Frittoli8bbdb162014-01-06 11:06:13 +000035 self.api_version = "v3"
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053036
37 def _parse_array(self, node):
38 array = []
39 for child in node.getchildren():
40 tag_list = child.tag.split('}', 1)
41 if tag_list[1] == "endpoint":
Haiwei Xuaad85db2014-03-05 05:17:39 +090042 array.append(common.xml_to_json(child))
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053043 return array
44
45 def _parse_body(self, body):
Haiwei Xuaad85db2014-03-05 05:17:39 +090046 json = common.xml_to_json(body)
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053047 return json
48
49 def request(self, method, url, headers=None, body=None, wait=None):
50 """Overriding the existing HTTP request in super class RestClient."""
Matthew Treinish684d8992014-01-30 16:27:40 +000051 dscv = CONF.identity.disable_ssl_certificate_validation
Mate Lakat23a58a32013-08-23 02:06:22 +010052 self.http_obj = http.ClosingHttp(
53 disable_ssl_certificate_validation=dscv)
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053054 return super(EndPointClientXML, self).request(method, url,
55 headers=headers,
56 body=body)
57
58 def list_endpoints(self):
59 """Get the list of endpoints."""
Valeriy Ponomaryov88686d82014-02-16 12:24:51 +020060 resp, body = self.get("endpoints")
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053061 body = self._parse_array(etree.fromstring(body))
62 return resp, body
63
64 def create_endpoint(self, service_id, interface, url, **kwargs):
65 """Create endpoint."""
66 region = kwargs.get('region', None)
67 enabled = kwargs.get('enabled', None)
Brant Knudson33402992014-02-27 13:31:37 -060068 if enabled is not None:
69 enabled = str(enabled).lower()
Haiwei Xuaad85db2014-03-05 05:17:39 +090070 create_endpoint = common.Element("endpoint",
71 xmlns=XMLNS,
72 service_id=service_id,
73 interface=interface,
74 url=url, region=region,
75 enabled=enabled)
76 resp, body = self.post('endpoints',
77 str(common.Document(create_endpoint)))
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053078 body = self._parse_body(etree.fromstring(body))
79 return resp, body
80
81 def update_endpoint(self, endpoint_id, service_id=None, interface=None,
82 url=None, region=None, enabled=None):
83 """Updates an endpoint with given parameters."""
Haiwei Xuaad85db2014-03-05 05:17:39 +090084 doc = common.Document()
85 endpoint = common.Element("endpoint")
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053086 doc.append(endpoint)
87
88 if service_id:
89 endpoint.add_attr("service_id", service_id)
90 if interface:
91 endpoint.add_attr("interface", interface)
92 if url:
93 endpoint.add_attr("url", url)
94 if region:
95 endpoint.add_attr("region", region)
96 if enabled is not None:
Brant Knudson33402992014-02-27 13:31:37 -060097 endpoint.add_attr("enabled", str(enabled).lower())
Valeriy Ponomaryov88686d82014-02-16 12:24:51 +020098 resp, body = self.patch('endpoints/%s' % str(endpoint_id), str(doc))
rajalakshmi-ganesanab426722013-02-08 15:49:15 +053099 body = self._parse_body(etree.fromstring(body))
100 return resp, body
101
102 def delete_endpoint(self, endpoint_id):
103 """Delete endpoint."""
104 resp_header, resp_body = self.delete('endpoints/%s' % endpoint_id)
105 return resp_header, resp_body