1 files changed, 41 insertions, 0 deletions
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."""