elastic arrange with config

Author: alemarcha

src/Contexts/Shared/infrastructure/persistence/elasticsearch/ElasticRepository.ts

@@ -16,7 +16,7 @@ export abstract class ElasticRepository<T extends AggregateRoot> {
     this.criteriaConverter = new ElasticCriteriaConverter();
   }
 
-  protected moduleName(): string {
+  protected indexName(): string {
     return this.config.indexName;
   }
 
@@ -41,7 +41,7 @@ export abstract class ElasticRepository<T extends AggregateRoot> {
 
     try {
       const response = await client.search({
-        index: this.moduleName(),
+        index: this.indexName(),
         body: body.build()
       });
 
@@ -62,6 +62,6 @@ export abstract class ElasticRepository<T extends AggregateRoot> {
     const client = await this.client();
     const document = { ...aggregateRoot.toPrimitives() };
 
-    await client.index({ index: this.moduleName(), body: document, refresh: 'wait_for' }); // wait_for wait for a refresh to make this operation visible to search
+    await client.index({ index: this.indexName(), body: document, refresh: 'wait_for' }); // wait_for wait for a refresh to make this operation visible to search
   }
 }

src/apps/backoffice/backend/dependency-injection/application_test.yaml

@@ -4,7 +4,7 @@ imports:
 services:
   Backoffice.Backend.EnvironmentArranger:
     class: ../../../../../tests/Contexts/Shared/infrastructure/elastic/ElasticEnvironmentArranger
-    arguments: ['@Shared.ElasticConnectionManager']
+    arguments: ['@Shared.ElasticConnectionManager', '@Backoffice.courses.ElasticConfig']
 
   Shared.EventBus:
     class: ../../../../Contexts/Shared/infrastructure/EventBus/InMemory/InMemorySyncEventBus

tests/Contexts/Shared/infrastructure/elastic/ElasticEnvironmentArranger.ts

@@ -1,20 +1,21 @@
 import { Client as ElasticClient } from '@elastic/elasticsearch';
+import ElasticConfig from '../../../../../src/Contexts/Shared/infrastructure/persistence/elasticsearch/ElasticConfig';
 import { EnvironmentArranger } from '../arranger/EnvironmentArranger';
 
 export class ElasticEnvironmentArranger extends EnvironmentArranger {
-  constructor(private _client: Promise<ElasticClient>) {
+  constructor(private _client: Promise<ElasticClient>, private config: ElasticConfig) {
     super();
   }
 
   public async arrange(): Promise<void> {
-    await this.dropAllIndex();
+    await this.dropIndex(this.config.indexName);
   }
 
-  protected async dropAllIndex(): Promise<void> {
+  protected async dropIndex(indexName: string): Promise<void> {
     const client = await this.client();
 
     await client.deleteByQuery({
-      index: 'backofficecourses-test',
+      index: indexName,
       body: {
         query: {
           match_all: {}