검색 API 구현

applicationServer/package.json

@@ -72,7 +72,8 @@
       "^@naver/(.*)$": "<rootDir>/src/auth/naver/$1",
       "^@cookie/(.*)$": "<rootDir>/src/auth/cookie/$1",
       "^@authUtil/(.*)$": "<rootDir>/src/auth/util/$1",
-      "^@follow/(.*)$": "<rootDir>/src/follow/$1"
+      "^@follow/(.*)$": "<rootDir>/src/follow/$1",
+      "^@search/(.*)$": "<rootDir>/src/search/$1"
     }
   }
 }

applicationServer/src/app.module.ts

@@ -6,13 +6,23 @@ import { LiveModule } from '@live/live.module';
 import { GithubAuthModule } from '@github/github.module';
 import { AuthModule } from '@auth/auth.module';
 import { FollowModule } from '@follow/follow.module';
+import { SearchModule } from '@search/search.module';
 import { NaverAuthModule } from '@naver/naver.module';
 import { GoogleAuthModule } from '@google/google.module';
 
 dotenv.config();
 
 @Module({
-  imports: [MemberModule, GithubAuthModule, AuthModule, LiveModule, FollowModule, NaverAuthModule, GoogleAuthModule],
+  imports: [
+    MemberModule,
+    GithubAuthModule,
+    AuthModule,
+    LiveModule,
+    SearchModule,
+    FollowModule,
+    NaverAuthModule,
+    GoogleAuthModule,
+  ],
 })
 export class AppModule implements NestModule {
   configure(consumer: MiddlewareConsumer) {

applicationServer/src/live/live.module.ts

@@ -8,5 +8,6 @@ import { AuthModule } from '@src/auth/core/auth.module';
   imports: [MemberModule, AuthModule],
   controllers: [LiveController],
   providers: [LiveService],
+  exports: [LiveService],
 })
 export class LiveModule {}

applicationServer/src/member/member.service.ts

@@ -12,19 +12,25 @@ class MemberService {
     private memberRepository: Repository<Member>,
   ) {}
 
-  async findMembers() {
+  findMembers() {
     return this.memberRepository.find();
   }
 
-  async findMembersWithFollowTable(id) {
+  findMembersWithCondition(condition) {
+    return this.memberRepository.find({
+      where: condition,
+    });
+  }
+
+  findMembersWithFollowTable(id) {
     return this.memberRepository
       .createQueryBuilder('member')
       .innerJoin('follow', 'f', 'f.following = member.id')
       .where('f.follower = :id', { id })
       .getMany();
   }
 
-  async findOneMemberWithCondition(condition: { [key: string]: string }) {
+  findOneMemberWithCondition(condition: { [key: string]: string }) {
     return this.memberRepository.findOne({ where: condition });
   }
 
@@ -37,7 +43,7 @@ class MemberService {
     return member;
   }
 
-  async register(id: string, image_url?: string): Promise<Member> {
+  register(id: string, image_url?: string): Promise<Member> {
     const name = this.generateUniqueName();
     const user = {
       id,
@@ -59,7 +65,7 @@ class MemberService {
     return name;
   }
 
-  async refreshStreamKey(id) {
+  refreshStreamKey(id) {
     const newStreamKey = crypto.randomUUID();
     this.memberRepository.update(id, { stream_key: newStreamKey });
 

applicationServer/src/search/search.controller.ts

@@ -0,0 +1,32 @@
+import { Controller, Get, Query } from '@nestjs/common';
+import { SearchService } from '@search/search.service';
+import { LiveService } from '@src/live/live.service';
+
+@Controller('search')
+export class SearchController {
+  constructor(
+    private readonly searchService: SearchService,
+    private readonly liveService: LiveService,
+  ) {}
+
+  @Get('/')
+  async getSearchData(@Query('query') query: string) {
+    const keyword = query.replace(' ', '');
+    const searchResult = {
+      lives: [],
+      members: [],
+    };
+    await Promise.all([
+      (searchResult.lives = this.searchService.getLiveListWithKeyword(keyword)),
+      (searchResult.members = (await this.searchService.getMemberListWithKeyword(keyword)).reduce(
+        (offline, thisUser) => {
+          if (!this.liveService.live.data.has(thisUser.broadcast_id)) offline.push(thisUser);
+          return offline;
+        },
+        [],
+      )),
+    ]);
+
+    return searchResult;
+  }
+}

applicationServer/src/search/search.module.ts

@@ -0,0 +1,12 @@
+import { Module } from '@nestjs/common';
+import { LiveModule } from '@live/live.module';
+import { MemberModule } from '@src/member/member.module';
+import { SearchController } from '@search/search.controller';
+import { SearchService } from '@search/search.service';
+
+@Module({
+  imports: [MemberModule, LiveModule],
+  controllers: [SearchController],
+  providers: [SearchService],
+})
+export class SearchModule {}

applicationServer/src/search/search.service.ts

@@ -0,0 +1,40 @@
+import { Injectable } from '@nestjs/common';
+import { MemberService } from '@src/member/member.service';
+import { LiveService } from '@src/live/live.service';
+import { Like } from 'typeorm';
+import { User } from '@src/types';
+
+@Injectable()
+export class SearchService {
+  constructor(
+    private readonly memberService: MemberService,
+    private readonly liveService: LiveService,
+  ) {}
+
+  getLiveListWithKeyword(keyword) {
+    const currentLiveList = this.liveService.getLiveList(0);
+    const filteredLiveList = currentLiveList.reduce((list, live) => {
+      const metadata = [...live.tags, live.contentCategory, live.moodCategory, live.title, live.userName]
+        .join('')
+        .replace(' ', '');
+      if (metadata.match(new RegExp(keyword))) list.push(live);
+      return list;
+    }, []);
+
+    return filteredLiveList;
+  }
+
+  async getMemberListWithKeyword(keyword) {
+    const condition = { name: Like(`%${keyword}%`) };
+    const searchMemberList = await this.memberService.findMembersWithCondition(condition);
+
+    return searchMemberList.map((member) => {
+      return {
+        name: member.name,
+        profile_image: member.profile_image,
+        broadcast_id: member.broadcast_id,
+        follower_count: member.follower_count,
+      } as User;
+    });
+  }
+}

applicationServer/tsconfig.json

@@ -22,7 +22,8 @@
       "@member/*": ["src/member/*"],
       "@live/*": ["src/live/*"],
       "@follow/*": ["src/follow/*"],
-      "@google/*": ["src/auth/google/*"]
+      "@google/*": ["src/auth/google/*"],
+      "@search/*": ["src/search/*"]
     },
     "incremental": true,
     "skipLibCheck": true,