BSR work also around the currently broken cosmos db emulator image

Author: bramvonk

modules/azure/src/main/java/org/testcontainers/containers/CosmosDBEmulatorContainer.java

@@ -4,6 +4,7 @@
 import org.testcontainers.utility.DockerImageName;
 
 import java.security.KeyStore;
+import java.time.Duration;
 
 /**
  * Testcontainers implementation for CosmosDB Emulator.
@@ -14,6 +15,8 @@
  */
 public class CosmosDBEmulatorContainer extends GenericContainer<CosmosDBEmulatorContainer> {
 
+    static final String CERTIFICATE_ENDPOINT = "/_explorer/emulator.pem";
+
     private static final DockerImageName DEFAULT_IMAGE_NAME = DockerImageName.parse(
         "mcr.microsoft.com/cosmosdb/linux/azure-cosmos-emulator"
     );
@@ -27,13 +30,15 @@ public CosmosDBEmulatorContainer(final DockerImageName dockerImageName) {
         super(dockerImageName);
         dockerImageName.assertCompatibleWith(DEFAULT_IMAGE_NAME);
         withExposedPorts(PORT);
-        waitingFor(Wait.forLogMessage(".*Started\\r\\n$", 1));
+        // Wait.forLogMessage(".*Started\\r\\n$") is not sufficient with the current version of cosmos db emulator (vnext-EN20251022),
+        // see https://github.com/Azure/azure-cosmos-db-emulator-docker/issues/209 .
+        waitingFor(Wait.forHttps(CERTIFICATE_ENDPOINT).allowInsecure().withStartupTimeout(Duration.ofSeconds(120)));
     }
 
     /**
      * @return new KeyStore built with PKCS12
      */
-    public KeyStore buildNewKeyStore() {
+    public KeyStore buildNewKeyStore() throws InterruptedException {
         return KeyStoreBuilder.buildByDownloadingCertificate(getEmulatorEndpoint(), getEmulatorKey());
     }
 

modules/azure/src/main/java/org/testcontainers/containers/KeyStoreBuilder.java

@@ -65,7 +65,7 @@ private static OkHttpClient buildTrustAllClient(TrustManager[] trustManagers) th
     }
 
     private static Request buildRequest(String endpoint) {
-        return new Request.Builder().get().url(endpoint + "/_explorer/emulator.pem").build();
+        return new Request.Builder().get().url(endpoint + CosmosDBEmulatorContainer.CERTIFICATE_ENDPOINT).build();
     }
 
     private static KeyStore buildKeyStore(InputStream certificateStream, String keyStorePassword) throws Exception {

modules/azure/src/test/java/org/testcontainers/containers/CosmosDBEmulatorContainerTest.java

@@ -43,6 +43,9 @@ void testWithCosmosClient() throws Exception {
             );
             // }
         ) {
+//            emulator.addEnv("AZURE_COSMOS_EMULATOR_PARTITION_COUNT", "3");
+//            emulator.addEnv("LOG_LEVEL", "debug");
+//            emulator.addEnv("ENABLE_CONSOLE_EXPORTER", "true");
             emulator.start();
             // buildAndSaveNewKeyStore {
             Path keyStoreFile = tempFolder.resolve("azure-cosmos-emulator.keystore");