Add additional reaper tests

Author: cristianrgreco

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

@@ -1,4 +1,5 @@
 import { ContainerRuntimeClient, getContainerRuntimeClient } from "../container-runtime";
+import { RandomUniquePortGenerator } from "../utils/port-generator";
 
 describe("Reaper", { timeout: 120_000 }, () => {
   let client: ContainerRuntimeClient;
@@ -12,6 +13,42 @@ describe("Reaper", { timeout: 120_000 }, () => {
     client = await getContainerRuntimeClient();
   });
 
+  it("should create disabled reaper when TESTCONTAINERS_RYUK_DISABLED=true", async () => {
+    vitest.stubEnv("TESTCONTAINERS_RYUK_DISABLED", "true");
+
+    vi.spyOn(client.container, "list").mockResolvedValue([]);
+    const reaper = await getReaper();
+
+    // DisabledReaper has an empty containerId
+    expect(reaper.containerId).toBe("");
+
+    // Should not throw exceptions when methods are called
+    expect(() => reaper.addSession("test-session")).not.toThrow();
+    expect(() => reaper.addComposeProject("test-project")).not.toThrow();
+  });
+
+  it("should use custom port when TESTCONTAINERS_RYUK_PORT is set", async () => {
+    const customPort = (await new RandomUniquePortGenerator().generatePort()).toString();
+    vitest.stubEnv("TESTCONTAINERS_RYUK_PORT", customPort);
+
+    vi.spyOn(client.container, "list").mockResolvedValue([]);
+    const reaper = await getReaper();
+
+    const reaperContainer = client.container.getById(reaper.containerId);
+    const ports = (await reaperContainer.inspect()).HostConfig.PortBindings;
+    expect(ports["8080"][0].HostPort).toBe(customPort);
+  });
+
+  it("should reuse existing reaper container if one is already running", async () => {
+    const reaper = await getReaper();
+    const reaperContainerInfo = (await client.container.list()).filter((c) => c.Id === reaper.containerId)[0];
+    vi.spyOn(client.container, "list").mockResolvedValue([reaperContainerInfo]);
+
+    const reaper2 = await getReaper();
+
+    expect(reaper2.containerId).toBe(reaper.containerId);
+  });
+
   it("should create Reaper container without RYUK_VERBOSE env var by default", async () => {
     vi.spyOn(client.container, "list").mockResolvedValue([]);
     const reaper = await getReaper();