Automated container feature enabling

Author: intisy

.idea/AndroidProjectSystem.xml

@@ -27,4 +27,8 @@ dependencies {
     implementation "org.apache.commons:commons-compress:1.24.0"
     implementation "org.slf4j:slf4j-simple:2.0.7"
     testImplementation "org.junit.jupiter:junit-jupiter:5.10.1"
+}
+
+test {
+    useJUnitPlatform()
 }

.idea/gradle.xml

@@ -6,9 +6,7 @@
 import com.github.dockerjava.httpclient5.ApacheDockerHttpClient;
 import com.github.dockerjava.transport.DockerHttpClient;
 
-import java.io.File;
-import java.io.IOException;
-import java.io.InputStream;
+import java.io.*;
 import java.net.HttpURLConnection;
 import java.net.URL;
 import java.nio.file.Files;
@@ -105,6 +103,13 @@ private void downloadAndExtract(String urlString) throws IOException {
 
     @Override
     public void start() throws IOException, InterruptedException {
+        if (!isAdministrator()) {
+            System.err.println("\nERROR: Docker daemon on Windows requires Administrator privileges.\nPlease run your application or test as Administrator.\n");
+            throw new RuntimeException("Administrator privileges required to start Docker daemon on Windows.");
+        }
+
+        ensureContainersFeatureEnabled();
+
         this.dockerClient = tryConnectToExistingDocker();
         if (this.dockerClient != null) {
             return;
@@ -123,15 +128,50 @@ public void start() throws IOException, InterruptedException {
         }
     }
 
-    private DockerClient tryConnectToExistingDocker() {
-        String systemPipePath = "//./pipe/docker_engine";
-        File systemPipe = new File(systemPipePath);
+    private void ensureContainersFeatureEnabled() throws IOException, InterruptedException {
+        ProcessBuilder pb = new ProcessBuilder("powershell.exe", "-Command", "Get-WindowsOptionalFeature -Online -FeatureName Containers");
+        pb.redirectErrorStream(true);
+        Process process = pb.start();
+        
+        StringBuilder output = new StringBuilder();
+        try (BufferedReader reader = new BufferedReader(new InputStreamReader(process.getInputStream()))) {
+            String line;
+            while ((line = reader.readLine()) != null) {
+                output.append(line).append("\n");
+            }
+        }
+        
+        process.waitFor();
+        String outputStr = output.toString();
+        
+        if (!outputStr.contains("State : Enabled")) {
+            System.out.println("Enabling Windows Containers feature (requires reboot)...");
+            ProcessBuilder enablePb = new ProcessBuilder("powershell.exe", "-Command", "Enable-WindowsOptionalFeature -Online -FeatureName Containers -All");
+            enablePb.inheritIO();
+            Process enableProcess = enablePb.start();
+            enableProcess.waitFor();
+            System.err.println("\nThe Windows Containers feature was just enabled. Please reboot your computer and run again.\n");
+            throw new RuntimeException("Windows Containers feature enabled. Reboot required.");
+        }
+    }
+
+    private boolean isAdministrator() {
+        try {
+            ProcessBuilder pb = new ProcessBuilder("net", "session");
+            pb.redirectErrorStream(true);
+            Process process = pb.start();
+            return process.waitFor() == 0;
+        } catch (IOException | InterruptedException e) {
+            return false;
+        }
+    }
 
-        if (systemPipe.exists()) {
-            System.out.println("Found existing Docker pipe at " + systemPipePath + ". Attempting to connect.");
+    private DockerClient tryConnectToExistingDocker() {
+        if (Files.exists(DOCKER_PIPE_PATH)) {
+            System.out.println("Found existing Docker pipe at " + DOCKER_PIPE_PATH + ". Attempting to connect.");
             try {
                 DefaultDockerClientConfig config = DefaultDockerClientConfig.createDefaultConfigBuilder()
-                        .withDockerHost("npipe://" + systemPipePath).build();
+                        .withDockerHost("npipe://" + DOCKER_PIPE_PATH.toString().replace("\\", "/")).build();
 
                 DockerHttpClient httpClient = new ApacheDockerHttpClient.Builder()
                         .dockerHost(config.getDockerHost())
@@ -143,7 +183,7 @@ private DockerClient tryConnectToExistingDocker() {
                 System.out.println("Successfully connected to existing Docker daemon.");
                 return client;
             } catch (Exception e) {
-                System.err.println("Failed to connect to existing Docker daemon at " + systemPipePath + ": " + e.getMessage());
+                System.err.println("Failed to connect to existing Docker daemon at " + DOCKER_PIPE_PATH + ": " + e.getMessage());
             }
         }
         return null;

.idea/vcs.xml

@@ -7,6 +7,7 @@
 import com.github.dockerjava.api.model.ExposedPort;
 import com.github.dockerjava.api.model.HostConfig;
 import com.github.dockerjava.api.model.Ports;
+import org.junit.jupiter.api.Test;
 
 import java.util.concurrent.TimeUnit;
 
@@ -89,17 +90,22 @@ public void shutdown() {
     }
 
     public static void main(String[] args) {
-        System.out.println("Starting container test on OS: " + System.getProperty("os.name"));
         ContainerTest test = new ContainerTest();
+        test.start();
+    }
+
+    @Test
+    public void start() {
+        System.out.println("Starting container test on OS: " + System.getProperty("os.name"));
         try {
-            test.initialize();
-            test.pullAndRunContainer("nginx:alpine", 80);
+            initialize();
+            pullAndRunContainer("nginx:alpine", 80);
             System.out.println("Container started successfully. The application will now shut down.");
-            Runtime.getRuntime().addShutdownHook(new Thread(test::shutdown));
+            Runtime.getRuntime().addShutdownHook(new Thread(this::shutdown));
 
         } catch (Exception e) {
             System.err.println("A critical error occurred:");
-            test.shutdown();
+            shutdown();
             throw new RuntimeException(e);
         }
     }