docker

Author: rieckpil

spring-boot-example/src/test/java/de/rieckpil/blog/localstack/ImageUploadEventListenerIT.java

@@ -14,16 +14,18 @@
 import org.testcontainers.junit.jupiter.Container;
 import org.testcontainers.junit.jupiter.Testcontainers;
 import org.testcontainers.utility.DockerImageName;
+import org.testcontainers.utility.MountableFile;
 import software.amazon.awssdk.core.sync.RequestBody;
 import software.amazon.awssdk.services.s3.S3Client;
 import software.amazon.awssdk.services.s3.model.GetObjectRequest;
+import software.amazon.awssdk.services.s3.model.NoSuchKeyException;
 import software.amazon.awssdk.services.s3.model.PutObjectRequest;
+import software.amazon.awssdk.services.sqs.SqsAsyncClient;
 import software.amazon.awssdk.services.sqs.SqsClient;
 import software.amazon.awssdk.services.sqs.model.SendMessageRequest;
 
 import static org.awaitility.Awaitility.given;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
-import static org.testcontainers.containers.BindMode.READ_ONLY;
 import static org.testcontainers.containers.localstack.LocalStackContainer.Service;
 import static org.testcontainers.containers.localstack.LocalStackContainer.Service.SQS;
 
@@ -35,21 +37,22 @@ class ImageUploadEventListenerIT {
   static LocalStackContainer localStack =
     new LocalStackContainer(DockerImageName.parse("localstack/localstack:4.0.1"))
       .withServices(Service.S3, Service.SQS)
-      .withClasspathResourceMapping("/localstack", "/docker-entrypoint-initaws.d", READ_ONLY)
+      .withCopyFileToContainer(MountableFile.forClasspathResource("localstack/", 0777), "/etc/localstack/init/ready.d")
       .waitingFor(Wait.forLogMessage(".*Initialized\\.\n", 1));
 
   @DynamicPropertySource
   static void configureLocalStackAccess(DynamicPropertyRegistry registry) {
     registry.add("spring.cloud.aws.credentials.secret-key", () -> "foo");
     registry.add("spring.cloud.aws.credentials.access-key", () -> "bar");
+    registry.add("spring.cloud.aws.sqs.enabled", () -> "true");
     registry.add("spring.cloud.aws.endpoint", () -> localStack.getEndpointOverride(SQS));
   }
 
   @Autowired
   private S3Client s3Client;
 
   @Autowired
-  private SqsClient sqsClient;
+  private SqsAsyncClient sqsClient;
 
   @Test
   void shouldProcessIncomingUploadEventAndUploadThumbnailImage() throws IOException {
@@ -71,6 +74,7 @@ void shouldProcessIncomingUploadEventAndUploadThumbnailImage() throws IOExceptio
     given()
       .atMost(Duration.ofSeconds(5))
       .await()
+      .ignoreException(NoSuchKeyException.class)
       .untilAsserted(() -> assertNotNull(s3Client.getObject(GetObjectRequest.builder().bucket("processed-images").key("thumbnail-duke-mascot.png").build())));
   }
 }

spring-boot-example/src/test/java/de/rieckpil/blog/localstack/ManualBeanOverrideIT.java

@@ -14,6 +14,7 @@
 import org.testcontainers.junit.jupiter.Container;
 import org.testcontainers.junit.jupiter.Testcontainers;
 import org.testcontainers.utility.DockerImageName;
+import org.testcontainers.utility.MountableFile;
 import software.amazon.awssdk.core.sync.RequestBody;
 import software.amazon.awssdk.services.s3.S3Client;
 import software.amazon.awssdk.services.s3.model.GetObjectRequest;
@@ -23,7 +24,6 @@
 
 import static org.awaitility.Awaitility.given;
 import static org.junit.jupiter.api.Assertions.assertNotNull;
-import static org.testcontainers.containers.BindMode.READ_ONLY;
 
 @Testcontainers
 @SpringBootTest(properties = "cloud.aws.sqs.enabled=true")
@@ -33,7 +33,7 @@ class ManualBeanOverrideIT {
   static LocalStackContainer localStack =
     new LocalStackContainer(DockerImageName.parse("localstack/localstack:4.0.1"))
       .withServices(LocalStackContainer.Service.S3, LocalStackContainer.Service.SQS)
-      .withClasspathResourceMapping("/localstack", "/docker-entrypoint-initaws.d", READ_ONLY)
+      .withCopyFileToContainer(MountableFile.forClasspathResource("localstack/", 0777), "/etc/localstack/init/ready.d")
       .waitingFor(Wait.forLogMessage(".*Initialized\\.\n", 1));
 
   @Autowired