nestjs-elasticsearch-example-2

app.controller.ts

import { Controller, Get } from '@nestjs/common';

import { AppService } from './app.service';

@Controller()
export class AppController {

    constructor(
        private readonly appService: AppService,
    ) {}

    @Get('/companies')
    getCompanies(): Promise<any[]> {
        return this.appService.getCompanies();
    }
}

app.module.ts

import { Module } from '@nestjs/common';

import { AppController } from './app.controller';
import { AppService } from './app.service';
import { ElasticsearchModule } from './elasticsearch/elasticsearch.module';

@Module({
    imports: [
        ElasticsearchModule,
    ],
    controllers: [
        AppController,
    ],
    providers: [
        AppService,
    ],
})
export class AppModule {}

app.service.ts

import { Injectable } from '@nestjs/common';
import { ElasticsearchService } from '@nestjs/elasticsearch';

@Injectable()
export class AppService {

    constructor(
        private readonly client: ElasticsearchService,
    ) {}

    async getCompanies(): Promise<any[]> {
        const results = await this.client.search({ index: 'companydatabase' });
        return results.body.hits.hits.map((hit) => hit._source);
    }
}

elasticsearch.module.ts

import { Module } from '@nestjs/common';
import { ElasticsearchModule as BaseElasticsearchModule } from '@nestjs/elasticsearch';

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