Add support for abortOnContainerExit to HTTP wait strategy

packages/testcontainers/src/wait-strategies/http-wait-strategy.ts

@@ -14,7 +14,7 @@ export class HttpWaitStrategy extends AbstractWaitStrategy {
   private _allowInsecure = false;
   private readTimeout = 1000;
 
-  constructor(private readonly path: string, private readonly port: number) {
+  constructor(private readonly path: string, private readonly port: number, private readonly shutdownOnExit = false) {
     super();
   }
 
@@ -66,9 +66,9 @@ export class HttpWaitStrategy extends AbstractWaitStrategy {
 
   public async waitUntilReady(container: Dockerode.Container, boundPorts: BoundPorts): Promise<void> {
     log.debug(`Waiting for HTTP...`, { containerId: container.id });
-    const client = await getContainerRuntimeClient();
 
-    await new IntervalRetry<Response | undefined, Error>(this.readTimeout).retryUntil(
+    const client = await getContainerRuntimeClient();
+    const healthCheckPromise = new IntervalRetry<Response | undefined, Error>(this.readTimeout).retryUntil(
       async () => {
         try {
           const url = `${this.protocol}://${client.info.containerRuntime.host}:${boundPorts.getBinding(this.port)}${
@@ -107,9 +107,36 @@ export class HttpWaitStrategy extends AbstractWaitStrategy {
       this.startupTimeout
     );
 
+    await Promise.race([this.waitContainerNotExited(container), healthCheckPromise]);
+
     log.debug(`HTTP wait strategy complete`, { containerId: container.id });
   }
 
+  private async waitContainerNotExited(container: Dockerode.Container) {
+    const exitStatus = 'exited';
+    const timeout = this.startupTimeout + 1000; // added 1 sec to avoid race condition
+    const status = await new IntervalRetry<string, null>(500).retryUntil(
+      async () => (await container.inspect()).State.Status,
+      (status) => status === exitStatus,
+      () => null,
+      timeout
+    );
+
+    if (status === null) {
+      return;
+    }
+
+    if (status === exitStatus) {
+      const tail = 50;
+      const lastLogs = (await container.logs({ tail, stdout: true, stderr: true })).toString();
+      const message = `container exited, last ${tail} logs: ${lastLogs}`;
+
+      log.error(message, { containerId: container.id });
+
+      if (this.shutdownOnExit) throw new Error(message);
+    }
+  }
+
   private getAgent(): Agent | undefined {
     if (this._allowInsecure) {
       return new https.Agent({