package com.github.dockerjava.core;

import com.github.dockerjava.api.DockerClient;

import com.github.dockerjava.api.command.AttachContainerCmd;

import com.github.dockerjava.api.command.AuthCmd;

import com.github.dockerjava.api.command.BuildImageCmd;

import com.github.dockerjava.api.command.CommitCmd;

import com.github.dockerjava.api.command.ContainerDiffCmd;

import com.github.dockerjava.api.command.CopyFileFromContainerCmd;

import com.github.dockerjava.api.command.CreateContainerCmd;

import com.github.dockerjava.api.command.CreateImageCmd;

import com.github.dockerjava.api.command.DockerCmdExecFactory;

import com.github.dockerjava.api.command.EventsCmd;

import com.github.dockerjava.api.command.ExecCreateCmd;

import com.github.dockerjava.api.command.ExecStartCmd;

import com.github.dockerjava.api.command.InfoCmd;

import com.github.dockerjava.api.command.InspectContainerCmd;

import com.github.dockerjava.api.command.InspectExecCmd;

import com.github.dockerjava.api.command.InspectImageCmd;

import com.github.dockerjava.api.command.KillContainerCmd;

import com.github.dockerjava.api.command.ListContainersCmd;

import com.github.dockerjava.api.command.ListImagesCmd;

import com.github.dockerjava.api.command.LogContainerCmd;

import com.github.dockerjava.api.command.PauseContainerCmd;

import com.github.dockerjava.api.command.PingCmd;

import com.github.dockerjava.api.command.PullImageCmd;

import com.github.dockerjava.api.command.PushImageCmd;

import com.github.dockerjava.api.command.RemoveContainerCmd;

import com.github.dockerjava.api.command.RemoveImageCmd;

import com.github.dockerjava.api.command.RestartContainerCmd;

import com.github.dockerjava.api.command.SaveImageCmd;

import com.github.dockerjava.api.command.SearchImagesCmd;

import com.github.dockerjava.api.command.StartContainerCmd;

import com.github.dockerjava.api.command.StatsCmd;

import com.github.dockerjava.api.command.StopContainerCmd;

import com.github.dockerjava.api.command.TagImageCmd;

import com.github.dockerjava.api.command.TopContainerCmd;

import com.github.dockerjava.api.command.UnpauseContainerCmd;

import com.github.dockerjava.api.command.VersionCmd;

import com.github.dockerjava.api.command.WaitContainerCmd;

import com.github.dockerjava.api.model.AuthConfig;

import com.github.dockerjava.api.model.Identifier;

import com.github.dockerjava.core.command.AttachContainerCmdImpl;

import com.github.dockerjava.core.command.AuthCmdImpl;

import com.github.dockerjava.core.command.BuildImageCmdImpl;

import com.github.dockerjava.core.command.CommitCmdImpl;

import com.github.dockerjava.core.command.ContainerDiffCmdImpl;

import com.github.dockerjava.core.command.CopyFileFromContainerCmdImpl;

import com.github.dockerjava.core.command.CreateContainerCmdImpl;

import com.github.dockerjava.core.command.CreateImageCmdImpl;

import com.github.dockerjava.core.command.EventsCmdImpl;

import com.github.dockerjava.core.command.ExecCreateCmdImpl;

import com.github.dockerjava.core.command.ExecStartCmdImpl;

import com.github.dockerjava.core.command.InfoCmdImpl;

import com.github.dockerjava.core.command.InspectContainerCmdImpl;

import com.github.dockerjava.core.command.InspectExecCmdImpl;

import com.github.dockerjava.core.command.InspectImageCmdImpl;

import com.github.dockerjava.core.command.KillContainerCmdImpl;

import com.github.dockerjava.core.command.ListContainersCmdImpl;

import com.github.dockerjava.core.command.ListImagesCmdImpl;

import com.github.dockerjava.core.command.LogContainerCmdImpl;

import com.github.dockerjava.core.command.PauseContainerCmdImpl;

import com.github.dockerjava.core.command.PingCmdImpl;

import com.github.dockerjava.core.command.PullImageCmdImpl;

import com.github.dockerjava.core.command.PushImageCmdImpl;

import com.github.dockerjava.core.command.RemoveContainerCmdImpl;

import com.github.dockerjava.core.command.RemoveImageCmdImpl;

import com.github.dockerjava.core.command.RestartContainerCmdImpl;

import com.github.dockerjava.core.command.SaveImageCmdImpl;

import com.github.dockerjava.core.command.SearchImagesCmdImpl;

import com.github.dockerjava.core.command.StartContainerCmdImpl;

import com.github.dockerjava.core.command.StatsCmdImpl;

import com.github.dockerjava.core.command.StopContainerCmdImpl;

import com.github.dockerjava.core.command.TagImageCmdImpl;

import com.github.dockerjava.core.command.TopContainerCmdImpl;

import com.github.dockerjava.core.command.UnpauseContainerCmdImpl;

import com.github.dockerjava.core.command.VersionCmdImpl;

import com.github.dockerjava.core.command.WaitContainerCmdImpl;

import java.io.Closeable;

import java.io.File;

import java.io.IOException;

import java.io.InputStream;

import static com.google.common.base.Preconditions.checkNotNull;

/**

* @author Konstantin Pelykh (kpelykh@gmail.com)

*

* @see "https://github.com/docker/docker/blob/master/api/client/commands.go"

*/

public class DockerClientImpl implements Closeable, DockerClient {

private final DockerClientConfig dockerClientConfig;

private DockerCmdExecFactory dockerCmdExecFactory;

private DockerClientImpl() {

this(DockerClientConfig.createDefaultConfigBuilder().build());

}

private DockerClientImpl(String serverUrl) {

this(configWithServerUrl(serverUrl));

}

private DockerClientImpl(DockerClientConfig dockerClientConfig) {

checkNotNull(dockerClientConfig, "config was not specified");

this.dockerClientConfig = dockerClientConfig;

}

private static DockerClientConfig configWithServerUrl(String serverUrl) {

return DockerClientConfig.createDefaultConfigBuilder().withUri(serverUrl).build();

}

public static DockerClientImpl getInstance() {

return new DockerClientImpl();

}

public static DockerClientImpl getInstance(DockerClientConfig dockerClientConfig) {

return new DockerClientImpl(dockerClientConfig);

}

public static DockerClientImpl getInstance(String serverUrl) {

return new DockerClientImpl(serverUrl);

}

public DockerClientImpl withDockerCmdExecFactory(DockerCmdExecFactory dockerCmdExecFactory) {

checkNotNull(dockerCmdExecFactory, "dockerCmdExecFactory was not specified");

this.dockerCmdExecFactory = dockerCmdExecFactory;

this.dockerCmdExecFactory.init(dockerClientConfig);

return this;

}

private DockerCmdExecFactory getDockerCmdExecFactory() {

checkNotNull(dockerCmdExecFactory, "dockerCmdExecFactory was not specified");

return dockerCmdExecFactory;

}

@Override

public AuthConfig authConfig() {

checkNotNull(dockerClientConfig.getUsername(), "Configured username is null.");

checkNotNull(dockerClientConfig.getServerAddress(), "Configured serverAddress is null.");

AuthConfig authConfig = new AuthConfig();

authConfig.setUsername(dockerClientConfig.getUsername());

authConfig.setPassword(dockerClientConfig.getPassword());

authConfig.setEmail(dockerClientConfig.getEmail());

authConfig.setServerAddress(dockerClientConfig.getServerAddress());

return authConfig;

}

/**

* * MISC API *

*/

/**

* Authenticate with the server, useful for checking authentication.

*/

@Override

public AuthCmd authCmd() {

return new AuthCmdImpl(getDockerCmdExecFactory().createAuthCmdExec(), authConfig());

}

@Override

public InfoCmd infoCmd() {

return new InfoCmdImpl(getDockerCmdExecFactory().createInfoCmdExec());

}

@Override

public PingCmd pingCmd() {

return new PingCmdImpl(getDockerCmdExecFactory().createPingCmdExec());

}

@Override

public VersionCmd versionCmd() {

return new VersionCmdImpl(getDockerCmdExecFactory().createVersionCmdExec());

}

/**

* * IMAGE API *

*/

@Override

public PullImageCmd pullImageCmd(String repository) {

return new PullImageCmdImpl(getDockerCmdExecFactory().createPullImageCmdExec(),

dockerClientConfig.effectiveAuthConfig(repository), repository);

}

@Override

public PushImageCmd pushImageCmd(String name) {

PushImageCmd cmd = new PushImageCmdImpl(getDockerCmdExecFactory().createPushImageCmdExec(), name);

AuthConfig cfg = dockerClientConfig.effectiveAuthConfig(name);

if (cfg != null)

cmd.withAuthConfig(cfg);

return cmd;

}

@Override

public PushImageCmd pushImageCmd(Identifier identifier) {

PushImageCmd cmd = pushImageCmd(identifier.repository.name);

if (identifier.tag.isPresent())

cmd.withTag(identifier.tag.get());

AuthConfig cfg = dockerClientConfig.effectiveAuthConfig(identifier.repository.name);

if (cfg != null)

cmd.withAuthConfig(cfg);

return cmd;

}

@Override

public SaveImageCmd saveImageCmd(String name) {

return new SaveImageCmdImpl(getDockerCmdExecFactory().createSaveImageCmdExec(), name);

}

@Override

public CreateImageCmd createImageCmd(String repository, InputStream imageStream) {

return new CreateImageCmdImpl(getDockerCmdExecFactory().createCreateImageCmdExec(), repository, imageStream);

}

@Override

public SearchImagesCmd searchImagesCmd(String term) {

return new SearchImagesCmdImpl(getDockerCmdExecFactory().createSearchImagesCmdExec(), term);

}

@Override

public RemoveImageCmd removeImageCmd(String imageId) {

return new RemoveImageCmdImpl(getDockerCmdExecFactory().createRemoveImageCmdExec(), imageId);

}

@Override

public ListImagesCmd listImagesCmd() {

return new ListImagesCmdImpl(getDockerCmdExecFactory().createListImagesCmdExec());

}

@Override

public InspectImageCmd inspectImageCmd(String imageId) {

return new InspectImageCmdImpl(getDockerCmdExecFactory().createInspectImageCmdExec(), imageId);

}

/**

* * CONTAINER API *

*/

@Override

public ListContainersCmd listContainersCmd() {

return new ListContainersCmdImpl(getDockerCmdExecFactory().createListContainersCmdExec());

}

@Override

public CreateContainerCmd createContainerCmd(String image) {

return new CreateContainerCmdImpl(getDockerCmdExecFactory().createCreateContainerCmdExec(), image);

}

@Override

public StartContainerCmd startContainerCmd(String containerId) {

return new StartContainerCmdImpl(getDockerCmdExecFactory().createStartContainerCmdExec(), containerId);

}

@Override

public InspectContainerCmd inspectContainerCmd(String containerId) {

return new InspectContainerCmdImpl(getDockerCmdExecFactory().createInspectContainerCmdExec(), containerId);

}

@Override

public ExecCreateCmd execCreateCmd(String containerId) {

return new ExecCreateCmdImpl(getDockerCmdExecFactory().createExecCmdExec(), containerId);

}

@Override

public RemoveContainerCmd removeContainerCmd(String containerId) {

return new RemoveContainerCmdImpl(getDockerCmdExecFactory().createRemoveContainerCmdExec(), containerId);

}

@Override

public WaitContainerCmd waitContainerCmd(String containerId) {

return new WaitContainerCmdImpl(getDockerCmdExecFactory().createWaitContainerCmdExec(), containerId);

}

@Override

public AttachContainerCmd attachContainerCmd(String containerId) {

return new AttachContainerCmdImpl(getDockerCmdExecFactory().createAttachContainerCmdExec(), containerId);

}

@Override

public ExecStartCmd execStartCmd(String containerId) {

return new ExecStartCmdImpl(getDockerCmdExecFactory().createExecStartCmdExec(), containerId);

}

@Override

public InspectExecCmd inspectExecCmd(String execId) {

return new InspectExecCmdImpl(getDockerCmdExecFactory().createInspectExecCmdExec(), execId);

}

@Override

public LogContainerCmd logContainerCmd(String containerId) {

return new LogContainerCmdImpl(getDockerCmdExecFactory().createLogContainerCmdExec(), containerId);

}

@Override

public CopyFileFromContainerCmd copyFileFromContainerCmd(String containerId, String resource) {

return new CopyFileFromContainerCmdImpl(getDockerCmdExecFactory().createCopyFileFromContainerCmdExec(),

containerId, resource);

}

@Override

public ContainerDiffCmd containerDiffCmd(String containerId) {

return new ContainerDiffCmdImpl(getDockerCmdExecFactory().createContainerDiffCmdExec(), containerId);

}

@Override

public StopContainerCmd stopContainerCmd(String containerId) {

return new StopContainerCmdImpl(getDockerCmdExecFactory().createStopContainerCmdExec(), containerId);

}

@Override

public KillContainerCmd killContainerCmd(String containerId) {

return new KillContainerCmdImpl(getDockerCmdExecFactory().createKillContainerCmdExec(), containerId);

}

@Override

public RestartContainerCmd restartContainerCmd(String containerId) {

return new RestartContainerCmdImpl(getDockerCmdExecFactory().createRestartContainerCmdExec(), containerId);

}

@Override

public CommitCmd commitCmd(String containerId) {

return new CommitCmdImpl(getDockerCmdExecFactory().createCommitCmdExec(), containerId);

}

@Override

public BuildImageCmd buildImageCmd() {

return new BuildImageCmdImpl(getDockerCmdExecFactory().createBuildImageCmdExec());

}

@Override

public BuildImageCmd buildImageCmd(File dockerFileOrFolder) {

return new BuildImageCmdImpl(getDockerCmdExecFactory().createBuildImageCmdExec(), dockerFileOrFolder);

}

@Override

public BuildImageCmd buildImageCmd(InputStream tarInputStream) {

return new BuildImageCmdImpl(getDockerCmdExecFactory().createBuildImageCmdExec(), tarInputStream);

}

@Override

public TopContainerCmd topContainerCmd(String containerId) {

return new TopContainerCmdImpl(getDockerCmdExecFactory().createTopContainerCmdExec(), containerId);

}

@Override

public TagImageCmd tagImageCmd(String imageId, String repository, String tag) {

return new TagImageCmdImpl(getDockerCmdExecFactory().createTagImageCmdExec(), imageId, repository, tag);

}

@Override

public PauseContainerCmd pauseContainerCmd(String containerId) {

return new PauseContainerCmdImpl(getDockerCmdExecFactory().createPauseContainerCmdExec(), containerId);

}

@Override

public UnpauseContainerCmd unpauseContainerCmd(String containerId) {

return new UnpauseContainerCmdImpl(getDockerCmdExecFactory().createUnpauseContainerCmdExec(), containerId);

}

@Override

public EventsCmd eventsCmd() {

return new EventsCmdImpl(getDockerCmdExecFactory().createEventsCmdExec());

}

@Override

public StatsCmd statsCmd() {

return new StatsCmdImpl(getDockerCmdExecFactory().createStatsCmdExec());

}

@Override

public void close() throws IOException {

getDockerCmdExecFactory().close();

}

}