|
|
@@ -26,9 +26,9 @@ import { aggregatePipelineToIndex } from './aggregate-to-index';
|
|
|
import type { AggregatedPage, BulkWriteBody, BulkWriteCommand } from './bulk-write';
|
|
|
import {
|
|
|
getClient,
|
|
|
- isES9ClientDelegetor,
|
|
|
- isES7ClientDelegetor,
|
|
|
- isES8ClientDelegetor,
|
|
|
+ isES7ClientDelegator,
|
|
|
+ isES8ClientDelegator,
|
|
|
+ isES9ClientDelegator,
|
|
|
type ElasticsearchClientDelegator,
|
|
|
} from './elasticsearch-client-delegator';
|
|
|
|
|
|
@@ -322,7 +322,7 @@ class ElasticsearchDelegator implements SearchDelegator<Data, ESTermsKey, ESQuer
|
|
|
|
|
|
async createIndex(index: string) {
|
|
|
// TODO: https://redmine.weseek.co.jp/issues/168446
|
|
|
- if (isES7ClientDelegetor(this.client)) {
|
|
|
+ if (isES7ClientDelegator(this.client)) {
|
|
|
const { mappings } = await import('^/resource/search/mappings-es7');
|
|
|
return this.client.indices.create({
|
|
|
index,
|
|
|
@@ -332,7 +332,7 @@ class ElasticsearchDelegator implements SearchDelegator<Data, ESTermsKey, ESQuer
|
|
|
});
|
|
|
}
|
|
|
|
|
|
- if (isES8ClientDelegetor(this.client)) {
|
|
|
+ if (isES8ClientDelegator(this.client)) {
|
|
|
const { mappings } = await import('^/resource/search/mappings-es8');
|
|
|
return this.client.indices.create({
|
|
|
index,
|
|
|
@@ -340,7 +340,7 @@ class ElasticsearchDelegator implements SearchDelegator<Data, ESTermsKey, ESQuer
|
|
|
});
|
|
|
}
|
|
|
|
|
|
- if (isES9ClientDelegetor(this.client)) {
|
|
|
+ if (isES9ClientDelegator(this.client)) {
|
|
|
const { mappings } = process.env.CI == null
|
|
|
? await import('^/resource/search/mappings-es9')
|
|
|
: await import('^/resource/search/mappings-es9-for-ci');
|