1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
# 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.
# This file handles all flask-restful resources for /v3/regions
import http.client
from keystone.catalog import schema
from keystone.common import provider_api
from keystone.common import rbac_enforcer
from keystone.common import validation
from keystone import exception
from keystone.i18n import _
from keystone.server import flask as ks_flask
ENFORCER = rbac_enforcer.RBACEnforcer
PROVIDERS = provider_api.ProviderAPIs
class RegionResource(ks_flask.ResourceBase):
collection_key = 'regions'
member_key = 'region'
def _get_region(self, region_id):
ENFORCER.enforce_call(action='identity:get_region')
return self.wrap_member(PROVIDERS.catalog_api.get_region(region_id))
def _list_regions(self):
filters = ['parent_region_id']
ENFORCER.enforce_call(action='identity:list_regions', filters=filters)
hints = self.build_driver_hints(filters)
refs = PROVIDERS.catalog_api.list_regions(hints)
return self.wrap_collection(refs, hints=hints)
def get(self, region_id=None):
if region_id is not None:
return self._get_region(region_id)
return self._list_regions()
def post(self):
ENFORCER.enforce_call(action='identity:create_region')
region = self.request_body_json.get('region')
validation.lazy_validate(schema.region_create, region)
region = self._normalize_dict(region)
if not region.get('id'):
# NOTE(morgan): even though we officially only support 'id' setting
# via the PUT mechanism, this is historical and we need to support
# both ways.
region = self._assign_unique_id(region)
ref = PROVIDERS.catalog_api.create_region(
region, initiator=self.audit_initiator)
return self.wrap_member(ref), http.client.CREATED
def put(self, region_id):
ENFORCER.enforce_call(action='identity:create_region')
region = self.request_body_json.get('region')
validation.lazy_validate(schema.region_create, region)
region = self._normalize_dict(region)
if 'id' not in region:
region['id'] = region_id
elif region_id != region.get('id'):
raise exception.ValidationError(
_('Conflicting region IDs specified: '
'"%(url_id)s" != "%(ref_id)s"') % {
'url_id': region_id,
'ref_id': region['id']})
ref = PROVIDERS.catalog_api.create_region(
region, initiator=self.audit_initiator)
return self.wrap_member(ref), http.client.CREATED
def patch(self, region_id):
ENFORCER.enforce_call(action='identity:update_region')
region = self.request_body_json.get('region')
validation.lazy_validate(schema.region_update, region)
self._require_matching_id(region)
return self.wrap_member(PROVIDERS.catalog_api.update_region(
region_id, region, initiator=self.audit_initiator))
def delete(self, region_id):
ENFORCER.enforce_call(action='identity:delete_region')
return PROVIDERS.catalog_api.delete_region(
region_id, initiator=self.audit_initiator), http.client.NO_CONTENT
class RegionAPI(ks_flask.APIBase):
_name = 'regions'
_import_name = __name__
resources = [RegionResource]
resource_mapping = []
APIs = (RegionAPI,)
|
