api: disks: add DELETE endpoint for directory, lvm, lvmthin, zfs

[pve-storage.git] / PVE / API2 / Disks / LVMThin.pm

diff --git a/PVE/API2/Disks/LVMThin.pm b/PVE/API2/Disks/LVMThin.pm
index ced4b6a149e4fc3f0aded96edbca5421d04c0a53..52f3062be5c48f7a76a62cc286e66e88c8c1838a 100644 (file)
--- a/PVE/API2/Disks/LVMThin.pm
+++ b/PVE/API2/Disks/LVMThin.pm
@@ -165,4 +165,46 @@ __PACKAGE__->register_method ({
        return $rpcenv->fork_worker('lvmthincreate', $name, $user, $worker);
     }});
 
+__PACKAGE__->register_method ({
+    name => 'delete',
+    path => '{name}',
+    method => 'DELETE',
+    proxyto => 'node',
+    protected => 1,
+    permissions => {
+       check => ['perm', '/', ['Sys.Modify', 'Datastore.Allocate']],
+    },
+    description => "Remove an LVM thin pool.",
+    parameters => {
+       additionalProperties => 0,
+       properties => {
+           node => get_standard_option('pve-node'),
+           name => get_standard_option('pve-storage-id'),
+           'volume-group' => get_standard_option('pve-storage-id'),
+       },
+    },
+    returns => { type => 'string' },
+    code => sub {
+       my ($param) = @_;
+
+       my $rpcenv = PVE::RPCEnvironment::get();
+       my $user = $rpcenv->get_user();
+
+       my $vg = $param->{'volume-group'};
+       my $lv = $param->{name};
+
+       my $worker = sub {
+           PVE::Diskmanage::locked_disk_action(sub {
+               my $thinpools = PVE::Storage::LvmThinPlugin::list_thinpools();
+
+               die "no such thin pool ${vg}/${lv}\n"
+                   if !grep { $_->{lv} eq $lv && $_->{vg} eq $vg } $thinpools->@*;
+
+               run_command(['lvremove', '-y', "${vg}/${lv}"]);
+           });
+       };
+
+       return $rpcenv->fork_worker('lvmthinremove', "${vg}-${lv}", $user, $worker);
+    }});
+
 1;