forked from cloudfoundry/cli
-
Notifications
You must be signed in to change notification settings - Fork 0
/
delete_route.go
137 lines (115 loc) · 4.27 KB
/
delete_route.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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
package route
import (
"fmt"
"code.cloudfoundry.org/cli/cf"
"code.cloudfoundry.org/cli/cf/api"
"code.cloudfoundry.org/cli/cf/commandregistry"
"code.cloudfoundry.org/cli/cf/configuration/coreconfig"
"code.cloudfoundry.org/cli/cf/errors"
"code.cloudfoundry.org/cli/cf/flags"
. "code.cloudfoundry.org/cli/cf/i18n"
"code.cloudfoundry.org/cli/cf/models"
"code.cloudfoundry.org/cli/cf/requirements"
"code.cloudfoundry.org/cli/cf/terminal"
)
type DeleteRoute struct {
ui terminal.UI
config coreconfig.Reader
routeRepo api.RouteRepository
domainReq requirements.DomainRequirement
}
func init() {
commandregistry.Register(&DeleteRoute{})
}
func (cmd *DeleteRoute) MetaData() commandregistry.CommandMetadata {
fs := make(map[string]flags.FlagSet)
fs["f"] = &flags.BoolFlag{ShortName: "f", Usage: T("Force deletion without confirmation")}
fs["hostname"] = &flags.StringFlag{Name: "hostname", ShortName: "n", Usage: T("Hostname used to identify the HTTP route")}
fs["path"] = &flags.StringFlag{Name: "path", Usage: T("Path used to identify the HTTP route")}
fs["port"] = &flags.IntFlag{Name: "port", Usage: T("Port used to identify the TCP route")}
return commandregistry.CommandMetadata{
Name: "delete-route",
Description: T("Delete a route"),
Usage: []string{
fmt.Sprintf("%s:\n", T("Delete an HTTP route")),
" CF_NAME delete-route ",
fmt.Sprintf("%s ", T("DOMAIN")),
fmt.Sprintf("[--hostname %s] ", T("HOSTNAME")),
fmt.Sprintf("[--path %s] [-f]\n\n", T("PATH")),
fmt.Sprintf(" %s:\n", T("Delete a TCP route")),
" CF_NAME delete-route ",
fmt.Sprintf("%s ", T("DOMAIN")),
fmt.Sprintf("--port %s [-f]", T("PORT")),
},
Examples: []string{
"CF_NAME delete-route example.com # example.com",
"CF_NAME delete-route example.com --hostname myhost # myhost.example.com",
"CF_NAME delete-route example.com --hostname myhost --path foo # myhost.example.com/foo",
"CF_NAME delete-route example.com --port 50000 # example.com:50000",
},
Flags: fs,
}
}
func (cmd *DeleteRoute) Requirements(requirementsFactory requirements.Factory, fc flags.FlagContext) ([]requirements.Requirement, error) {
if len(fc.Args()) != 1 {
cmd.ui.Failed(T("Incorrect Usage. Requires an argument\n\n") + commandregistry.Commands.CommandUsage("delete-route"))
return nil, fmt.Errorf("Incorrect usage: %d arguments of %d required", len(fc.Args()), 1)
}
if fc.IsSet("port") && (fc.IsSet("hostname") || fc.IsSet("path")) {
cmd.ui.Failed(T("Cannot specify port together with hostname and/or path."))
return nil, fmt.Errorf("Cannot specify port together with hostname and/or path.")
}
cmd.domainReq = requirementsFactory.NewDomainRequirement(fc.Args()[0])
var reqs []requirements.Requirement
if fc.String("path") != "" {
reqs = append(reqs, requirementsFactory.NewMinAPIVersionRequirement("Option '--path'", cf.RoutePathMinimumAPIVersion))
}
if fc.IsSet("port") {
reqs = append(reqs, requirementsFactory.NewMinAPIVersionRequirement("Option '--port'", cf.TCPRoutingMinimumAPIVersion))
}
reqs = append(reqs, []requirements.Requirement{
requirementsFactory.NewLoginRequirement(),
cmd.domainReq,
}...)
return reqs, nil
}
func (cmd *DeleteRoute) SetDependency(deps commandregistry.Dependency, pluginCall bool) commandregistry.Command {
cmd.ui = deps.UI
cmd.config = deps.Config
cmd.routeRepo = deps.RepoLocator.GetRouteRepository()
return cmd
}
func (cmd *DeleteRoute) Execute(c flags.FlagContext) error {
host := c.String("n")
path := c.String("path")
domainName := c.Args()[0]
port := c.Int("port")
url := (&models.RoutePresenter{
Host: host,
Domain: domainName,
Path: path,
Port: port,
}).URL()
if !c.Bool("f") {
if !cmd.ui.ConfirmDelete("route", url) {
return nil
}
}
cmd.ui.Say(T("Deleting route {{.URL}}...", map[string]interface{}{"URL": terminal.EntityNameColor(url)}))
domain := cmd.domainReq.GetDomain()
route, err := cmd.routeRepo.Find(host, domain, path, port)
if err != nil {
if _, ok := err.(*errors.ModelNotFoundError); ok {
cmd.ui.Warn(T("Unable to delete, route '{{.URL}}' does not exist.",
map[string]interface{}{"URL": url}))
return nil
}
return err
}
err = cmd.routeRepo.Delete(route.GUID)
if err != nil {
return err
}
cmd.ui.Ok()
return nil
}