forked from kopia/kopia
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathcommand_policy.go
More file actions
76 lines (61 loc) · 2.02 KB
/
Copy pathcommand_policy.go
File metadata and controls
76 lines (61 loc) · 2.02 KB
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
71
72
73
74
75
76
package cli
import (
"context"
"github.com/alecthomas/kingpin/v2"
"github.com/pkg/errors"
"github.com/kopia/kopia/repo"
"github.com/kopia/kopia/repo/manifest"
"github.com/kopia/kopia/snapshot"
"github.com/kopia/kopia/snapshot/policy"
)
type commandPolicy struct {
edit commandPolicyEdit
list commandPolicyList
delete commandPolicyDelete
set commandPolicySet
show commandPolicyShow
export commandPolicyExport
pImport commandPolicyImport
}
func (c *commandPolicy) setup(svc appServices, parent commandParent) {
cmd := parent.Command("policy", "Commands to manipulate snapshotting policies.").Alias("policies")
c.edit.setup(svc, cmd)
c.list.setup(svc, cmd)
c.delete.setup(svc, cmd)
c.set.setup(svc, cmd)
c.show.setup(svc, cmd)
c.export.setup(svc, cmd)
c.pImport.setup(svc, cmd)
}
type policyTargetFlags struct {
targets []string
global bool
}
func (c *policyTargetFlags) setup(cmd *kingpin.CmdClause) {
cmd.Arg("target", "Select a particular policy (a per-host policy `@host`, a per-user policy `user@host`, a per-path policy `user@host:path` or a local path). Use --global to target the global policy.").StringsVar(&c.targets)
cmd.Flag("global", "Select the global policy.").BoolVar(&c.global)
}
func (c *policyTargetFlags) policyTargets(ctx context.Context, rep repo.Repository) ([]snapshot.SourceInfo, error) {
if c.global == (len(c.targets) > 0) {
return nil, errors.New("must pass either '--global' or a list of path targets")
}
if c.global {
return []snapshot.SourceInfo{
policy.GlobalPolicySourceInfo,
}, nil
}
var res []snapshot.SourceInfo
for _, ts := range c.targets {
// try loading policy by its manifest ID
if t, err := policy.GetPolicyByID(ctx, rep, manifest.ID(ts)); err == nil {
res = append(res, t.Target())
continue
}
target, err := snapshot.ParseSourceInfo(ts, rep.ClientOptions().Hostname, rep.ClientOptions().Username)
if err != nil {
return nil, errors.Wrapf(err, "unable to parse source info: %q", ts)
}
res = append(res, target)
}
return res, nil
}