c5d739269a
Activate the --long option for openstack recordset list command When this option is used, additional columns and values are displayed. The new columns are ttl, version, and description. Add test code for the new columns. Change-Id: I69f15bc56cc0f637c66ad975d8019757adfab038
265 lines
8.3 KiB
Python
265 lines
8.3 KiB
Python
# Copyright 2014 Hewlett-Packard Development Company, L.P.
|
|
#
|
|
# Author: Endre Karlson <endre.karlson@hp.com>
|
|
#
|
|
# 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 logging
|
|
|
|
from osc_lib.command import command
|
|
|
|
from designateclient import utils
|
|
from designateclient.v2.cli import common
|
|
from designateclient.v2.utils import get_all
|
|
|
|
|
|
LOG = logging.getLogger(__name__)
|
|
|
|
|
|
def _format_recordset(recordset):
|
|
# Remove unneeded fields for display output formatting
|
|
recordset['records'] = "\n".join(recordset['records'])
|
|
recordset.pop('links', None)
|
|
return recordset
|
|
|
|
|
|
def _has_project_id(data):
|
|
if len(data) < 1:
|
|
return False
|
|
if 'project_id' in data[0]:
|
|
return True
|
|
return False
|
|
|
|
|
|
class ListRecordSetsCommand(command.Lister):
|
|
"""List recordsets"""
|
|
|
|
columns = ['id', 'name', 'type', 'records', 'status', 'action']
|
|
|
|
def get_parser(self, prog_name):
|
|
parser = super().get_parser(prog_name)
|
|
|
|
parser.add_argument('--name', help='RecordSet Name', required=False)
|
|
parser.add_argument('--type', help='RecordSet Type', required=False)
|
|
parser.add_argument('--data', help='RecordSet Record Data',
|
|
required=False)
|
|
parser.add_argument('--ttl', help='Time To Live (Seconds)',
|
|
required=False)
|
|
parser.add_argument('--description', help='Description',
|
|
required=False)
|
|
parser.add_argument('--status', help='RecordSet Status',
|
|
required=False)
|
|
parser.add_argument('--action', help='RecordSet Action',
|
|
required=False)
|
|
|
|
parser.add_argument('zone_id', help="Zone ID. To list all"
|
|
" recordsets specify 'all'")
|
|
parser.add_argument(
|
|
'--long',
|
|
help='List additional fields in output',
|
|
default=False,
|
|
action='store_true',
|
|
required=False
|
|
)
|
|
|
|
common.add_all_common_options(parser)
|
|
|
|
return parser
|
|
|
|
def take_action(self, parsed_args):
|
|
client = self.app.client_manager.dns
|
|
common.set_all_common_headers(client, parsed_args)
|
|
|
|
criterion = {}
|
|
if parsed_args.type is not None:
|
|
criterion['type'] = parsed_args.type
|
|
|
|
if parsed_args.name is not None:
|
|
criterion['name'] = parsed_args.name
|
|
|
|
if parsed_args.data is not None:
|
|
criterion['data'] = parsed_args.data
|
|
|
|
if parsed_args.ttl is not None:
|
|
criterion['ttl'] = parsed_args.ttl
|
|
|
|
if parsed_args.description is not None:
|
|
criterion['description'] = parsed_args.description
|
|
|
|
if parsed_args.status is not None:
|
|
criterion['status'] = parsed_args.status
|
|
|
|
if parsed_args.action is not None:
|
|
criterion['action'] = parsed_args.action
|
|
|
|
cols = list(self.columns)
|
|
|
|
if parsed_args.zone_id == 'all':
|
|
data = get_all(client.recordsets.list_all_zones,
|
|
criterion=criterion)
|
|
cols.insert(2, 'zone_name')
|
|
else:
|
|
data = get_all(client.recordsets.list, args=[parsed_args.zone_id],
|
|
criterion=criterion)
|
|
|
|
if client.session.all_projects and _has_project_id(data):
|
|
cols.insert(1, 'project_id')
|
|
|
|
if parsed_args.long:
|
|
cols += ['ttl', 'version', 'description']
|
|
|
|
for i, rs in enumerate(data):
|
|
data[i] = _format_recordset(rs)
|
|
|
|
return cols, (utils.get_item_properties(s, cols) for s in data)
|
|
|
|
|
|
class ShowRecordSetCommand(command.ShowOne):
|
|
"""Show recordset details"""
|
|
|
|
def get_parser(self, prog_name):
|
|
parser = super().get_parser(prog_name)
|
|
|
|
parser.add_argument('zone_id', help='Zone ID')
|
|
parser.add_argument('id', help='RecordSet ID')
|
|
|
|
common.add_all_common_options(parser)
|
|
|
|
return parser
|
|
|
|
def take_action(self, parsed_args):
|
|
client = self.app.client_manager.dns
|
|
common.set_all_common_headers(client, parsed_args)
|
|
data = client.recordsets.get(parsed_args.zone_id, parsed_args.id)
|
|
|
|
_format_recordset(data)
|
|
return zip(*sorted(data.items()))
|
|
|
|
|
|
class CreateRecordSetCommand(command.ShowOne):
|
|
"""Create new recordset"""
|
|
|
|
def get_parser(self, prog_name):
|
|
parser = super().get_parser(prog_name)
|
|
|
|
parser.add_argument('zone_id', help='Zone ID')
|
|
parser.add_argument('name', help='RecordSet Name')
|
|
req_group = parser.add_mutually_exclusive_group(required=True)
|
|
req_group.add_argument(
|
|
'--record',
|
|
help='RecordSet Record, repeat if necessary',
|
|
action='append')
|
|
parser.add_argument('--type', help='RecordSet Type', required=True)
|
|
parser.add_argument('--ttl', type=int, help='Time To Live (Seconds)')
|
|
parser.add_argument('--description', help='Description')
|
|
|
|
common.add_all_common_options(parser)
|
|
|
|
return parser
|
|
|
|
def take_action(self, parsed_args):
|
|
client = self.app.client_manager.dns
|
|
common.set_all_common_headers(client, parsed_args)
|
|
|
|
data = client.recordsets.create(
|
|
parsed_args.zone_id,
|
|
parsed_args.name,
|
|
parsed_args.type,
|
|
parsed_args.record,
|
|
description=parsed_args.description,
|
|
ttl=parsed_args.ttl)
|
|
|
|
_format_recordset(data)
|
|
return zip(*sorted(data.items()))
|
|
|
|
|
|
class SetRecordSetCommand(command.ShowOne):
|
|
"""Set recordset properties"""
|
|
|
|
def get_parser(self, prog_name):
|
|
parser = super().get_parser(prog_name)
|
|
|
|
parser.add_argument('zone_id', help='Zone ID')
|
|
parser.add_argument('id', help='RecordSet ID')
|
|
req_group = parser.add_mutually_exclusive_group()
|
|
req_group.add_argument(
|
|
'--record',
|
|
help='RecordSet Record, repeat if necessary',
|
|
action='append')
|
|
|
|
description_group = parser.add_mutually_exclusive_group()
|
|
description_group.add_argument('--description', help='Description')
|
|
description_group.add_argument('--no-description', action='store_true')
|
|
|
|
ttl_group = parser.add_mutually_exclusive_group()
|
|
ttl_group.add_argument('--ttl', type=int, help='TTL')
|
|
ttl_group.add_argument('--no-ttl', action='store_true')
|
|
|
|
common.add_all_common_options(parser)
|
|
common.add_edit_managed_option(parser)
|
|
|
|
return parser
|
|
|
|
def take_action(self, parsed_args):
|
|
data = {}
|
|
|
|
if parsed_args.no_description:
|
|
data['description'] = None
|
|
elif parsed_args.description:
|
|
data['description'] = parsed_args.description
|
|
|
|
if parsed_args.no_ttl:
|
|
data['ttl'] = None
|
|
elif parsed_args.ttl:
|
|
data['ttl'] = parsed_args.ttl
|
|
|
|
if parsed_args.record:
|
|
data['records'] = parsed_args.record
|
|
|
|
client = self.app.client_manager.dns
|
|
common.set_all_common_headers(client, parsed_args)
|
|
|
|
updated = client.recordsets.update(
|
|
parsed_args.zone_id,
|
|
parsed_args.id,
|
|
data)
|
|
|
|
_format_recordset(updated)
|
|
|
|
return zip(*sorted(updated.items()))
|
|
|
|
|
|
class DeleteRecordSetCommand(command.ShowOne):
|
|
"""Delete recordset"""
|
|
|
|
def get_parser(self, prog_name):
|
|
parser = super().get_parser(prog_name)
|
|
|
|
parser.add_argument('zone_id', help='Zone ID')
|
|
parser.add_argument('id', help='RecordSet ID')
|
|
|
|
common.add_all_common_options(parser)
|
|
common.add_edit_managed_option(parser)
|
|
|
|
return parser
|
|
|
|
def take_action(self, parsed_args):
|
|
client = self.app.client_manager.dns
|
|
common.set_all_common_headers(client, parsed_args)
|
|
data = client.recordsets.delete(parsed_args.zone_id, parsed_args.id)
|
|
|
|
LOG.info('RecordSet %s was deleted', parsed_args.id)
|
|
|
|
_format_recordset(data)
|
|
return zip(*sorted(data.items()))
|