Skip to content

Commit 33086e4

Browse files
committed
fix(api-elasticsearch): get es client
1 parent 966e0cb commit 33086e4

File tree

2 files changed

+9
-9
lines changed

2 files changed

+9
-9
lines changed

packages/api-elasticsearch/__tests__/utils/waitUntilHealthy.test.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
import { describe, expect, it, vi } from "vitest";
2-
import { createWaitUntilHealthy } from "~/utils/waitUntilHealthy";
3-
import { createElasticsearchClient } from "@webiny/project-utils/testing/elasticsearch/createClient";
4-
import { ElasticsearchCatClusterHealthStatus } from "~/operations/types";
5-
import { UnhealthyClusterError } from "~/utils/waitUntilHealthy/UnhealthyClusterError";
6-
import { WaitingHealthyClusterAbortedError } from "~/utils/waitUntilHealthy/WaitingHealthyClusterAbortedError";
2+
import { createWaitUntilHealthy } from "~/utils/waitUntilHealthy/index.js";
3+
import { createElasticsearchClient } from "@webiny/project-utils/testing/elasticsearch/createClient.js";
4+
import { ElasticsearchCatClusterHealthStatus } from "~/operations/types.js";
5+
import { UnhealthyClusterError } from "~/utils/waitUntilHealthy/UnhealthyClusterError.js";
6+
import { WaitingHealthyClusterAbortedError } from "~/utils/waitUntilHealthy/WaitingHealthyClusterAbortedError.js";
77

88
describe("wait until healthy", () => {
99
const client = createElasticsearchClient();

packages/project-utils/testing/elasticsearch/getElasticsearchClient.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -49,11 +49,11 @@ interface OnBeforeEach {
4949
}
5050

5151
export class ElasticsearchClientConfig {
52-
public elasticsearchClient: ElasticsearchClient;
53-
public plugins: PluginCollection;
52+
public readonly elasticsearchClient: ElasticsearchClient;
53+
public readonly plugins: PluginCollection;
5454
private onBeforeEach: { name: string; cb: OnBeforeEach }[] = [];
5555

56-
constructor(prefix: string) {
56+
public constructor(prefix: string) {
5757
if (prefix !== "") {
5858
// Prefix will only be handled once, for the first processed storage operations.
5959
const indexPrefix = getElasticsearchIndexPrefix();
@@ -65,7 +65,7 @@ export class ElasticsearchClientConfig {
6565
logger.debug(`ES index prefix = "%s"`, getElasticsearchIndexPrefix());
6666

6767
const documentClient = getDocumentClient();
68-
this.elasticsearchClient = createElasticsearchClient() as ElasticsearchClient;
68+
this.elasticsearchClient = createElasticsearchClient();
6969
const elasticsearchClientContext = elasticsearchClientContextPlugin(
7070
this.elasticsearchClient
7171
);

0 commit comments

Comments
 (0)