Create an Elastic Search extension

__tests__/elasticsearch/elastic-search-extension.t.ts

@@ -0,0 +1,57 @@
+import {afterEach, describe, expect, it} from "@jest/globals";
+import {ElasticSearchExtension} from "../../src";
+
+describe("ElasticSearchExtension", () => {
+  afterEach(async () => {
+    if (global.ELASTIC_SEARCH_CONTAINER) {
+      await global.ELASTIC_SEARCH_CONTAINER.stop();
+      global.ELASTIC_SEARCH_CONTAINER = undefined;
+    }
+  });
+
+  describe("startElasticSearchContainer", () => {
+    it("should start the elastic search container", async () => {
+      await ElasticSearchExtension.startElasticSearchContainer();
+
+      expect(global.ELASTIC_SEARCH_CONTAINER).toBeDefined();
+
+      await global.ELASTIC_SEARCH_CONTAINER.stop();
+    }, 60_000);
+  });
+
+  describe("stopElasticSearchContainer", () => {
+    it("should stop the elastic search container", async () => {
+      await ElasticSearchExtension.startElasticSearchContainer();
+      await ElasticSearchExtension.stopElasticSearchContainer();
+
+      expect(global.ELASTIC_SEARCH_CONTAINER).toBeUndefined();
+    }, 60_000);
+
+    it("should throw error when container is not previously started", () => {
+      expect(
+        ElasticSearchExtension.stopElasticSearchContainer(),
+      ).rejects.toEqual(
+        Error(
+          "IllegalStateException: Elastic Search container has not been previously started",
+        ),
+      );
+
+      expect(global.ELASTIC_SEARCH_CONTAINER).toBeUndefined();
+    });
+  });
+
+  describe("getElasticSearchUrl", () => {
+    it("should return the base url for the started container", async () => {
+      await ElasticSearchExtension.startElasticSearchContainer();
+
+      const url = ElasticSearchExtension.getElasticSearchUrl();
+      expect(url).toContain("http://localhost:");
+    }, 60_000);
+
+    it("should throw error when container is not previously started", () => {
+      expect(() => ElasticSearchExtension.getElasticSearchUrl()).toThrow(
+        "IllegalStateException: Elastic Search container has not been previously started",
+      );
+    });
+  });
+});

package.json

@@ -24,6 +24,7 @@
   "dependencies": {
     "@jest/globals": "29.6.2",
     "@kiwiproject/kiwi-js": "0.8.0",
+    "@testcontainers/elasticsearch": "10.2.1",
     "@testcontainers/postgresql": "10.2.1",
     "jest": "29.6.2",
     "mongodb": "5.7.0",

src/elasticsearch/elastic-search-extension.ts

@@ -0,0 +1,34 @@
+import {KiwiPreconditions} from "@kiwiproject/kiwi-js";
+import {ElasticsearchContainer} from "@testcontainers/elasticsearch";
+
+async function startElasticSearchContainer() {
+  global.ELASTIC_SEARCH_CONTAINER = await new ElasticsearchContainer(
+    "elasticsearch:8.6.1",
+  )
+    .withEnvironment({ "xpack.security.enabled": "false" })
+    .start();
+}
+
+async function stopElasticSearchContainer() {
+  KiwiPreconditions.checkState(
+    global.ELASTIC_SEARCH_CONTAINER !== undefined,
+    "Elastic Search container has not been previously started",
+  );
+  await global.ELASTIC_SEARCH_CONTAINER.stop();
+  global.ELASTIC_SEARCH_CONTAINER = undefined;
+}
+
+function getElasticSearchUrl(): string {
+  KiwiPreconditions.checkState(
+    global.ELASTIC_SEARCH_CONTAINER !== undefined,
+    "Elastic Search container has not been previously started",
+  );
+
+  return global.ELASTIC_SEARCH_CONTAINER.getHttpUrl();
+}
+
+export const ElasticSearchExtension = {
+  startElasticSearchContainer,
+  stopElasticSearchContainer,
+  getElasticSearchUrl,
+};

src/index.ts

@@ -1,2 +1,3 @@
 export { MongoExtension } from "./mongo/mongo-extension";
 export { PostgresExtension } from "./postgres/postgres-extension";
+export { ElasticSearchExtension } from "./elasticsearch/elastic-search-extension";