Ensure we do not connect to reapers created in test

Author: cristianrgreco

packages/testcontainers/src/reaper/reaper.test.ts

@@ -8,6 +8,7 @@ describe("Reaper", { timeout: 120_000 }, () => {
 
   beforeEach(async () => {
     vi.resetModules();
+    vi.stubEnv("TESTCONTAINERS_RYUK_TEST_LABEL", "true");
     client = await getContainerRuntimeClient();
   });
 

packages/testcontainers/src/reaper/reaper.ts

@@ -48,7 +48,10 @@ export async function getReaper(client: ContainerRuntimeClient): Promise<Reaper>
 async function findReaperContainer(client: ContainerRuntimeClient): Promise<ContainerInfo | undefined> {
   const containers = await client.container.list();
   return containers.find(
-    (container) => container.State === "running" && container.Labels[LABEL_TESTCONTAINERS_RYUK] === "true"
+    (container) =>
+      container.State === "running" &&
+      container.Labels[LABEL_TESTCONTAINERS_RYUK] === "true" &&
+      container.Labels["TESTCONTAINERS_RYUK_TEST_LABEL"] !== "true"
   );
 }
 
@@ -81,9 +84,12 @@ async function createNewReaper(sessionId: string, remoteSocketPath: string): Pro
   if (process.env["TESTCONTAINERS_RYUK_VERBOSE"]) {
     container.withEnvironment({ RYUK_VERBOSE: process.env["TESTCONTAINERS_RYUK_VERBOSE"] });
   }
-  if (process.env.TESTCONTAINERS_RYUK_PRIVILEGED === "true") {
+  if (process.env["TESTCONTAINERS_RYUK_PRIVILEGED"] === "true") {
     container.withPrivilegedMode();
   }
+  if (process.env["TESTCONTAINERS_RYUK_TEST_LABEL"] === "true") {
+    container.withLabels({ TESTCONTAINERS_RYUK_TEST_LABEL: "true" });
+  }
 
   const startedContainer = await container.start();