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
|
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.vespa.hosted.dockerapi;
import com.github.dockerjava.api.DockerClient;
import com.github.dockerjava.api.command.ExecCreateCmd;
import com.github.dockerjava.api.command.ExecCreateCmdResponse;
import com.github.dockerjava.api.command.ExecStartCmd;
import com.github.dockerjava.api.command.InspectExecCmd;
import com.github.dockerjava.api.command.InspectExecResponse;
import com.github.dockerjava.core.DefaultDockerClientConfig;
import com.github.dockerjava.core.command.ExecStartResultCallback;
import org.junit.Test;
import org.mockito.Matchers;
import java.io.IOException;
import java.security.KeyManagementException;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
import java.security.UnrecoverableKeyException;
import static org.hamcrest.CoreMatchers.is;
import static org.junit.Assert.assertThat;
import static org.junit.Assert.assertTrue;
import static org.mockito.Matchers.any;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;
/**
* @author tonytv
*/
public class DockerImplTest {
@Test
public void testDockerConfigWithUnixPath() throws UnrecoverableKeyException, NoSuchAlgorithmException, KeyStoreException, KeyManagementException {
String dockerUri = "unix:///var/run/docker.sock";
DockerConfig config = createConfig(dockerUri, null, null, null);
DefaultDockerClientConfig clientConfig = DockerImpl.buildDockerClientConfig(config).build();
assertTrue("Docker uri incorrectly set", clientConfig.getDockerHost().toString().equals(dockerUri));
assertTrue("SSL config was set when using socket", clientConfig.getSSLConfig() == null);
}
@Test
public void testDockerConfigWithTcpPathWithoutSSL() {
String dockerUri = "tcp://127.0.0.1:2376";
DockerConfig config = createConfig(dockerUri, null, null, null);
DefaultDockerClientConfig clientConfig = DockerImpl.buildDockerClientConfig(config).build();
assertTrue("Docker uri incorrectly set", clientConfig.getDockerHost().toString().equals(dockerUri));
assertTrue("SSL config was set", clientConfig.getSSLConfig() == null);
}
@Test
public void testDockerConfigWithTcpPathWithSslConfig() throws IOException, UnrecoverableKeyException, NoSuchAlgorithmException, KeyStoreException, KeyManagementException {
String dockerUri = "tcp://127.0.0.1:2376";
DockerConfig config = createConfig(dockerUri, "/some/path/ca", "/some/path/cert", "/some/path/key");
DefaultDockerClientConfig clientConfig = DockerImpl.buildDockerClientConfig(config).build();
assertTrue("Docker uri incorrectly set", clientConfig.getDockerHost().toString().equals(dockerUri));
assertTrue("SSL config was not set", clientConfig.getSSLConfig() != null);
}
@Test(expected=RuntimeException.class)
public void testDockerConfigWithTcpPathWithInvalidSslConfig() throws IOException, UnrecoverableKeyException, NoSuchAlgorithmException, KeyStoreException, KeyManagementException {
String dockerUri = "tcp://127.0.0.1:2376";
DockerConfig config = createConfig(dockerUri, "/some/path/ca", "/some/path/cert", "/some/path/key");
DefaultDockerClientConfig clientConfig = DockerImpl.buildDockerClientConfig(config).build();
assertTrue("Docker uri incorrectly set", clientConfig.getDockerHost().toString().equals(dockerUri));
assertTrue("SSL config was not set", clientConfig.getSSLConfig() != null);
// SSL certificates are read during the getSSLContext(), the invalid paths should cause a RuntimeException
clientConfig.getSSLConfig().getSSLContext();
}
private static DockerConfig createConfig(String uri, String caCertPath, String clientCertPath, String clientKeyPath) {
DockerConfig.Builder configBuilder = new DockerConfig.Builder();
if (uri != null) configBuilder.uri(uri);
if (caCertPath != null) configBuilder.caCertPath(caCertPath);
if (clientCertPath != null) configBuilder.clientCertPath(clientCertPath);
if (clientKeyPath != null) configBuilder.clientKeyPath(clientKeyPath);
return new DockerConfig(configBuilder);
}
@Test
public void testExecuteCompletes() throws Exception {
final String containerId = "container-id";
final String[] command = new String[] {"/bin/ls", "-l"};
final String execId = "exec-id";
final int exitCode = 3;
final DockerClient dockerClient = mock(DockerClient.class);
final ExecCreateCmdResponse response = mock(ExecCreateCmdResponse.class);
when(response.getId()).thenReturn(execId);
final ExecCreateCmd execCreateCmd = mock(ExecCreateCmd.class);
when(dockerClient.execCreateCmd(any(String.class))).thenReturn(execCreateCmd);
when(execCreateCmd.withCmd(Matchers.<String>anyVararg())).thenReturn(execCreateCmd);
when(execCreateCmd.withAttachStdout(any(Boolean.class))).thenReturn(execCreateCmd);
when(execCreateCmd.withAttachStderr(any(Boolean.class))).thenReturn(execCreateCmd);
when(execCreateCmd.withUser(any(String.class))).thenReturn(execCreateCmd);
when(execCreateCmd.exec()).thenReturn(response);
final ExecStartCmd execStartCmd = mock(ExecStartCmd.class);
when(dockerClient.execStartCmd(any(String.class))).thenReturn(execStartCmd);
when(execStartCmd.exec(any(ExecStartResultCallback.class))).thenReturn(mock(ExecStartResultCallback.class));
final InspectExecCmd inspectExecCmd = mock(InspectExecCmd.class);
final InspectExecResponse state = mock(InspectExecResponse.class);
when(dockerClient.inspectExecCmd(any(String.class))).thenReturn(inspectExecCmd);
when(inspectExecCmd.exec()).thenReturn(state);
when(state.isRunning()).thenReturn(false);
when(state.getExitCode()).thenReturn(exitCode);
final Docker docker = new DockerImpl(dockerClient);
final ProcessResult result = docker.executeInContainer(new ContainerName(containerId), command);
assertThat(result.getExitStatus(), is(exitCode));
}
}
|
