nestjs-elasticsearch-example-3

elasticsearch.module.ts

import { Module, OnModuleInit } from '@nestjs/common';
import { ElasticsearchModule as BaseElasticsearchModule, ElasticsearchService } from '@nestjs/elasticsearch';
import { v4 as uuid }from 'uuid';

@Module({
    imports: [
        BaseElasticsearchModule.register({
            node: 'http://localhost:9200',
            generateRequestId: () => uuid(),
        }),
    ],
    exports: [
        BaseElasticsearchModule,
    ],
})
export class ElasticsearchModule implements OnModuleInit {

    constructor(
        private readonly client: ElasticsearchService,
    ) {}

    public onModuleInit(): any {
        this.client.on('request', (err, result) => {
            const { id } = result.meta.request;
            console.log('ES Request ID', id);
        });

        this.client.on('response', (err, result) => {
            const { id } = result.meta.request;
            console.log('ES Response ID', id);
        });
    }
}