added bodybuilder for elastic search criteria

Author: alemarcha

package-lock.json

@@ -44,6 +44,7 @@
     "@types/uuid": "^8.3.0",
     "@types/uuid-validate": "0.0.1",
     "body-parser": "^1.19.0",
+    "bodybuilder": "^2.3.0",
     "bson": "^4.2.0",
     "compression": "^1.7.4",
     "connect-flash": "^0.1.1",

package.json

@@ -19,6 +19,6 @@ export class ElasticBackofficeCourseRepository
   }
 
   matching(criteria: Criteria): Promise<BackofficeCourse[]> {
-    throw new Error('Method not implemented.');
+    return this.searchByCriteria(criteria, BackofficeCourse.fromPrimitives);
   }
 }

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

@@ -17,6 +17,7 @@ export class Order {
 
     return new Order(new OrderBy(orderBy), OrderType.fromValue(orderType || OrderTypes.ASC));
   }
+
   static none(): Order {
     return new Order(new OrderBy(''), new OrderType(OrderTypes.NONE));
   }

src/Contexts/Shared/domain/criteria/Order.ts

@@ -2,6 +2,8 @@ import { Client as ElasticClient } from '@elastic/elasticsearch';
 import { ResponseError } from '@elastic/elasticsearch/lib/errors';
 import httpStatus from 'http-status';
 import { AggregateRoot } from '../../../domain/AggregateRoot';
+import { Criteria } from '../../../domain/criteria/Criteria';
+import bodybuilder, { Bodybuilder } from 'bodybuilder';
 
 type Hit = { _source: any };
 
@@ -15,17 +17,27 @@ export abstract class ElasticRepository<T extends AggregateRoot> {
   }
 
   protected async searchAllInElastic(unserializer: (data: any) => T): Promise<T[]> {
+    const body = bodybuilder().query('match_all');
+    body.build();
+    return this.searchInElasticWithSourceBuilder(unserializer, body);
+  }
+
+  protected async searchByCriteria(criteria: Criteria, unserializer: (data: any) => T): Promise<T[]> {
+    // TODO elastic search converter from Criteria
+    const body = bodybuilder().query('match_all');
+    body.build();
+    return this.searchInElasticWithSourceBuilder(unserializer, body);
+  }
+
+  private async searchInElasticWithSourceBuilder(unserializer: (data: any) => T, body: Bodybuilder): Promise<T[]> {
     const client = await this.client();
 
     try {
       const response = await client.search({
         index: this.moduleName(),
-        body: {
-          query: {
-            match_all: {}
-          }
-        }
+        body
       });
+
       return response.body.hits.hits.map((hit: Hit) => unserializer({ ...hit._source }));
     } catch (e) {
       if (this.isNotFoundError(e)) {