From d2273ecea5d540f4dacc89772870722355f2492f Mon Sep 17 00:00:00 2001
From: Huanxuan Ao <huanxuan.ao@easystack.cn>
Date: Mon, 8 Aug 2016 12:09:19 +0800
Subject: Implement "volume transfer request delete" command

Add "volume transfer request delete" command in
volume v1 and v2. Also add the unit tests, docs,
release note and functional tests

Change-Id: Ic3d375bc8df3312fac53c1800d75f48376b8c91c
Implements: bp cinder-command-support
Co-Authored-By: Sheel Rana <ranasheel2000@gmail.com>
---
 .../volume/v1/volume_transfer_request.py           | 41 ++++++++++++++++++++++
 .../volume/v2/volume_transfer_request.py           | 41 ++++++++++++++++++++++
 2 files changed, 82 insertions(+)

(limited to 'openstackclient/volume')

diff --git a/openstackclient/volume/v1/volume_transfer_request.py b/openstackclient/volume/v1/volume_transfer_request.py
index b1167340..8c505528 100644
--- a/openstackclient/volume/v1/volume_transfer_request.py
+++ b/openstackclient/volume/v1/volume_transfer_request.py
@@ -14,13 +14,19 @@
 
 """Volume v1 transfer action implementations"""
 
+import logging
+
 from osc_lib.command import command
+from osc_lib import exceptions
 from osc_lib import utils
 import six
 
 from openstackclient.i18n import _
 
 
+LOG = logging.getLogger(__name__)
+
+
 class CreateTransferRequest(command.ShowOne):
     """Create volume transfer request."""
 
@@ -50,6 +56,41 @@ class CreateTransferRequest(command.ShowOne):
         return zip(*sorted(six.iteritems(volume_transfer_request._info)))
 
 
+class DeleteTransferRequest(command.Command):
+    """Delete volume transfer request(s)."""
+
+    def get_parser(self, prog_name):
+        parser = super(DeleteTransferRequest, self).get_parser(prog_name)
+        parser.add_argument(
+            'transfer_request',
+            metavar="<transfer-request>",
+            nargs="+",
+            help=_('Volume transfer request(s) to delete (name or ID)'),
+        )
+        return parser
+
+    def take_action(self, parsed_args):
+        volume_client = self.app.client_manager.volume
+        result = 0
+
+        for t in parsed_args.transfer_request:
+            try:
+                transfer_request_id = utils.find_resource(
+                    volume_client.transfers, t).id
+                volume_client.transfers.delete(transfer_request_id)
+            except Exception as e:
+                result += 1
+                LOG.error(_("Failed to delete volume transfer request "
+                            "with name or ID '%(transfer)s': %(e)s")
+                          % {'transfer': t, 'e': e})
+
+        if result > 0:
+            total = len(parsed_args.transfer_request)
+            msg = (_("%(result)s of %(total)s volume transfer requests failed"
+                   " to delete.") % {'result': result, 'total': total})
+            raise exceptions.CommandError(msg)
+
+
 class ListTransferRequests(command.Lister):
     """Lists all volume transfer requests."""
 
diff --git a/openstackclient/volume/v2/volume_transfer_request.py b/openstackclient/volume/v2/volume_transfer_request.py
index 45581586..f5de8d7a 100644
--- a/openstackclient/volume/v2/volume_transfer_request.py
+++ b/openstackclient/volume/v2/volume_transfer_request.py
@@ -14,13 +14,19 @@
 
 """Volume v2 transfer action implementations"""
 
+import logging
+
 from osc_lib.command import command
+from osc_lib import exceptions
 from osc_lib import utils
 import six
 
 from openstackclient.i18n import _
 
 
+LOG = logging.getLogger(__name__)
+
+
 class CreateTransferRequest(command.ShowOne):
     """Create volume transfer request."""
 
@@ -50,6 +56,41 @@ class CreateTransferRequest(command.ShowOne):
         return zip(*sorted(six.iteritems(volume_transfer_request._info)))
 
 
+class DeleteTransferRequest(command.Command):
+    """Delete volume transfer request(s)."""
+
+    def get_parser(self, prog_name):
+        parser = super(DeleteTransferRequest, self).get_parser(prog_name)
+        parser.add_argument(
+            'transfer_request',
+            metavar="<transfer-request>",
+            nargs="+",
+            help=_('Volume transfer request(s) to delete (name or ID)'),
+        )
+        return parser
+
+    def take_action(self, parsed_args):
+        volume_client = self.app.client_manager.volume
+        result = 0
+
+        for t in parsed_args.transfer_request:
+            try:
+                transfer_request_id = utils.find_resource(
+                    volume_client.transfers, t).id
+                volume_client.transfers.delete(transfer_request_id)
+            except Exception as e:
+                result += 1
+                LOG.error(_("Failed to delete volume transfer request "
+                            "with name or ID '%(transfer)s': %(e)s")
+                          % {'transfer': t, 'e': e})
+
+        if result > 0:
+            total = len(parsed_args.transfer_request)
+            msg = (_("%(result)s of %(total)s volume transfer requests failed"
+                   " to delete.") % {'result': result, 'total': total})
+            raise exceptions.CommandError(msg)
+
+
 class ListTransferRequests(command.Lister):
     """Lists all volume transfer requests."""
 
-- 
cgit v1.2.1