-
Notifications
You must be signed in to change notification settings - Fork 385
/
cmd_rb.go
70 lines (55 loc) · 1.41 KB
/
cmd_rb.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
// Copyright (C) 2021 Storj Labs, Inc.
// See LICENSE for copying information.
package main
import (
"context"
"fmt"
"strconv"
"github.com/zeebo/clingy"
"github.com/zeebo/errs"
"storj.io/storj/cmd/uplink/ulext"
"storj.io/storj/cmd/uplink/ulloc"
)
type cmdRb struct {
ex ulext.External
access string
force bool
loc ulloc.Location
}
func newCmdRb(ex ulext.External) *cmdRb {
return &cmdRb{ex: ex}
}
func (c *cmdRb) Setup(params clingy.Parameters) {
c.access = params.Flag("access", "Access name or value to use", "").(string)
c.force = params.Flag("force", "Deletes any objects in bucket first", false,
clingy.Transform(strconv.ParseBool), clingy.Boolean,
).(bool)
c.loc = params.Arg("name", "Bucket name (sj://BUCKET)",
clingy.Transform(ulloc.Parse),
).(ulloc.Location)
}
func (c *cmdRb) Execute(ctx context.Context) (err error) {
defer mon.Task()(&ctx)(&err)
project, err := c.ex.OpenProject(ctx, c.access)
if err != nil {
return err
}
defer func() { _ = project.Close() }()
bucket, key, ok := c.loc.RemoteParts()
if !ok {
return errs.New("location must be remote")
}
if key != "" {
return errs.New("key must not be specified: %q", key)
}
if c.force {
_, err = project.DeleteBucketWithObjects(ctx, bucket)
} else {
_, err = project.DeleteBucket(ctx, bucket)
}
if err != nil {
return err
}
fmt.Fprintf(clingy.Stdout(ctx), "Bucket %q has been deleted.\n", bucket)
return nil
}