Nestjs Elasticsearch Module

[!NOTE]
This repository is a Work In Progress, driven by the motive.

Motive

Due to Production Experience when working with Elasticsearch leaded to maintenance issues when extensively used searches, filters and aggregations (especially aggregations).

1. Current Elasticsearch Nestjs Modules does not provide auto-complete for queries
2. Since Elasticsearch indexes are schema-less we got no proper feedback about what we should expect on the index
3. Elasticsearch response forgets about types of aggregations

Adding package to your Nestjs project

1. Install package using yarn or npm

1$ yarn add @codemaskjs/nestjs-elasticsearch
2// or
3$ npm -i @codemaskjs/nestjs-elasticsearch

2. Import module

1import { ElasticsearchModule } from '@codemaskjs/nestjs-elasticsearch'
2
3@Module({
4    imports: [
5        ElasticsearchModule.register({
6            node: 'http://localhost:9200'
7        })
8    ]
9})
10class AppModule {}

3. (optional) Registering Index with Document

1import { RegisterIndex } from '@codemaskjs/nestjs-elasticsearch'
2
3@RegisterIndex('examples')
4export class ExampleDocument {
5    readonly id: string
6    readonly test?: string
7}

1import { Injectable } from '@nestjs/common'
2import { Index } from '@codemaskjs/nestjs-elasticsearch'
3import { ExampleDocument } from './example.document'
4
5@Injectable()
6export class ExampleService {
7    @InjectIndex(ExampleDocument)
8    private readonly exampleIndex: Index<ExampleDocument>
9
10    getExampleDocuments() {
11        return this.exampleIndex.search()
12    }
13}

1import { ElasticsearchModule } from '@codemaskjs/nestjs-elasticsearch'
2import { ExampleDocument } from './example.document'
3
4@Module({
5    imports: [
6        providers: [ExampleService],
7        ElasticsearchModule.register({
8            node: 'http://localhost:9200'
9        }),
10        ElasticsearchModule.forFeature([
11            ExampleDocument
12        ])
13    ]
14})
15class AppModule {}

Future actions

1. Add case_insensitive option to term search
2. Filter undefined/null values from request body
3. Add field to aggregations body so that it can return more than default 10 results
4. Add and <search_after> fields to request type and field to response type to enable pagination
5. Add e2e tests setup for features scenario tests
6. Add extraction of aggregations on response
7. Add healthcheck from ElasticsearchService
8. Add checkDocumentIntegrity with the connection on the source on runtime
9. Add optional script to sum, avg, max aggregation
10. Add order field to terms aggregation