summaryrefslogtreecommitdiff
path: root/openstackclient
diff options
context:
space:
mode:
Diffstat (limited to 'openstackclient')
-rw-r--r--openstackclient/image/v2/image.py80
-rw-r--r--openstackclient/shell.py7
-rw-r--r--openstackclient/tests/image/v2/fakes.py15
-rw-r--r--openstackclient/tests/image/v2/test_image.py155
-rw-r--r--openstackclient/tests/volume/v2/fakes.py11
-rw-r--r--openstackclient/tests/volume/v2/test_type.py4
-rw-r--r--openstackclient/volume/v2/volume_type.py2
7 files changed, 269 insertions, 5 deletions
diff --git a/openstackclient/image/v2/image.py b/openstackclient/image/v2/image.py
index 3808f6cf..4c019db6 100644
--- a/openstackclient/image/v2/image.py
+++ b/openstackclient/image/v2/image.py
@@ -27,6 +27,49 @@ from glanceclient.common import utils as gc_utils
from openstackclient.api import utils as api_utils
from openstackclient.common import parseractions
from openstackclient.common import utils
+from openstackclient.identity import common
+
+
+class AddProjectToImage(show.ShowOne):
+ """Associate project with image"""
+
+ log = logging.getLogger(__name__ + ".AddProjectToImage")
+
+ def get_parser(self, prog_name):
+ parser = super(AddProjectToImage, self).get_parser(prog_name)
+ parser.add_argument(
+ "image",
+ metavar="<image>",
+ help="Image to share (name or ID)",
+ )
+ parser.add_argument(
+ "project",
+ metavar="<project>",
+ help="Project to associate with image (name or ID)",
+ )
+ common.add_project_domain_option_to_parser(parser)
+ return parser
+
+ def take_action(self, parsed_args):
+ self.log.debug("take_action(%s)", parsed_args)
+
+ image_client = self.app.client_manager.image
+ identity_client = self.app.client_manager.identity
+
+ project_id = common.find_project(identity_client,
+ parsed_args.project,
+ parsed_args.project_domain).id
+
+ image_id = utils.find_resource(
+ image_client.images,
+ parsed_args.image).id
+
+ image_member = image_client.image_members.create(
+ image_id,
+ project_id,
+ )
+
+ return zip(*sorted(six.iteritems(image_member._info)))
class DeleteImage(command.Command):
@@ -192,6 +235,43 @@ class ListImage(lister.Lister):
)
+class RemoveProjectImage(command.Command):
+ """Disassociate project with image"""
+
+ log = logging.getLogger(__name__ + ".RemoveProjectImage")
+
+ def get_parser(self, prog_name):
+ parser = super(RemoveProjectImage, self).get_parser(prog_name)
+ parser.add_argument(
+ "image",
+ metavar="<image>",
+ help="Image to unshare (name or ID)",
+ )
+ parser.add_argument(
+ "project",
+ metavar="<project>",
+ help="Project to disassociate with image (name or ID)",
+ )
+ common.add_project_domain_option_to_parser(parser)
+ return parser
+
+ def take_action(self, parsed_args):
+ self.log.debug("take_action(%s)", parsed_args)
+
+ image_client = self.app.client_manager.image
+ identity_client = self.app.client_manager.identity
+
+ project_id = common.find_project(identity_client,
+ parsed_args.project,
+ parsed_args.project_domain).id
+
+ image_id = utils.find_resource(
+ image_client.images,
+ parsed_args.image).id
+
+ image_client.image_members.delete(image_id, project_id)
+
+
class SaveImage(command.Command):
"""Save an image locally"""
diff --git a/openstackclient/shell.py b/openstackclient/shell.py
index edeffdfb..319f10de 100644
--- a/openstackclient/shell.py
+++ b/openstackclient/shell.py
@@ -240,9 +240,9 @@ class OpenStackShell(app.App):
# Set the default plugin to token_endpoint if url and token are given
if (self.options.url and self.options.token):
# Use service token authentication
- cloud_config.set_default('auth_type', 'token_endpoint')
+ auth_type = 'token_endpoint'
else:
- cloud_config.set_default('auth_type', 'osc_password')
+ auth_type = 'osc_password'
self.log.debug("options: %s", self.options)
project_id = getattr(self.options, 'project_id', None)
@@ -266,7 +266,8 @@ class OpenStackShell(app.App):
# Ignore the default value of interface. Only if it is set later
# will it be used.
cc = cloud_config.OpenStackConfig(
- override_defaults={'interface': None, })
+ override_defaults={'interface': None,
+ 'auth_type': auth_type, })
self.log.debug("defaults: %s", cc.defaults)
self.cloud = cc.get_one_cloud(
diff --git a/openstackclient/tests/image/v2/fakes.py b/openstackclient/tests/image/v2/fakes.py
index 678291bb..1a9e301a 100644
--- a/openstackclient/tests/image/v2/fakes.py
+++ b/openstackclient/tests/image/v2/fakes.py
@@ -18,6 +18,7 @@ import mock
from openstackclient.tests import fakes
from openstackclient.tests import utils
+from openstackclient.tests.identity.v3 import fakes as identity_fakes
image_id = '0f41529e-7c12-4de8-be2d-181abb825b3c'
image_name = 'graven'
@@ -36,6 +37,13 @@ IMAGE = {
IMAGE_columns = tuple(sorted(IMAGE))
IMAGE_data = tuple((IMAGE[x] for x in sorted(IMAGE)))
+member_status = 'pending'
+MEMBER = {
+ 'member_id': identity_fakes.project_id,
+ 'image_id': image_id,
+ 'status': member_status,
+}
+
# Just enough v2 schema to do some testing
IMAGE_schema = {
"additionalProperties": {
@@ -125,6 +133,8 @@ class FakeImagev2Client(object):
def __init__(self, **kwargs):
self.images = mock.Mock()
self.images.resource_class = fakes.FakeResource(None, {})
+ self.image_members = mock.Mock()
+ self.image_members.resource_class = fakes.FakeResource(None, {})
self.auth_token = kwargs['token']
self.management_url = kwargs['endpoint']
@@ -137,3 +147,8 @@ class TestImagev2(utils.TestCommand):
endpoint=fakes.AUTH_URL,
token=fakes.AUTH_TOKEN,
)
+
+ self.app.client_manager.identity = identity_fakes.FakeIdentityv3Client(
+ endpoint=fakes.AUTH_URL,
+ token=fakes.AUTH_TOKEN,
+ )
diff --git a/openstackclient/tests/image/v2/test_image.py b/openstackclient/tests/image/v2/test_image.py
index 7cfaf083..bfb94765 100644
--- a/openstackclient/tests/image/v2/test_image.py
+++ b/openstackclient/tests/image/v2/test_image.py
@@ -21,6 +21,7 @@ import warlock
from glanceclient.v2 import schemas
from openstackclient.image.v2 import image
from openstackclient.tests import fakes
+from openstackclient.tests.identity.v3 import fakes as identity_fakes
from openstackclient.tests.image.v2 import fakes as image_fakes
@@ -32,6 +33,96 @@ class TestImage(image_fakes.TestImagev2):
# Get a shortcut to the ServerManager Mock
self.images_mock = self.app.client_manager.image.images
self.images_mock.reset_mock()
+ self.image_members_mock = self.app.client_manager.image.image_members
+ self.image_members_mock.reset_mock()
+ self.project_mock = self.app.client_manager.identity.projects
+ self.project_mock.reset_mock()
+ self.domain_mock = self.app.client_manager.identity.domains
+ self.domain_mock.reset_mock()
+
+
+class TestAddProjectToImage(TestImage):
+
+ def setUp(self):
+ super(TestAddProjectToImage, self).setUp()
+
+ # This is the return value for utils.find_resource()
+ self.images_mock.get.return_value = fakes.FakeResource(
+ None,
+ copy.deepcopy(image_fakes.IMAGE),
+ loaded=True,
+ )
+ self.image_members_mock.create.return_value = fakes.FakeResource(
+ None,
+ copy.deepcopy(image_fakes.MEMBER),
+ loaded=True,
+ )
+ self.project_mock.get.return_value = fakes.FakeResource(
+ None,
+ copy.deepcopy(identity_fakes.PROJECT),
+ loaded=True,
+ )
+ self.domain_mock.get.return_value = fakes.FakeResource(
+ None,
+ copy.deepcopy(identity_fakes.DOMAIN),
+ loaded=True,
+ )
+ # Get the command object to test
+ self.cmd = image.AddProjectToImage(self.app, None)
+
+ def test_add_project_to_image_no_option(self):
+ arglist = [
+ image_fakes.image_id,
+ identity_fakes.project_id,
+ ]
+ verifylist = [
+ ('image', image_fakes.image_id),
+ ('project', identity_fakes.project_id),
+ ]
+ parsed_args = self.check_parser(self.cmd, arglist, verifylist)
+
+ # DisplayCommandBase.take_action() returns two tuples
+ columns, data = self.cmd.take_action(parsed_args)
+ self.image_members_mock.create.assert_called_with(
+ image_fakes.image_id,
+ identity_fakes.project_id
+ )
+ collist = ('image_id', 'member_id', 'status')
+ self.assertEqual(collist, columns)
+ datalist = (
+ image_fakes.image_id,
+ identity_fakes.project_id,
+ image_fakes.member_status
+ )
+ self.assertEqual(datalist, data)
+
+ def test_add_project_to_image_with_option(self):
+ arglist = [
+ image_fakes.image_id,
+ identity_fakes.project_id,
+ '--project-domain', identity_fakes.domain_id,
+ ]
+ verifylist = [
+ ('image', image_fakes.image_id),
+ ('project', identity_fakes.project_id),
+ ('project_domain', identity_fakes.domain_id),
+ ]
+ parsed_args = self.check_parser(self.cmd, arglist, verifylist)
+
+ # DisplayCommandBase.take_action() returns two tuples
+ columns, data = self.cmd.take_action(parsed_args)
+ self.image_members_mock.create.assert_called_with(
+ image_fakes.image_id,
+ identity_fakes.project_id
+ )
+ collist = ('image_id', 'member_id', 'status')
+ self.assertEqual(collist, columns)
+ datalist = (
+ image_fakes.image_id,
+ identity_fakes.project_id,
+ image_fakes.member_status
+ )
+ self.assertEqual(datalist, data)
class TestImageDelete(TestImage):
@@ -298,6 +389,70 @@ class TestImageList(TestImage):
self.assertEqual(datalist, tuple(data))
+class TestRemoveProjectImage(TestImage):
+
+ def setUp(self):
+ super(TestRemoveProjectImage, self).setUp()
+
+ # This is the return value for utils.find_resource()
+ self.images_mock.get.return_value = fakes.FakeResource(
+ None,
+ copy.deepcopy(image_fakes.IMAGE),
+ loaded=True,
+ )
+ self.project_mock.get.return_value = fakes.FakeResource(
+ None,
+ copy.deepcopy(identity_fakes.PROJECT),
+ loaded=True,
+ )
+ self.domain_mock.get.return_value = fakes.FakeResource(
+ None,
+ copy.deepcopy(identity_fakes.DOMAIN),
+ loaded=True,
+ )
+ self.image_members_mock.delete.return_value = None
+ # Get the command object to test
+ self.cmd = image.RemoveProjectImage(self.app, None)
+
+ def test_remove_project_image_no_options(self):
+ arglist = [
+ image_fakes.image_id,
+ identity_fakes.project_id,
+ ]
+ verifylist = [
+ ('image', image_fakes.image_id),
+ ('project', identity_fakes.project_id),
+ ]
+ parsed_args = self.check_parser(self.cmd, arglist, verifylist)
+
+ # DisplayCommandBase.take_action() returns two tuples
+ self.cmd.take_action(parsed_args)
+ self.image_members_mock.delete.assert_called_with(
+ image_fakes.image_id,
+ identity_fakes.project_id,
+ )
+
+ def test_remove_project_image_with_options(self):
+ arglist = [
+ image_fakes.image_id,
+ identity_fakes.project_id,
+ '--project-domain', identity_fakes.domain_id,
+ ]
+ verifylist = [
+ ('image', image_fakes.image_id),
+ ('project', identity_fakes.project_id),
+ ('project_domain', identity_fakes.domain_id),
+ ]
+ parsed_args = self.check_parser(self.cmd, arglist, verifylist)
+
+ # DisplayCommandBase.take_action() returns two tuples
+ self.cmd.take_action(parsed_args)
+ self.image_members_mock.delete.assert_called_with(
+ image_fakes.image_id,
+ identity_fakes.project_id,
+ )
+
+
class TestImageShow(TestImage):
def setUp(self):
diff --git a/openstackclient/tests/volume/v2/fakes.py b/openstackclient/tests/volume/v2/fakes.py
index 4f5f9cfd..c896ed6d 100644
--- a/openstackclient/tests/volume/v2/fakes.py
+++ b/openstackclient/tests/volume/v2/fakes.py
@@ -93,6 +93,17 @@ TYPE = {
TYPE_columns = tuple(sorted(TYPE))
TYPE_data = tuple((TYPE[x] for x in sorted(TYPE)))
+formatted_type_properties = "foo='bar'"
+TYPE_FORMATTED = {
+ 'id': type_id,
+ 'name': type_name,
+ 'description': type_description,
+ 'properties': formatted_type_properties
+}
+TYPE_FORMATTED_columns = tuple(sorted(TYPE_FORMATTED))
+TYPE_FORMATTED_data = tuple((TYPE_FORMATTED[x] for x in
+ sorted(TYPE_FORMATTED)))
+
backup_id = "3c409fe6-4d03-4a06-aeab-18bdcdf3c8f4"
backup_volume_id = "bdbae8dc-e6ca-43c0-8076-951cc1b093a4"
backup_name = "fake_backup"
diff --git a/openstackclient/tests/volume/v2/test_type.py b/openstackclient/tests/volume/v2/test_type.py
index 39634966..c5b27fa5 100644
--- a/openstackclient/tests/volume/v2/test_type.py
+++ b/openstackclient/tests/volume/v2/test_type.py
@@ -180,8 +180,8 @@ class TestTypeShow(TestType):
columns, data = self.cmd.take_action(parsed_args)
self.types_mock.get.assert_called_with(volume_fakes.type_id)
- self.assertEqual(volume_fakes.TYPE_columns, columns)
- self.assertEqual(volume_fakes.TYPE_data, data)
+ self.assertEqual(volume_fakes.TYPE_FORMATTED_columns, columns)
+ self.assertEqual(volume_fakes.TYPE_FORMATTED_data, data)
class TestTypeDelete(TestType):
diff --git a/openstackclient/volume/v2/volume_type.py b/openstackclient/volume/v2/volume_type.py
index c785021f..7f9a1c4b 100644
--- a/openstackclient/volume/v2/volume_type.py
+++ b/openstackclient/volume/v2/volume_type.py
@@ -162,4 +162,6 @@ class ShowVolumeType(show.ShowOne):
volume_client = self.app.client_manager.volume
volume_type = utils.find_resource(
volume_client.volume_types, parsed_args.volume_type)
+ properties = utils.format_dict(volume_type._info.pop('extra_specs'))
+ volume_type._info.update({'properties': properties})
return zip(*sorted(six.iteritems(volume_type._info)))