Fixes problems with Keycloak in the CI (#739)

* Fixes problems with keycloak in the CI

* Tries to fix kafka problem in SM Service

* Fixes problem in kafka tests

Author: aaronzi

basyx.submodelservice/basyx.submodelservice-feature-kafka/src/test/java/org/eclipse/digitaltwin/basyx/submodelservice/feature/kafka/KafkaSubmodelServiceIdsOnlySmokeTest.java

@@ -88,12 +88,20 @@ public class KafkaSubmodelServiceIdsOnlySmokeTest {
 	@Before
 	public void awaitAssignment() throws InterruptedException, SerializationException {
 		listener.awaitTopicAssignment();
+
+		assertNoAdditionalMessage();
 
 		FileRepository repository = new InMemoryFileRepository();
 		SubmodelBackend backend = new InMemorySubmodelBackend();
 		SubmodelServiceFactory smFactory = new CrudSubmodelServiceFactory(backend ,repository);
 		service = feature.decorate(smFactory).create(submodel);
 	}
+
+	@After
+	public void assertNoAdditionalMessage() throws InterruptedException {
+		SubmodelEvent evt = listener.next(1, TimeUnit.SECONDS);
+		Assert.assertNull(evt);
+	}
 
 	@Test
 	public void testToplevelSubmodelElementAdded() throws InterruptedException {

basyx.submodelservice/basyx.submodelservice-feature-kafka/src/test/java/org/eclipse/digitaltwin/basyx/submodelservice/feature/kafka/KafkaSubmodelServiceSubmodelElementsEventsIntegrationTest.java

@@ -89,12 +89,20 @@ public class KafkaSubmodelServiceSubmodelElementsEventsIntegrationTest {
 	@Before
 	public void awaitAssignment() throws InterruptedException {
 		listener.awaitTopicAssignment();
+
+		skipAdditionalMessage();
 
 		FileRepository repository = new InMemoryFileRepository();
 		SubmodelBackend backend = new InMemorySubmodelBackend();
 		SubmodelServiceFactory smFactory = new CrudSubmodelServiceFactory(backend ,repository);
 		service = feature.decorate(smFactory).create(submodel);
 	}
+
+	@After
+	public void skipAdditionalMessage() throws InterruptedException {
+		while(listener.next(1, TimeUnit.SECONDS) != null);
+
+	}
 
 	@Test
 	public void testToplevelSubmodelElementAdded() throws InterruptedException, SerializationException {

basyx.submodelservice/basyx.submodelservice-feature-kafka/src/test/java/org/eclipse/digitaltwin/basyx/submodelservice/feature/kafka/KafkaSubmodelServiceSubmodelEventsIntegrationTest.java

@@ -81,6 +81,12 @@ public void awaitAssignment() throws InterruptedException {
 		listener.awaitTopicAssignment();
 	}
 
+	@After
+	public void assertGotTearDownMessage() throws InterruptedException {
+		SubmodelEvent evt = listener.next(1, TimeUnit.MINUTES);
+		Assert.assertNull(evt);
+	}
+
 	@Test
 	public void testSubmodelEvents() throws InterruptedException {
 		// we expect the "onStartup" submodel created event

ci/docker-compose.yml

@@ -1,4 +1,3 @@
-version: "3.9"
 services:
 
   nginx-proxy:
@@ -16,18 +15,15 @@ services:
 
   mongo:
     image: mongo:5.0.10
-    # Provide mongo config
     restart: always
     environment:
       MONGO_INITDB_ROOT_USERNAME: mongoAdmin
       MONGO_INITDB_ROOT_PASSWORD: mongoPassword
-    # Set health checks to wait until mongo has started
     healthcheck:
       test: mongo
       interval: 10s
       start_period: 5s
       retries: 5
-    # Maps tcp port to host
     ports:
       - 27017:27017
     networks:
@@ -109,6 +105,9 @@ services:
     volumes:
       - ./keycloak/rules/rbac_rules-aas-discovery.json:/rbac/rbac_rules.json:ro
     restart: always
+    depends_on:
+      keycloak-healthcheck:
+        condition: service_healthy
     networks:
       - basyx-java-server-sdk
 
@@ -153,6 +152,9 @@ services:
     volumes:
       - ./keycloak/rules/rbac_rules-aas-registry.json:/rbac/rbac_rules.json:ro
     restart: always
+    depends_on:
+      keycloak-healthcheck:
+        condition: service_healthy
     networks:
       - basyx-java-server-sdk
 
@@ -174,6 +176,9 @@ services:
       - ./keycloak/rules/rbac_rules-sm-registry.json:/rbac/rbac_rules.json:ro
     ports:
       - "8061:8080"
+    depends_on:
+      keycloak-healthcheck:
+        condition: service_healthy
     restart: always
     networks:
       - basyx-java-server-sdk
@@ -187,6 +192,9 @@ services:
       - ./rules/sm-repo-rbac_rules.json:/application/rbac_rules.json
       - ./rules/sm-repo.properties:/application/application.properties
     restart: always
+    depends_on:
+      keycloak-healthcheck:
+        condition: service_healthy
     networks:
       - basyx-java-server-sdk
 
@@ -253,9 +261,19 @@ services:
         until curl -sf http://keycloak-nginx:8080/health/ready; do
           sleep 5;
         done;
-        echo 'Keycloak is ready!'"
+        echo 'Keycloak is ready!';
+        # Create a file that signals Keycloak is ready
+        touch /tmp/keycloak-ready;
+        # Keep container running after health check passes
+        tail -f /dev/null"
     depends_on:
-      - keycloak
+      - keycloak-nginx
+    healthcheck:
+      test: ["CMD", "test", "-f", "/tmp/keycloak-ready"]
+      interval: 10s
+      timeout: 3s
+      retries: 20
+      start_period: 5s
     networks:
       - basyx-java-server-sdk
 

ci/keycloak/Dockerfile

@@ -1,4 +1,4 @@
-FROM quay.io/keycloak/keycloak:22.0.0
+FROM quay.io/keycloak/keycloak:24.0.4
 ARG HTTP_PROXY
 ARG HTTPS_PROXY
 # Make the realm configuration available for import