mirror of https://github.com/docker/cli.git
Resolve the docker Endpoint even if the client already exists. In that case the `TestDialStdio` e2e test had to be modified: the `--tls` option triggers an error since the endpoint resolution tries to read the `${DOCKER_CERT_PATH}/ca.pem` file which does not exist.
Signed-off-by: Jean-Christophe Sirot <jean-christophe.sirot@docker.com>
This commit is contained in:
parent
3b26cfce8b
commit
37fcaf7a29
|
@ -214,20 +214,18 @@ func (cli *DockerCli) Initialize(opts *cliflags.ClientOptions, ops ...Initialize
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
cli.dockerEndpoint, err = resolveDockerEndpoint(cli.contextStore, cli.currentContext, opts.Common)
|
||||||
|
if err != nil {
|
||||||
|
return errors.Wrap(err, "unable to resolve docker endpoint")
|
||||||
|
}
|
||||||
|
|
||||||
if cli.client == nil {
|
if cli.client == nil {
|
||||||
endpoint, err := resolveDockerEndpoint(cli.contextStore, cli.currentContext, opts.Common)
|
cli.client, err = newAPIClientFromEndpoint(cli.dockerEndpoint, cli.configFile)
|
||||||
if err != nil {
|
|
||||||
return errors.Wrap(err, "unable to resolve docker endpoint")
|
|
||||||
}
|
|
||||||
cli.dockerEndpoint = endpoint
|
|
||||||
|
|
||||||
cli.client, err = newAPIClientFromEndpoint(endpoint, cli.configFile)
|
|
||||||
if tlsconfig.IsErrEncryptedKey(err) {
|
if tlsconfig.IsErrEncryptedKey(err) {
|
||||||
passRetriever := passphrase.PromptRetrieverWithInOut(cli.In(), cli.Out(), nil)
|
passRetriever := passphrase.PromptRetrieverWithInOut(cli.In(), cli.Out(), nil)
|
||||||
newClient := func(password string) (client.APIClient, error) {
|
newClient := func(password string) (client.APIClient, error) {
|
||||||
endpoint.TLSPassword = password
|
cli.dockerEndpoint.TLSPassword = password
|
||||||
return newAPIClientFromEndpoint(endpoint, cli.configFile)
|
return newAPIClientFromEndpoint(cli.dockerEndpoint, cli.configFile)
|
||||||
}
|
}
|
||||||
cli.client, err = getClientWithPassword(passRetriever, newClient)
|
cli.client, err = getClientWithPassword(passRetriever, newClient)
|
||||||
}
|
}
|
||||||
|
|
|
@ -18,9 +18,9 @@ func TestDialStdio(t *testing.T) {
|
||||||
// follows. We observe this from the debug level logging from
|
// follows. We observe this from the debug level logging from
|
||||||
// the connhelper stuff.
|
// the connhelper stuff.
|
||||||
helloworld := filepath.Join(os.Getenv("DOCKER_CLI_E2E_PLUGINS_EXTRA_DIRS"), "docker-helloworld")
|
helloworld := filepath.Join(os.Getenv("DOCKER_CLI_E2E_PLUGINS_EXTRA_DIRS"), "docker-helloworld")
|
||||||
cmd := icmd.Command(helloworld, "--config=blah", "--tls", "--log-level", "debug", "helloworld", "--who=foo")
|
cmd := icmd.Command(helloworld, "--config=blah", "--log-level", "debug", "helloworld", "--who=foo")
|
||||||
res := icmd.RunCmd(cmd, icmd.WithEnv(manager.ReexecEnvvar+"=/bin/true"))
|
res := icmd.RunCmd(cmd, icmd.WithEnv(manager.ReexecEnvvar+"=/bin/true"))
|
||||||
res.Assert(t, icmd.Success)
|
res.Assert(t, icmd.Success)
|
||||||
assert.Assert(t, is.Contains(res.Stderr(), `msg="commandconn: starting /bin/true with [--config=blah --tls --log-level debug system dial-stdio]"`))
|
assert.Assert(t, is.Contains(res.Stderr(), `msg="commandconn: starting /bin/true with [--config=blah --log-level debug system dial-stdio]"`))
|
||||||
assert.Assert(t, is.Equal(res.Stdout(), "Hello foo!\n"))
|
assert.Assert(t, is.Equal(res.Stdout(), "Hello foo!\n"))
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue