132 lines
3.6 KiB
Python
132 lines
3.6 KiB
Python
# 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.
|
|
|
|
|
|
from __future__ import absolute_import
|
|
|
|
import logging
|
|
|
|
from castellan import key_manager
|
|
|
|
from horizon import exceptions
|
|
from horizon.utils.memoized import memoized
|
|
from openstack_dashboard.api import base
|
|
|
|
# for stab, should remove when use CLI API
|
|
import copy
|
|
from datetime import datetime
|
|
import uuid
|
|
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
|
|
ATTRIBUTES = ['name', 'description', 'enabled', 'size', 'temperature',
|
|
'base', 'flavor', 'topping']
|
|
|
|
STUB_DATA = {}
|
|
|
|
|
|
# for stab, should be removed when use CLI API
|
|
class StubResponse(object):
|
|
|
|
def __init__(self, info):
|
|
self._info = info
|
|
|
|
def __repr__(self):
|
|
reprkeys = sorted(k for k in self.__dict__.keys() if k[0] != '_')
|
|
info = ", ".join("%s=%s" % (k, getattr(self, k)) for k in reprkeys)
|
|
return "<%s %s>" % (self.__class__.__name__, info)
|
|
|
|
def to_dict(self):
|
|
return copy.deepcopy(self._info)
|
|
|
|
|
|
@memoized
|
|
def apiclient(request):
|
|
api_url = ""
|
|
|
|
try:
|
|
api_url = base.url_for(request, 'manage')
|
|
except exceptions.ServiceCatalogException:
|
|
LOG.debug('No Manage Management service is configured.')
|
|
return None
|
|
|
|
LOG.debug('castellan connection created using the token "%s" and url'
|
|
'"%s"' % (request.user.token.id, api_url))
|
|
c = key_manager.API()
|
|
return c
|
|
|
|
|
|
def manage_create(request, **kwargs):
|
|
args = {}
|
|
for (key, value) in kwargs.items():
|
|
if key in ATTRIBUTES:
|
|
args[str(key)] = value
|
|
else:
|
|
raise exceptions.BadRequest(
|
|
"Key must be in %s" % ",".join(ATTRIBUTES))
|
|
# created = apiclient(request).manages.create(**args)
|
|
|
|
# create dummy response
|
|
args["uuid"] = uuid.uuid1().hex
|
|
args["created_at"] = datetime.now().isoformat()
|
|
created = StubResponse(args)
|
|
for k in args:
|
|
setattr(created, k, args[k])
|
|
STUB_DATA[created.uuid] = created
|
|
|
|
return created
|
|
|
|
|
|
def manage_update(request, id, **kwargs):
|
|
args = {}
|
|
for (key, value) in kwargs.items():
|
|
if key in ATTRIBUTES:
|
|
args[str(key)] = value
|
|
else:
|
|
raise exceptions.BadRequest(
|
|
"Key must be in %s" % ",".join(ATTRIBUTES))
|
|
# updated = apiclient(request).manage.update(id, **args)
|
|
|
|
# update dummy response
|
|
args["uuid"] = id
|
|
args["updated_at"] = datetime.now().isoformat()
|
|
updated = StubResponse(args)
|
|
for k in args:
|
|
setattr(updated, k, args[k])
|
|
STUB_DATA[updated.uuid] = updated
|
|
|
|
return updated
|
|
|
|
|
|
def manage_delete(request, id):
|
|
# deleted = apiclient(request).manages.delete(id)
|
|
deleted = STUB_DATA.pop(id)
|
|
|
|
return deleted
|
|
|
|
|
|
def manage_list(
|
|
request, limit=None, marker=None, sort_key=None,
|
|
sort_dir=None, detail=True):
|
|
|
|
# list = apiclient(request).Manages.list(limit, marker, sort_key,
|
|
# sort_dir, detail)
|
|
list = [STUB_DATA[data] for data in STUB_DATA]
|
|
return list
|
|
|
|
|
|
def manage_show(request, id):
|
|
# show = apiclient(request).manages.get(id)
|
|
show = STUB_DATA.get(id)
|
|
return show
|