mirror of https://github.com/hashicorp/consul
command/connect/proxy: set ACL token based on proxy token flag
parent
867db89303
commit
5d969e3cbb
|
@ -80,6 +80,10 @@ func (c *cmd) Run(args []string) int {
|
||||||
if c.proxyID == "" {
|
if c.proxyID == "" {
|
||||||
c.proxyID = os.Getenv(proxyAgent.EnvProxyId)
|
c.proxyID = os.Getenv(proxyAgent.EnvProxyId)
|
||||||
}
|
}
|
||||||
|
if c.http.Token() == "" {
|
||||||
|
c.http.SetToken(os.Getenv(proxyAgent.EnvProxyToken))
|
||||||
|
}
|
||||||
|
|
||||||
// Setup the log outputs
|
// Setup the log outputs
|
||||||
logConfig := &logger.Config{
|
logConfig := &logger.Config{
|
||||||
LogLevel: c.logLevel,
|
LogLevel: c.logLevel,
|
||||||
|
|
|
@ -84,6 +84,10 @@ func (f *HTTPFlags) Token() string {
|
||||||
return f.token.String()
|
return f.token.String()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (f *HTTPFlags) SetToken(v string) error {
|
||||||
|
return f.token.Set(v)
|
||||||
|
}
|
||||||
|
|
||||||
func (f *HTTPFlags) APIClient() (*api.Client, error) {
|
func (f *HTTPFlags) APIClient() (*api.Client, error) {
|
||||||
c := api.DefaultConfig()
|
c := api.DefaultConfig()
|
||||||
|
|
||||||
|
|
|
@ -0,0 +1,15 @@
|
||||||
|
package flags
|
||||||
|
|
||||||
|
import (
|
||||||
|
"testing"
|
||||||
|
|
||||||
|
"github.com/stretchr/testify/require"
|
||||||
|
)
|
||||||
|
|
||||||
|
func TestHTTPFlagsSetToken(t *testing.T) {
|
||||||
|
var f HTTPFlags
|
||||||
|
require := require.New(t)
|
||||||
|
require.Empty(f.Token())
|
||||||
|
require.NoError(f.SetToken("foo"))
|
||||||
|
require.Equal("foo", f.Token())
|
||||||
|
}
|
Loading…
Reference in New Issue