beta of the redis enterprise container

Author: jruaux

build.gradle

@@ -2,7 +2,9 @@ plugins {
     id 'java-library'
     id 'maven-publish'
     id 'signing'
-    id 'io.github.gradle-nexus.publish-plugin' version '1.0.0'
+    id 'org.springframework.boot' version '2.4.5'
+    id 'io.spring.dependency-management' version '1.0.11.RELEASE'
+    id 'io.github.gradle-nexus.publish-plugin' version '1.1.0'
     id 'net.researchgate.release' version '2.8.1'
     id 'com.github.ben-manes.versions' version '0.38.0'
     id 'com.github.breadmoirai.github-release' version '2.2.12'
@@ -23,18 +25,26 @@ repositories {
     mavenLocal()
 }
 
+bootJar {
+    enabled = false
+}
+
+jar {
+    enabled = true
+}
+
 dependencies {
-    compileOnly group: 'org.projectlombok', name: 'lombok', version: lombok_version
-    annotationProcessor group: 'org.projectlombok', name: 'lombok', version: lombok_version
-    api group: 'org.junit.jupiter', name:'junit-jupiter-api', version: junit_version
-    api group: 'org.junit.jupiter', name:'junit-jupiter-engine', version: junit_version
-    api group: 'org.junit.jupiter', name:'junit-jupiter-params', version: junit_version
+    compileOnly 'org.projectlombok:lombok'
+    annotationProcessor 'org.projectlombok:lombok'
+    api 'org.junit.jupiter:junit-jupiter-api'
+    api 'org.junit.jupiter:junit-jupiter-engine'
+    api 'org.junit.jupiter:junit-jupiter-params'
     api group: 'org.testcontainers', name: 'testcontainers', version: testcontainers_version
     api group: 'org.testcontainers', name: 'junit-jupiter', version: testcontainers_version
-    testImplementation 'com.redislabs:mesclun:1.2.4'
-    testImplementation 'org.slf4j:slf4j-simple:1.7.30'
-    testImplementation group: 'org.projectlombok', name: 'lombok', version: lombok_version
-    testAnnotationProcessor group: 'org.projectlombok', name: 'lombok', version: lombok_version
+    testImplementation 'com.redislabs:mesclun:1.3.2'
+    testImplementation 'org.projectlombok:lombok'
+    testAnnotationProcessor 'org.projectlombok:lombok'
+    testImplementation 'ch.qos.logback:logback-classic:1.2.3'
 }
 
 test {

gradle/wrapper/gradle-wrapper.properties

@@ -1,5 +1,5 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-7.0-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-7.0.2-bin.zip
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists

src/main/java/com/redislabs/testcontainers/RedisEnterpriseContainer.java

@@ -0,0 +1,48 @@
+package com.redislabs.testcontainers;
+
+import org.testcontainers.containers.GenericContainer;
+import org.testcontainers.shaded.org.apache.commons.lang.ClassUtils;
+
+import java.time.Duration;
+import java.time.temporal.ChronoUnit;
+import java.util.Arrays;
+import java.util.List;
+
+public class RedisEnterpriseContainer extends GenericContainer<RedisEnterpriseContainer> implements RedisContainer {
+
+    public static final String DEFAULT_IMAGE_NAME = "redislabs/redis:latest";
+    public static final List<Integer> PORTS = Arrays.asList(53, 5353, 8001, 8070, 8080, 8443, 9443, 12000);
+
+    private static final int DEFAULT_STARTUP_TIMEOUT_SECONDS = 240;
+    private static final int DEFAULT_CONNECT_TIMEOUT_SECONDS = 120;
+
+    public RedisEnterpriseContainer() {
+        super(DEFAULT_IMAGE_NAME);
+        withPrivilegedMode(true);
+        setStartupAttempts(1);
+        withStartupTimeout(Duration.of(2, ChronoUnit.MINUTES));
+        withExposedPorts(PORTS.toArray(new Integer[0]));
+        PORTS.forEach(p -> addFixedExposedPort(p, p));
+    }
+
+    @Override
+    public boolean isCluster() {
+        return false;
+    }
+
+    /**
+     * Get Redis URI.
+     *
+     * @return Redis URI.
+     */
+    @Override
+    public String getRedisURI() {
+        return RedisContainerUtils.redisURI(this);
+    }
+
+    @Override
+    public String toString() {
+        return ClassUtils.getShortClassName(getClass());
+    }
+
+}

src/test/java/com/redislabs/testcontainers/TestRedisEnterpriseContainer.java

@@ -0,0 +1,65 @@
+package com.redislabs.testcontainers;
+
+import io.lettuce.core.RedisClient;
+import io.lettuce.core.api.StatefulRedisConnection;
+import io.netty.util.internal.logging.InternalLoggerFactory;
+import io.netty.util.internal.logging.JdkLoggerFactory;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.jupiter.api.*;
+import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.startupcheck.StartupCheckStrategy;
+
+import java.util.HashMap;
+import java.util.Map;
+import java.util.logging.ConsoleHandler;
+import java.util.logging.Level;
+import java.util.logging.LogManager;
+import java.util.logging.Logger;
+
+//@Testcontainers
+@Slf4j
+public class TestRedisEnterpriseContainer {
+
+    private static final String ROOT_LOGGER = "";
+    private RedisClient client;
+    private StatefulRedisConnection<String, String> connection;
+
+    @BeforeAll
+    static void isRunning() {
+        RedisEnterpriseContainer redisEnterprise = new RedisEnterpriseContainer();
+        redisEnterprise.withLogConsumer(new Slf4jLogConsumer(log));
+        redisEnterprise.start();
+        Assertions.assertTrue(redisEnterprise.isRunning());
+    }
+
+//    @BeforeEach
+//    public void setupEach() {
+//        this.client = RedisClient.create(REDIS_ENTERPRISE.getRedisURI());
+//        this.connection = client.connect();
+//    }
+//
+//    @AfterEach
+//    public void cleanupEach() {
+//        connection.sync().flushall();
+//        connection.close();
+//        client.shutdown();
+//    }
+
+    @Test
+    void canPing() {
+//        Assertions.assertEquals("PONG", connection.sync().ping());
+    }
+//
+//    @Test
+//    void canWrite() {
+//        Map<String, String> hash = new HashMap<>();
+//        hash.put("field1", "value1");
+//        connection.sync().hset("hash:test", hash);
+//        Map<String, String> response = connection.sync().hgetall("hash:test");
+//        Assertions.assertEquals(hash, response);
+//    }
+
+    public static void main(String[] args) {
+        isRunning();
+    }
+}

src/test/resources/logback-test.xml

@@ -0,0 +1,14 @@
+<configuration>
+    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
+        <encoder>
+            <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger - %msg%n</pattern>
+        </encoder>
+    </appender>
+
+    <root level="debug">
+        <appender-ref ref="STDOUT"/>
+    </root>
+
+    <logger name="org.testcontainers" level="DEBUG"/>
+    <logger name="com.github.dockerjava" level="DEBUG"/>
+</configuration>