feat(person): add full-text search method #78

Author: mdwitr0

src/person/person.controller.ts

@@ -9,13 +9,31 @@ import { PersonDocsResponseDto } from './dto/person-docs.response';
 import { PersonService } from './person.service';
 import { PersonAward } from './schemas/person-award.schema';
 import { Person } from './schemas/person.schema';
+import { SearchDto } from 'src/common/dto/query/search.dto';
+import { SearchPersonResponseDto } from './dto/search-person.response.dto';
 
 @Controller('person', 'Актеры, режиссеры, операторы, и т.д')
-export class PersonController extends BaseControllerWithFindById(Person, PersonDocsResponseDto, 'Поиск персон') {
+export class PersonController extends BaseControllerWithFindById(
+  Person,
+  PersonDocsResponseDto,
+  'Универсальный поиск персон с фильтрами',
+) {
   constructor(private readonly personService: PersonService) {
     super(personService);
   }
 
+  @Version('1.2')
+  @Get('search')
+  @UseInterceptors(CacheInterceptor)
+  @ApiOperation({
+    summary: 'Полнотекстовый поиск',
+    description: `Этот метод предназначен для полнотекстового поиска персон по текстовому запросу. Он принимает только один параметр \`query\`. Если вам нужны фильтры, гибкость и множество результатов, используйте метод \`Универсальный поиск с фильтрами\` (findMany). В этом методе также не доступен выбор полей. А в ответ приходит упрощенная модель, которая подходит только для отображения результатов поиска.`,
+  })
+  async searchPerson(@Query() query: SearchDto): Promise<SearchPersonResponseDto> {
+    const data = await this.service.searchPerson(query);
+    return data;
+  }
+
   @Version('1.1')
   @Get('awards')
   @UseInterceptors(CacheInterceptor)

src/person/person.module.ts

@@ -4,13 +4,15 @@ import { PersonController } from './person.controller';
 import { MongooseModule } from '@nestjs/mongoose';
 import { Person, PersonSchema } from './schemas/person.schema';
 import { PersonAward, PersonAwardSchema } from './schemas/person-award.schema';
+import { MeiliModule } from 'src/meili/meili.module';
 
 @Module({
   imports: [
     MongooseModule.forFeature([
       { name: Person.name, schema: PersonSchema },
       { name: PersonAward.name, schema: PersonAwardSchema },
     ]),
+    MeiliModule,
   ],
   controllers: [PersonController],
   providers: [PersonService],

src/person/person.service.ts

@@ -6,16 +6,42 @@ import { IQuery } from 'src/common/interfaces/query.interface';
 import { Person, PersonDocument } from 'src/person/schemas/person.schema';
 import { PersonAwardDocsResponseDto } from './dto/person-award-docs.response.dto';
 import { PersonAward, PersonAwardDocument } from './schemas/person-award.schema';
+import { SearchDto } from 'src/common/dto/query/search.dto';
+import { SearchPersonResponseDto } from './dto/search-person.response.dto';
+import { MeiliService } from 'src/meili/meili.service';
+import { MeiliPersonEntity } from './entities/meili-person.entity';
+import { PERSON_INDEX } from './constants/person-index';
 
 @Injectable()
 export class PersonService extends BaseService<Person> {
   constructor(
     @InjectModel(Person.name) private readonly personModel: Model<PersonDocument>,
     @InjectModel(PersonAward.name) private readonly personAwardModel: Model<PersonAwardDocument>,
+    private readonly meiliService: MeiliService,
   ) {
     super(personModel);
   }
 
+  async searchPerson(dto: SearchDto): Promise<SearchPersonResponseDto> {
+    const offset = (dto.page - 1) * dto.limit;
+    const searchResponse = await this.meiliService.search<MeiliPersonEntity>(
+      dto.query,
+      PERSON_INDEX,
+      dto.limit,
+      offset,
+    );
+
+    const personEntities = searchResponse.hits.map((person) => new MeiliPersonEntity(person));
+
+    return {
+      docs: personEntities,
+      total: searchResponse.totalHits,
+      limit: dto.limit,
+      page: dto.page,
+      pages: Math.ceil(searchResponse.totalHits / dto.limit),
+    };
+  }
+
   async findManyAwards(query: IQuery): Promise<PersonAwardDocsResponseDto> {
     const [total, docs] = await Promise.all([
       this.personAwardModel.countDocuments(query.filter),