Start adding domain socket support to ContainerPgRule

Author: vietj

vertx-pg-client/src/test/java/io/vertx/tests/pgclient/junit/ContainerPgRule.java

@@ -24,10 +24,17 @@
 import org.testcontainers.containers.InternetProtocol;
 import org.testcontainers.containers.wait.strategy.LogMessageWaitStrategy;
 
+import java.io.File;
+import java.nio.file.Files;
+import java.nio.file.attribute.PosixFilePermission;
 import java.time.Duration;
 import java.time.temporal.ChronoUnit;
+import java.util.ArrayList;
+import java.util.HashSet;
+import java.util.List;
 
 import static io.vertx.pgclient.PgConnectOptions.DEFAULT_PORT;
+import static org.junit.Assert.assertTrue;
 
 /**
  * Postgresql test database based on https://www.testcontainers.org
@@ -48,6 +55,7 @@ public class ContainerPgRule extends ExternalResource {
   private boolean ssl;
   private boolean forceSsl;
   private String user = "postgres";
+  private File sock;
 
   public ContainerPgRule ssl(boolean ssl) {
     this.ssl = ssl;
@@ -76,6 +84,29 @@ public ContainerPgRule user(String user) {
   }
 
   private void initServer(String version) throws Exception {
+
+    List<String> cmd = new ArrayList<>(List.of("postgres", "-c", "fsync=off"));
+
+    // Domain socket on Linux
+    String osName = System.getProperty("os.name");
+    if (osName != null && (osName.startsWith("Linux") || osName.startsWith("LINUX"))) {
+      // Create temp file, length must be < 107 chars (Linux limitation)
+      sock = Files.createTempFile("pg_", ".sock").toFile();
+      assertTrue(sock.delete());
+      assertTrue(sock.mkdir());
+      sock.deleteOnExit();
+      Files.setPosixFilePermissions(sock.toPath(), new HashSet<>(List.of(
+        PosixFilePermission.OWNER_EXECUTE,
+        PosixFilePermission.OWNER_READ,
+        PosixFilePermission.OWNER_WRITE,
+        PosixFilePermission.GROUP_EXECUTE,
+        PosixFilePermission.GROUP_READ,
+        PosixFilePermission.GROUP_WRITE
+      )));
+      cmd.add("-k");
+      cmd.add("/var/run/mysqld"); // Todo : change this path
+    }
+
     server = new ServerContainer<>("postgres:" + version)
       .withEnv("POSTGRES_DB", "postgres")
       .withEnv("POSTGRES_USER", user)
@@ -84,8 +115,13 @@ private void initServer(String version) throws Exception {
         .withRegEx(".*database system is ready to accept connections.*\\s")
         .withTimes(2)
         .withStartupTimeout(Duration.of(60, ChronoUnit.SECONDS)))
-      .withCommand("postgres", "-c", "fsync=off")
+      .withCommand(cmd.toArray(new String[0]))
       .withClasspathResourceMapping("create-postgres.sql", "/docker-entrypoint-initdb.d/create-postgres.sql", BindMode.READ_ONLY);
+
+    if (sock != null) {
+      server = server.withFileSystemBind(sock.getAbsolutePath(), "/var/run/mysqld");
+    }
+
     if (ssl) {
       server
         .withClasspathResourceMapping("tls/server.crt", "/server.crt", BindMode.READ_ONLY)