mirror of https://github.com/status-im/consul.git
cli: Test API access using /status/leader in consul watch (#10795)
Replace call to /agent/self with /status/leader to verify agent reachability before initializing a watch. This endpoint is not guarded by ACLs, and as such can be queried by any API client regardless of their permissions. Fixes #9353
This commit is contained in:
parent
d3325b0253
commit
6a68bfc5e1
|
@ -0,0 +1,4 @@
|
|||
```release-note:bug
|
||||
cli: Fix a bug which prevented initializing a watch when using a namespaced
|
||||
token.
|
||||
```
|
|
@ -158,13 +158,19 @@ func (c *cmd) Run(args []string) int {
|
|||
return 1
|
||||
}
|
||||
|
||||
// Create and test the HTTP client
|
||||
// Create and test that the API is accessible before starting a blocking
|
||||
// loop for the watch.
|
||||
//
|
||||
// Consul does not have a /ping endpoint, so the /status/leader endpoint
|
||||
// will be used as a substitute since it does not require an ACL token to
|
||||
// query, and will always return a response to the client, unless there is a
|
||||
// network communication error.
|
||||
client, err := c.http.APIClient()
|
||||
if err != nil {
|
||||
c.UI.Error(fmt.Sprintf("Error connecting to Consul agent: %s", err))
|
||||
return 1
|
||||
}
|
||||
_, err = client.Agent().NodeName()
|
||||
_, err = client.Status().Leader()
|
||||
if err != nil {
|
||||
c.UI.Error(fmt.Sprintf("Error querying Consul agent: %s", err))
|
||||
return 1
|
||||
|
|
Loading…
Reference in New Issue