Change v3 extended_status to v2.1
This patch changes v3 extended_status API to v2.1 and makes v2 unit tests share between v2 and v2.1. Revert v3 changes back to v2. os-extended-status:* -> OS-EXT-STS:* The differences between v2 and v3 are descibed on the wiki page https://wiki.openstack.org/wiki/NovaAPIv2tov3. Partially implements blueprint v2-on-v3-api Change-Id: Ieefca1d0e8da831830f43cc83eb50bc7e7f4a10c
This commit is contained in:
parent
dab9a09a5c
commit
f9930a85b0
|
@ -53,10 +53,10 @@
|
|||
"OS-EXT-SRV-ATTR:host": "b8b357f7100d4391828f2177c922ef93",
|
||||
"OS-EXT-SRV-ATTR:hypervisor_hostname": "fake-mini",
|
||||
"OS-EXT-SRV-ATTR:instance_name": "instance-00000001",
|
||||
"os-extended-status:locked_by": null,
|
||||
"os-extended-status:power_state": 1,
|
||||
"os-extended-status:task_state": null,
|
||||
"os-extended-status:vm_state": "active",
|
||||
"OS-EXT-STS:locked_by": null,
|
||||
"OS-EXT-STS:power_state": 1,
|
||||
"OS-EXT-STS:task_state": null,
|
||||
"OS-EXT-STS:vm_state": "active",
|
||||
"os-extended-volumes:volumes_attached": [],
|
||||
"os-pci:pci_devices": [
|
||||
{
|
||||
|
|
|
@ -54,10 +54,10 @@
|
|||
"OS-EXT-SRV-ATTR:host": "c3f14e9812ad496baf92ccfb3c61e15f",
|
||||
"OS-EXT-SRV-ATTR:hypervisor_hostname": "fake-mini",
|
||||
"OS-EXT-SRV-ATTR:instance_name": "instance-00000001",
|
||||
"os-extended-status:locked_by": null,
|
||||
"os-extended-status:power_state": 1,
|
||||
"os-extended-status:task_state": null,
|
||||
"os-extended-status:vm_state": "active",
|
||||
"OS-EXT-STS:locked_by": null,
|
||||
"OS-EXT-STS:power_state": 1,
|
||||
"OS-EXT-STS:task_state": null,
|
||||
"OS-EXT-STS:vm_state": "active",
|
||||
"os-extended-volumes:volumes_attached": [],
|
||||
"os-pci:pci_devices": [
|
||||
{
|
||||
|
|
|
@ -46,10 +46,10 @@
|
|||
"My Server Name": "Apache1"
|
||||
},
|
||||
"name": "new-server-test",
|
||||
"os-extended-status:locked_by": null,
|
||||
"os-extended-status:power_state": 1,
|
||||
"os-extended-status:task_state": null,
|
||||
"os-extended-status:vm_state": "active",
|
||||
"OS-EXT-STS:locked_by": null,
|
||||
"OS-EXT-STS:power_state": 1,
|
||||
"OS-EXT-STS:task_state": null,
|
||||
"OS-EXT-STS:vm_state": "active",
|
||||
"progress": 0,
|
||||
"status": "ACTIVE",
|
||||
"tenant_id": "openstack",
|
||||
|
|
|
@ -47,10 +47,10 @@
|
|||
"My Server Name": "Apache1"
|
||||
},
|
||||
"name": "new-server-test",
|
||||
"os-extended-status:locked_by": null,
|
||||
"os-extended-status:power_state": 1,
|
||||
"os-extended-status:task_state": null,
|
||||
"os-extended-status:vm_state": "active",
|
||||
"OS-EXT-STS:locked_by": null,
|
||||
"OS-EXT-STS:power_state": 1,
|
||||
"OS-EXT-STS:task_state": null,
|
||||
"OS-EXT-STS:vm_state": "active",
|
||||
"progress": 0,
|
||||
"status": "ACTIVE",
|
||||
"tenant_id": "openstack",
|
||||
|
|
|
@ -29,7 +29,7 @@ class ExtendedStatusController(wsgi.Controller):
|
|||
|
||||
def _extend_server(self, server, instance):
|
||||
for state in ['task_state', 'vm_state', 'power_state', 'locked_by']:
|
||||
key = "%s:%s" % (ExtendedStatus.alias, state)
|
||||
key = "%s:%s" % ('OS-EXT-STS', state)
|
||||
server[key] = instance[state]
|
||||
|
||||
@wsgi.extends
|
||||
|
|
|
@ -52,28 +52,31 @@ def fake_compute_get_all(*args, **kwargs):
|
|||
db_list, fields)
|
||||
|
||||
|
||||
class ExtendedStatusTest(test.TestCase):
|
||||
class ExtendedStatusTestV21(test.TestCase):
|
||||
content_type = 'application/json'
|
||||
prefix = 'OS-EXT-STS:'
|
||||
fake_url = '/v3'
|
||||
|
||||
def setUp(self):
|
||||
super(ExtendedStatusTest, self).setUp()
|
||||
fakes.stub_out_nw_api(self.stubs)
|
||||
self.stubs.Set(compute.api.API, 'get', fake_compute_get)
|
||||
self.stubs.Set(compute.api.API, 'get_all', fake_compute_get_all)
|
||||
self.flags(
|
||||
osapi_compute_extension=[
|
||||
'nova.api.openstack.compute.contrib.select_extensions'],
|
||||
osapi_compute_ext_list=['Extended_status'])
|
||||
return_server = fakes.fake_instance_get()
|
||||
self.stubs.Set(db, 'instance_get_by_uuid', return_server)
|
||||
def _set_flags(self):
|
||||
pass
|
||||
|
||||
def _make_request(self, url):
|
||||
req = webob.Request.blank(url)
|
||||
req.headers['Accept'] = self.content_type
|
||||
res = req.get_response(fakes.wsgi_app(init_only=('servers',)))
|
||||
res = req.get_response(fakes.wsgi_app_v3(
|
||||
init_only=('servers',
|
||||
'os-extended-status')))
|
||||
return res
|
||||
|
||||
def setUp(self):
|
||||
super(ExtendedStatusTestV21, self).setUp()
|
||||
fakes.stub_out_nw_api(self.stubs)
|
||||
self.stubs.Set(compute.api.API, 'get', fake_compute_get)
|
||||
self.stubs.Set(compute.api.API, 'get_all', fake_compute_get_all)
|
||||
self._set_flags()
|
||||
return_server = fakes.fake_instance_get()
|
||||
self.stubs.Set(db, 'instance_get_by_uuid', return_server)
|
||||
|
||||
def _get_server(self, body):
|
||||
return jsonutils.loads(body).get('server')
|
||||
|
||||
|
@ -87,7 +90,7 @@ class ExtendedStatusTest(test.TestCase):
|
|||
self.assertEqual(server.get('%stask_state' % self.prefix), task_state)
|
||||
|
||||
def test_show(self):
|
||||
url = '/v2/fake/servers/%s' % UUID3
|
||||
url = self.fake_url + '/servers/%s' % UUID3
|
||||
res = self._make_request(url)
|
||||
|
||||
self.assertEqual(res.status_int, 200)
|
||||
|
@ -97,7 +100,7 @@ class ExtendedStatusTest(test.TestCase):
|
|||
task_state='kayaking')
|
||||
|
||||
def test_detail(self):
|
||||
url = '/v2/fake/servers/detail'
|
||||
url = self.fake_url + '/servers/detail'
|
||||
res = self._make_request(url)
|
||||
|
||||
self.assertEqual(res.status_int, 200)
|
||||
|
@ -113,13 +116,29 @@ class ExtendedStatusTest(test.TestCase):
|
|||
raise exception.InstanceNotFound(instance_id='fake')
|
||||
|
||||
self.stubs.Set(compute.api.API, 'get', fake_compute_get)
|
||||
url = '/v2/fake/servers/70f6db34-de8d-4fbd-aafb-4065bdfa6115'
|
||||
url = self.fake_url + '/servers/70f6db34-de8d-4fbd-aafb-4065bdfa6115'
|
||||
res = self._make_request(url)
|
||||
|
||||
self.assertEqual(res.status_int, 404)
|
||||
|
||||
|
||||
class ExtendedStatusXmlTest(ExtendedStatusTest):
|
||||
class ExtendedStatusTestV2(ExtendedStatusTestV21):
|
||||
fake_url = '/v2/fake'
|
||||
|
||||
def _set_flags(self):
|
||||
self.flags(
|
||||
osapi_compute_extension=[
|
||||
'nova.api.openstack.compute.contrib.select_extensions'],
|
||||
osapi_compute_ext_list=['Extended_status'])
|
||||
|
||||
def _make_request(self, url):
|
||||
req = webob.Request.blank(url)
|
||||
req.headers['Accept'] = self.content_type
|
||||
res = req.get_response(fakes.wsgi_app(init_only=('servers',)))
|
||||
return res
|
||||
|
||||
|
||||
class ExtendedStatusXmlTest(ExtendedStatusTestV2):
|
||||
content_type = 'application/xml'
|
||||
prefix = '{%s}' % extended_status.Extended_status.namespace
|
||||
|
||||
|
|
|
@ -1,119 +0,0 @@
|
|||
# Copyright 2011 OpenStack Foundation
|
||||
# All Rights Reserved.
|
||||
#
|
||||
# Licensed under the Apache License, Version 2.0 (the "License"); you may
|
||||
# not use this file except in compliance with the License. You may obtain
|
||||
# a copy of the License at
|
||||
#
|
||||
# http://www.apache.org/licenses/LICENSE-2.0
|
||||
#
|
||||
# Unless required by applicable law or agreed to in writing, software
|
||||
# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
||||
# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
||||
# License for the specific language governing permissions and limitations
|
||||
# under the License.
|
||||
|
||||
import webob
|
||||
|
||||
from nova import compute
|
||||
from nova import db
|
||||
from nova import exception
|
||||
from nova import objects
|
||||
from nova.objects import instance as instance_obj
|
||||
from nova.openstack.common import jsonutils
|
||||
from nova import test
|
||||
from nova.tests.api.openstack import fakes
|
||||
from nova.tests import fake_instance
|
||||
|
||||
UUID1 = '00000000-0000-0000-0000-000000000001'
|
||||
UUID2 = '00000000-0000-0000-0000-000000000002'
|
||||
UUID3 = '00000000-0000-0000-0000-000000000003'
|
||||
|
||||
|
||||
def fake_compute_get(*args, **kwargs):
|
||||
inst = fakes.stub_instance(1, uuid=UUID3, task_state="kayaking",
|
||||
vm_state="slightly crunchy", power_state=1, locked_by='owner')
|
||||
return fake_instance.fake_instance_obj(args[1], **inst)
|
||||
|
||||
|
||||
def fake_compute_get_all(*args, **kwargs):
|
||||
db_list = [
|
||||
fakes.stub_instance(1, uuid=UUID1, task_state="task-1",
|
||||
vm_state="vm-1", power_state=1, locked_by=None),
|
||||
fakes.stub_instance(2, uuid=UUID2, task_state="task-2",
|
||||
vm_state="vm-2", power_state=2, locked_by='admin'),
|
||||
]
|
||||
fields = instance_obj.INSTANCE_DEFAULT_FIELDS
|
||||
return instance_obj._make_instance_list(args[1],
|
||||
objects.InstanceList(),
|
||||
db_list, fields)
|
||||
|
||||
|
||||
class ExtendedStatusTest(test.TestCase):
|
||||
content_type = 'application/json'
|
||||
prefix = 'os-extended-status:'
|
||||
|
||||
def setUp(self):
|
||||
super(ExtendedStatusTest, self).setUp()
|
||||
fakes.stub_out_nw_api(self.stubs)
|
||||
self.stubs.Set(compute.api.API, 'get', fake_compute_get)
|
||||
self.stubs.Set(compute.api.API, 'get_all', fake_compute_get_all)
|
||||
return_server = fakes.fake_instance_get()
|
||||
self.stubs.Set(db, 'instance_get_by_uuid', return_server)
|
||||
|
||||
def _make_request(self, url):
|
||||
req = webob.Request.blank(url)
|
||||
req.headers['Accept'] = self.content_type
|
||||
res = req.get_response(fakes.wsgi_app_v3(
|
||||
init_only=('servers',
|
||||
'os-extended-status')))
|
||||
return res
|
||||
|
||||
def _get_server(self, body):
|
||||
return jsonutils.loads(body).get('server')
|
||||
|
||||
def _get_servers(self, body):
|
||||
return jsonutils.loads(body).get('servers')
|
||||
|
||||
def assertServerStates(self, server, vm_state, power_state, task_state,
|
||||
locked_by):
|
||||
self.assertEqual(server.get('%svm_state' % self.prefix), vm_state)
|
||||
self.assertEqual(int(server.get('%spower_state' % self.prefix)),
|
||||
power_state)
|
||||
self.assertEqual(server.get('%stask_state' % self.prefix), task_state)
|
||||
self.assertEqual(str(server.get('%slocked_by' % self.prefix)),
|
||||
locked_by)
|
||||
|
||||
def test_show(self):
|
||||
url = '/v3/servers/%s' % UUID3
|
||||
res = self._make_request(url)
|
||||
|
||||
self.assertEqual(res.status_int, 200)
|
||||
self.assertServerStates(self._get_server(res.body),
|
||||
vm_state='slightly crunchy',
|
||||
power_state=1,
|
||||
task_state='kayaking',
|
||||
locked_by='owner')
|
||||
|
||||
def test_detail(self):
|
||||
url = '/v3/servers/detail'
|
||||
res = self._make_request(url)
|
||||
|
||||
self.assertEqual(res.status_int, 200)
|
||||
for i, server in enumerate(self._get_servers(res.body)):
|
||||
self.assertServerStates(server,
|
||||
vm_state='vm-%s' % (i + 1),
|
||||
power_state=(i + 1),
|
||||
task_state='task-%s' % (i + 1),
|
||||
locked_by=['None', 'admin'][i])
|
||||
|
||||
def test_no_instance_passthrough_404(self):
|
||||
|
||||
def fake_compute_get(*args, **kwargs):
|
||||
raise exception.InstanceNotFound(instance_id='fake')
|
||||
|
||||
self.stubs.Set(compute.api.API, 'get', fake_compute_get)
|
||||
url = '/v3/servers/70f6db34-de8d-4fbd-aafb-4065bdfa6115'
|
||||
res = self._make_request(url)
|
||||
|
||||
self.assertEqual(res.status_int, 404)
|
|
@ -53,10 +53,10 @@
|
|||
"OS-EXT-SRV-ATTR:host": "%(compute_host)s",
|
||||
"OS-EXT-SRV-ATTR:hypervisor_hostname": "%(hypervisor_hostname)s",
|
||||
"OS-EXT-SRV-ATTR:instance_name": "instance-00000001",
|
||||
"os-extended-status:locked_by": null,
|
||||
"os-extended-status:power_state": 1,
|
||||
"os-extended-status:task_state": null,
|
||||
"os-extended-status:vm_state": "active",
|
||||
"OS-EXT-STS:locked_by": null,
|
||||
"OS-EXT-STS:power_state": 1,
|
||||
"OS-EXT-STS:task_state": null,
|
||||
"OS-EXT-STS:vm_state": "active",
|
||||
"os-extended-volumes:volumes_attached": [],
|
||||
"os-pci:pci_devices": [{"id": 1}],
|
||||
"os-server-usage:launched_at": "%(strtime)s",
|
||||
|
|
|
@ -54,10 +54,10 @@
|
|||
"OS-EXT-SRV-ATTR:host": "%(compute_host)s",
|
||||
"OS-EXT-SRV-ATTR:hypervisor_hostname": "%(hypervisor_hostname)s",
|
||||
"OS-EXT-SRV-ATTR:instance_name": "instance-00000001",
|
||||
"os-extended-status:locked_by": null,
|
||||
"os-extended-status:power_state": 1,
|
||||
"os-extended-status:task_state": null,
|
||||
"os-extended-status:vm_state": "active",
|
||||
"OS-EXT-STS:locked_by": null,
|
||||
"OS-EXT-STS:power_state": 1,
|
||||
"OS-EXT-STS:task_state": null,
|
||||
"OS-EXT-STS:vm_state": "active",
|
||||
"os-extended-volumes:volumes_attached": [],
|
||||
"os-pci:pci_devices": [{"id": 1}],
|
||||
"os-server-usage:launched_at": "%(strtime)s",
|
||||
|
|
|
@ -1,9 +1,9 @@
|
|||
{
|
||||
"server": {
|
||||
"os-extended-status:task_state": null,
|
||||
"os-extended-status:vm_state": "active",
|
||||
"os-extended-status:power_state": 1,
|
||||
"os-extended-status:locked_by": null,
|
||||
"OS-EXT-STS:task_state": null,
|
||||
"OS-EXT-STS:vm_state": "active",
|
||||
"OS-EXT-STS:power_state": 1,
|
||||
"OS-EXT-STS:locked_by": null,
|
||||
"updated": "%(isotime)s",
|
||||
"created": "%(isotime)s",
|
||||
"addresses": {
|
||||
|
|
|
@ -1,10 +1,10 @@
|
|||
{
|
||||
"servers": [
|
||||
{
|
||||
"os-extended-status:task_state": null,
|
||||
"os-extended-status:vm_state": "active",
|
||||
"os-extended-status:power_state": 1,
|
||||
"os-extended-status:locked_by": null,
|
||||
"OS-EXT-STS:task_state": null,
|
||||
"OS-EXT-STS:vm_state": "active",
|
||||
"OS-EXT-STS:power_state": 1,
|
||||
"OS-EXT-STS:locked_by": null,
|
||||
"updated": "%(isotime)s",
|
||||
"created": "%(isotime)s",
|
||||
"addresses": {
|
||||
|
|
Loading…
Reference in New Issue