Add Redis module (#642)

Author: djakielski

.github/workflows/test.yml

@@ -90,6 +90,7 @@ jobs:
           - nats
           - neo4j
           - postgresql
+          - redis
           - selenium
     uses: ./.github/workflows/test-template.yml
     with:

docs/modules/redis.md

@@ -0,0 +1,31 @@
+# Redis Module
+
+[Redis](https://redis.io/) The open source, in-memory data store used by millions of developers as a database, cache, streaming engine, and message broker.
+
+## Install
+
+```bash
+npm install @testcontainers/redis --save-dev
+```
+
+## Examples
+
+<!--codeinclude-->
+[Start container:](../../packages/modules/redis/src/redis-container.test.ts) inside_block:startContainer
+<!--/codeinclude-->
+
+<!--codeinclude-->
+[Connect redis client to container:](../../packages/modules/redis/src/redis-container.test.ts) inside_block:simpleConnect
+<!--/codeinclude-->
+
+<!--codeinclude-->
+[Start container with password authentication:](../../packages/modules/redis/src/redis-container.test.ts) inside_block:startWithCredentials
+<!--/codeinclude-->
+
+<!--codeinclude-->
+[Define volume for persistent/predefined data:](../../packages/modules/redis/src/redis-container.test.ts) inside_block:persistentData
+<!--/codeinclude-->
+
+<!--codeinclude-->
+[Execute a command inside the container:](../../packages/modules/redis/src/redis-container.test.ts) inside_block:executeCommand
+<!--/codeinclude-->

mkdocs.yml

@@ -52,4 +52,5 @@ nav:
       - Neo4J: modules/neo4j.md
       - PostgreSQL: modules/postgresql.md
       - Selenium: modules/selenium.md
+      - Redis: modules/redis.md
   - Configuration: configuration.md

package-lock.json

@@ -0,0 +1,11 @@
+import type { Config } from "jest";
+import * as path from "path";
+
+const config: Config = {
+  preset: "ts-jest",
+  moduleNameMapper: {
+    "^testcontainers$": path.resolve(__dirname, "../../testcontainers/src"),
+  },
+};
+
+export default config;

packages/modules/redis/jest.config.ts

@@ -0,0 +1,38 @@
+{
+  "name": "@testcontainers/redis",
+  "version": "10.2.1",
+  "license": "MIT",
+  "keywords": [
+    "redis",
+    "testing",
+    "docker",
+    "testcontainers"
+  ],
+  "description": "Redis module for Testcontainers",
+  "homepage": "https://github.com/testcontainers/testcontainers-node#readme",
+  "repository": {
+    "type": "git",
+    "url": "https://github.com/testcontainers/testcontainers-node"
+  },
+  "bugs": {
+    "url": "https://github.com/testcontainers/testcontainers-node/issues"
+  },
+  "main": "build/index.js",
+  "files": [
+    "build"
+  ],
+  "publishConfig": {
+    "access": "public"
+  },
+  "scripts": {
+    "prepack": "shx cp ../../../README.md . && shx cp ../../../LICENSE .",
+    "build": "tsc --project tsconfig.build.json"
+  },
+  "devDependencies": {
+    "@types/redis": "^4.0.11",
+    "redis": "^4.6.7"
+  },
+  "dependencies": {
+    "testcontainers": "^10.2.1"
+  }
+}

packages/modules/redis/package.json

@@ -0,0 +1,4 @@
+#!/usr/bin/env bash
+set -e
+redis-cli $([[ -n "$1" ]] && echo "-a $1") < "/tmp/import.redis"
+echo "Imported"

packages/modules/redis/src/import.sh

@@ -0,0 +1 @@
+export { RedisContainer, StartedRedisContainer } from "./redis-container";

packages/modules/redis/src/index.ts

@@ -0,0 +1,2 @@
+SET "user:001" '{"first_name":"John","last_name":"Doe","dob":"12-JUN-1970"}'
+SET "user:002" '{"first_name":"David","last_name":"Bloom","dob":"03-MAR-1981"}'

packages/modules/redis/src/initData.redis

@@ -0,0 +1,117 @@
+import { createClient } from "redis";
+import { RedisContainer, StartedRedisContainer } from "./redis-container";
+import * as os from "os";
+import * as path from "path";
+import * as fs from "fs";
+
+describe("RedisContainer", () => {
+  jest.setTimeout(240_000);
+
+  // startContainer {
+  it("should connect and execute set-get", async () => {
+    const container = await new RedisContainer().start();
+
+    const client = await connectTo(container);
+
+    await client.set("key", "val");
+    expect(await client.get("key")).toBe("val");
+
+    await client.disconnect();
+    await container.stop();
+  });
+  // }
+
+  it("should connect with password and execute set-get", async () => {
+    const container = await new RedisContainer().withPassword("test").start();
+
+    const client = await connectTo(container);
+
+    await client.set("key", "val");
+    expect(await client.get("key")).toBe("val");
+
+    await client.disconnect();
+    await container.stop();
+  });
+
+  // persistentData {
+  it("should reconnect with volume and persistence data", async () => {
+    const sourcePath = fs.mkdtempSync(path.join(os.tmpdir(), "redis-"));
+    const container = await new RedisContainer().withPassword("test").withPersistence(sourcePath).start();
+    let client = await connectTo(container);
+
+    await client.set("key", "val");
+    await client.disconnect();
+    await container.restart();
+    client = await connectTo(container);
+    expect(await client.get("key")).toBe("val");
+
+    await client.disconnect();
+    await container.stop();
+    try {
+      fs.rmSync(sourcePath, { force: true, recursive: true });
+    } catch (e) {
+      //Ignore clean up, when have no access on fs.
+      console.log(e);
+    }
+  });
+  // }
+
+  // initial data import {
+  it("should load initial data and can read it", async () => {
+    const container = await new RedisContainer()
+      .withPassword("test")
+      .withInitialData(path.join(__dirname, "initData.redis"))
+      .start();
+    const client = await connectTo(container);
+    const user = {
+      first_name: "David",
+      last_name: "Bloom",
+      dob: "03-MAR-1981",
+    };
+    expect(await client.get("user:002")).toBe(JSON.stringify(user));
+
+    await client.disconnect();
+    await container.stop();
+  });
+  // }
+
+  // startWithCredentials {
+  it("should start with credentials and login", async () => {
+    const password = "testPassword";
+
+    // Test authentication
+    const container = await new RedisContainer().withPassword(password).start();
+    expect(container.getConnectionUrl()).toEqual(`redis://:${password}@${container.getHost()}:${container.getPort()}`);
+
+    const client = await connectTo(container);
+
+    await client.set("key", "val");
+    expect(await client.get("key")).toBe("val");
+
+    await client.disconnect();
+    await container.stop();
+  });
+  // }
+
+  // executeCommand {
+  it("should execute container cmd and return the result", async () => {
+    const container = await new RedisContainer().start();
+
+    const queryResult = await container.executeCliCmd("info", ["clients"]);
+    expect(queryResult).toEqual(expect.stringContaining("connected_clients:1"));
+
+    await container.stop();
+  });
+  // }
+
+  // simpleConnect {
+  async function connectTo(container: StartedRedisContainer) {
+    const client = createClient({
+      url: container.getConnectionUrl(),
+    });
+    await client.connect();
+    expect(client.isOpen).toBeTruthy();
+    return client;
+  }
+  // }
+});