added searchAllInElastic into ElasticRepository

Author: alemarcha

src/Contexts/Backoffice/Courses/infrastructure/persistence/ElasticBackofficeCourseRepository.ts

@@ -2,8 +2,6 @@ import { ElasticRepository } from '../../../../Shared/infrastructure/persistence
 import { BackofficeCourse } from '../../domain/BackofficeCourse';
 import { BackofficeCourseRepository } from '../../domain/BackofficeCourseRepository';
 
-type ElasticBackofficeCourseDocument = { _source: { id: string; duration: string; name: string } };
-
 export class ElasticBackofficeCourseRepository
   extends ElasticRepository<BackofficeCourse>
   implements BackofficeCourseRepository {
@@ -12,23 +10,10 @@ export class ElasticBackofficeCourseRepository
   }
 
   async searchAll(): Promise<BackofficeCourse[]> {
-    const client = await this.client();
-
-    const response = await client.search({
-      index: this.moduleName(),
-      body: {
-        query: {
-          match_all: {}
-        }
-      }
-    });
-
-    return response.body.hits.hits.map((hit: ElasticBackofficeCourseDocument) =>
-      BackofficeCourse.fromPrimitives({ ...hit._source })
-    );
+    return this.searchAllInElastic(BackofficeCourse.fromPrimitives);
   }
 
   async save(course: BackofficeCourse): Promise<void> {
-    return this.persist(this.moduleName(), course);
+    return this.persist(course);
   }
 }

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

@@ -1,6 +1,8 @@
 import { Client as ElasticClient } from '@elastic/elasticsearch';
 import { AggregateRoot } from '../../../domain/AggregateRoot';
 
+type Hit = { _source: any };
+
 export abstract class ElasticRepository<T extends AggregateRoot> {
   constructor(private _client: Promise<ElasticClient>) {}
 
@@ -10,10 +12,25 @@ export abstract class ElasticRepository<T extends AggregateRoot> {
     return this._client;
   }
 
-  protected async persist(index: string, aggregateRoot: T): Promise<void> {
-    const document = { ...aggregateRoot.toPrimitives() };
+  protected async searchAllInElastic(unserializer: (data: any) => T): Promise<T[]> {
+    const client = await this.client();
+
+    const response = await client.search({
+      index: this.moduleName(),
+      body: {
+        query: {
+          match_all: {}
+        }
+      }
+    });
+
+    return response.body.hits.hits.map((hit: Hit) => unserializer({ ...hit._source }));
+  }
+
+  protected async persist(aggregateRoot: T): Promise<void> {
     const client = await this.client();
+    const document = { ...aggregateRoot.toPrimitives() };
 
-    await client.index({ index: index, body: document, refresh: 'wait_for' }); // wait_for wait for a refresh to make this operation visible to search
+    await client.index({ index: this.moduleName(), body: document, refresh: 'wait_for' }); // wait_for wait for a refresh to make this operation visible to search
   }
 }