wip

Author: alemarcha

docker-compose.yml

@@ -7,6 +7,8 @@ x-app-service: &default-app
     - MONGO_URL=mongodb://mongo:27017/dev
   depends_on:
     - mongo
+    - kibana
+    - elasticsearch
   volumes:
     - .:/code:delegated
     - node_modules:/code/node_modules:delegated
@@ -21,6 +23,12 @@ services:
     ports:
       - 3000:3000
 
+  backoffice-backend:
+    <<: *default-app
+    command: bash -c "npm run build && npm run start:backoffice:backend"
+    ports:
+      - 3002:3000
+
   backoffice-frontend:
     <<: *default-app
     command: bash -c "npm run build && npm run start:backoffice:frontend"
@@ -34,5 +42,34 @@ services:
     ports:
       - 27017:27017
 
+  elasticsearch:
+    image: docker.elastic.co/elasticsearch/elasticsearch:7.9.3
+    container_name: codely-elasticsearch
+    environment:
+      #   - cluster.name=codely-elasticsearch
+      - node.name=codely-elasticsearch
+      - discovery.type=single-node #Elasticsearch forms a single-node cluster
+      - bootstrap.memory_lock=true # might cause the JVM or shell session to exit if it tries to allocate more memory than is available!
+      - 'ES_JAVA_OPTS=-Xms512m -Xmx512m'
+    ulimits:
+      memlock:
+        soft: -1 # The memlock soft and hard values configures the range of memory that ElasticSearch will use. Setting this to –1 means unlimited.
+        hard: -1
+    volumes:
+      - esdata:/usr/share/elasticsearch/data
+    ports:
+      - '9200:9200'
+
+  kibana:
+    image: docker.elastic.co/kibana/kibana:7.8.1
+    container_name: codely-kibana
+    environment:
+      ELASTICSEARCH_URL: http://codely-elasticsearch:9200
+      ELASTICSEARCH_HOSTS: http://codely-elasticsearch:9200
+    ports:
+      - 5601:5601
+
 volumes:
   node_modules:
+  esdata:
+    driver: local

package-lock.json

@@ -31,6 +31,7 @@
     "cypress:run": "NODE_ENV=test ts-node tests/utils/cypress/run"
   },
   "dependencies": {
+    "@elastic/elasticsearch": "^7.9.1",
     "@types/bson": "^4.0.2",
     "@types/compression": "^1.7.0",
     "@types/convict": "^5.2.1",

package.json

@@ -0,0 +1,53 @@
+import { ElasticRepository } from '../../Shared/infrastructure/persistence/elasticsearch/ElasticRepository';
+import { BackofficeCourse } from '../domain/BackofficeCourse';
+import { BackofficeCourseRepository } from '../domain/BackofficeCourseRepository';
+import { Uuid } from '../../Shared/domain/value-object/Uuid';
+import { BackofficeCourseName } from '../domain/BackofficeCourseName';
+import { BackofficeCourseId } from '../domain/BackofficeCourseId';
+import { BackofficeCourseDuration } from '../domain/BackofficeCourseDuration';
+
+type ElasticBackofficeCourseDocument = { _source: { id: string; duration: string; name: string } };
+
+export class ElasticBackofficeCourseRepository
+  extends ElasticRepository<BackofficeCourse>
+  implements BackofficeCourseRepository {
+  protected moduleName(): string {
+    return 'backofficecourses';
+  }
+
+  async searchAll(): Promise<BackofficeCourse[]> {
+    const client = await this.client();
+
+    const response = await client.search({
+      index: this.moduleName(),
+      body: {
+        query: {
+          match_all: {}
+        }
+      }
+    });
+
+    // console.log(response.body.hits.hits);
+
+    return response.body.hits.hits.map((hit: ElasticBackofficeCourseDocument) =>
+      BackofficeCourse.fromPrimitives({ ...hit._source })
+    );
+  }
+
+  async save(course: BackofficeCourse) {
+    return this.persist(this.moduleName(), course);
+  }
+
+  async delete() {
+    const client = await this.client();
+
+    return client.deleteByQuery({
+      index: this.moduleName(),
+      body: {
+        query: {
+          match_all: {}
+        }
+      }
+    });
+  }
+}

src/Contexts/Backoffice/infrastructure/ElasticBackofficeCourseRepository.ts

@@ -0,0 +1,33 @@
+import { Client as ElasticClient } from '@elastic/elasticsearch';
+import config from '../../../../../apps/backoffice/backend/config/config';
+import { Nullable } from '../../../domain/Nullable';
+
+export class ElasticClientFactory {
+  private static clients: { [key: string]: ElasticClient } = {};
+
+  static async createClient(contextName: string): Promise<ElasticClient> {
+    let client = ElasticClientFactory.getClient(contextName);
+
+    if (!client) {
+      client = await ElasticClientFactory.createAndConnectClient();
+
+      ElasticClientFactory.registerClient(client, contextName);
+    }
+
+    return client;
+  }
+
+  private static getClient(contextName: string): Nullable<ElasticClient> {
+    return ElasticClientFactory.clients[contextName];
+  }
+
+  private static async createAndConnectClient(): Promise<ElasticClient> {
+    const client = new ElasticClient({ node: config.get('elastic.url') });
+
+    return client;
+  }
+
+  private static registerClient(client: ElasticClient, contextName: string): void {
+    ElasticClientFactory.clients[contextName] = client;
+  }
+}

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

@@ -0,0 +1,19 @@
+import { Client as ElasticClient } from '@elastic/elasticsearch';
+import { AggregateRoot } from '../../../../Mooc/Courses/domain/AggregateRoot';
+
+export abstract class ElasticRepository<T extends AggregateRoot> {
+  constructor(private _client: Promise<ElasticClient>) {}
+
+  protected abstract moduleName(): string;
+
+  protected client(): Promise<ElasticClient> {
+    return this._client;
+  }
+
+  protected async persist(index: string, aggregateRoot: T): Promise<void> {
+    const document = { ...aggregateRoot.toPrimitives() };
+
+    console.log('persist', document);
+    (await this.client()).index({ index: index, body: document });
+  }
+}

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

@@ -14,6 +14,14 @@ const convictConfig = convict({
       env: 'MONGO_URL',
       default: 'mongodb://localhost:27017/backoffice-backend-dev'
     }
+  },
+  elastic: {
+    url: {
+      doc: 'The Elastic connection URL',
+      format: String,
+      env: 'ELASTIC_URL',
+      default: 'http://localhost:9200'
+    }
   }
 });
 

src/apps/backoffice/backend/config/config.ts

@@ -1,15 +1,18 @@
 services:
-    Backoffice.Backend.courses.BackofficeCourseRepository:
-        class: ../../../../../../Contexts/Backoffice/infrastructure/MongoBackofficeCourseRepository
-        arguments: ['@Shared.ConnectionManager']
+  Backoffice.Backend.courses.BackofficeCourseRepository:
+    class: ../../../../../../Contexts/Backoffice/infrastructure/MongoBackofficeCourseRepository
+    arguments: ['@Shared.ConnectionManager']
 
-    Backoffice.Backend.courses.CoursesFinder:
-        class: ../../../../../../Contexts/Backoffice/application/SearchAll/CoursesFinder
-        arguments: ["@Backoffice.Backend.courses.BackofficeCourseRepository"]
-        
-    Backoffice.Backend.courses.SearchAllCoursesQueryHandler:
-        class: ../../../../../../Contexts/Backoffice/application/SearchAll/SearchAllCoursesQueryHandler
-        arguments: ["@Backoffice.Backend.courses.CoursesFinder"]
-        tags:
-            - { name: 'queryHandler' }
+  Backoffice.Backend.courses.BackofficeCourseRepository2:
+    class: ../../../../../../Contexts/Backoffice/infrastructure/ElasticBackofficeCourseRepository
+    arguments: ['@Shared.ConnectionManagerElastic']
 
+  Backoffice.Backend.courses.CoursesFinder:
+    class: ../../../../../../Contexts/Backoffice/application/SearchAll/CoursesFinder
+    arguments: ['@Backoffice.Backend.courses.BackofficeCourseRepository2']
+
+  Backoffice.Backend.courses.SearchAllCoursesQueryHandler:
+    class: ../../../../../../Contexts/Backoffice/application/SearchAll/SearchAllCoursesQueryHandler
+    arguments: ['@Backoffice.Backend.courses.CoursesFinder']
+    tags:
+      - { name: 'queryHandler' }

src/apps/backoffice/backend/config/dependency-injection/Courses/application.yaml

@@ -1,11 +1,17 @@
 services:
   Shared.Logger:
-    class:  ../../../../../../Contexts/Shared/infrastructure/WinstonLogger
+    class: ../../../../../../Contexts/Shared/infrastructure/WinstonLogger
     arguments: []
 
   Shared.ConnectionManager:
     factory:
-      class:  ../../../../../../Contexts/Shared/infrastructure/persistence/mongo/MongoClientFactory
+      class: ../../../../../../Contexts/Shared/infrastructure/persistence/mongo/MongoClientFactory
+      method: 'createClient'
+      arguments: ['mooc']
+
+  Shared.ConnectionManagerElastic:
+    factory:
+      class: ../../../../../../Contexts/Shared/infrastructure/persistence/elasticsearch/ElasticClientFactory
       method: 'createClient'
       arguments: ['mooc']
 
@@ -15,4 +21,4 @@ services:
 
   Shared.QueryBus:
     class: ../../../../../../Contexts/Shared/infrastructure/QueryBus/InMemoryQueryBus
-    arguments: ['@Shared.QueryHandlersInformation']
+    arguments: ['@Shared.QueryHandlersInformation']

src/apps/backoffice/backend/config/dependency-injection/Shared/application.yaml

@@ -0,0 +1,27 @@
+import container from '../../../../src/apps/backoffice/backend/config/dependency-injection';
+import { ElasticBackofficeCourseRepository } from '../../../../src/Contexts/Backoffice/infrastructure/ElasticBackofficeCourseRepository';
+import { ElasticClientFactory } from '../../../../src/Contexts/Shared/infrastructure/persistence/elasticsearch/ElasticClientFactory';
+import { EnvironmentArranger } from '../../Shared/infrastructure/arranger/EnvironmentArranger';
+import { BackofficeCourseMother } from '../application/domain/BackofficeCourseMother';
+
+const client = ElasticClientFactory.createClient('test');
+const repository: ElasticBackofficeCourseRepository = new ElasticBackofficeCourseRepository(client);
+const environmentArranger: Promise<EnvironmentArranger> = container.get('Backoffice.Backend.EnvironmentArranger');
+
+beforeEach(async () => {
+  await repository.delete();
+});
+
+afterAll(async () => {
+  //   await repository.delete();
+});
+
+describe('Search all courses', () => {
+  it('should return the existing courses', async () => {
+    const courses = [BackofficeCourseMother.random(), BackofficeCourseMother.random()];
+    await Promise.all(courses.map(course => repository.save(course)));
+    const expectedCourses = await repository.searchAll();
+    expect(courses.length).toEqual(expectedCourses.length);
+    expect(courses.sort()).toEqual(expectedCourses.sort());
+  });
+});