gistfile1.txt

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

export class IngredientService {

    constructor(
	...
        private readonly elasticsearchService: ElasticsearchService
	...

    ) {

	public async elastic_search(pBody: any, pUser: UserDocument) {
        	let aQueryParams = {
            	      index: process.env.ELASTIC_SEARCH_OPTICS_INDEX,
            	      body: JSON.stringify(pBody),
                };
                let aResult = {};
                try {
                      aResult = await this.elasticsearchService.search(aQueryParams);
                } catch (e) {
                      this.logger.error(`ElasticSearchService search failed: ${e}`);
                      throw new HttpException(`${e}`, HttpStatus.INTERNAL_SERVER_ERROR);
                }
                return aResult;
         }
}