최근 매칭 조회 소켓

Author: khmandarrin

src/matching/dto/matching.response.ts

@@ -132,4 +132,10 @@ export class GetMatchingsResponse {
 
 export class GetOneMatchingResponse extends OmitType(PatchMatchingResponse, [
   'chatRoomId',
-] as const) {}
+] as const) {
+  @ApiProperty({
+    example: '2024-10-11T09:00:00.000Z',
+    description: '신청 시각',
+  })
+  createdAt: string;
+}

src/matching/matching.controller.ts

@@ -14,7 +14,6 @@ import { MatchingService } from './matching.service';
 import {
   CreateMatchingSwagger,
   DeleteMatchingSwagger,
-  getLatestMatchingSwagger,
   GetMatchingsSwagger,
   PatchMatchingRequestStatusSwagger,
 } from './matching.swagger';
@@ -142,22 +141,4 @@ export class MatchingController {
     const response = await this.matchingService.getMatchings(req.user.id);
     return new BaseResponse(true, 'SUCCESS', response);
   }
-
-  @Get('latest')
-  @UseGuards(AuthGuard)
-  @getLatestMatchingSwagger('최근 매칭 조회 API')
-  async getLatestMatching(
-    @Req() req: Request,
-  ): Promise<BaseResponse<GetOneMatchingResponse>> {
-    const matching = await this.matchingService.getLatestMatching(req.user.id);
-    if (!matching) {
-      throw DataNotFoundException('매칭을 찾을 수 없습니다.');
-    }
-    return new BaseResponse<GetOneMatchingResponse>(true, '매칭 조회 성공', {
-      id: matching.id,
-      requesterId: matching.requester.id,
-      targetId: matching.target.id,
-      requestStatus: matching.requestStatus,
-    });
-  }
 }

src/matching/matching.service.ts

@@ -12,6 +12,7 @@ import { InjectRepository } from '@nestjs/typeorm';
 import {
   CreateMatchingResponse,
   GetMatchingsResponse,
+  GetOneMatchingResponse,
 } from './dto/matching.response';
 import { MatchingRequestStatusEnum } from 'src/common/enum/matchingRequestStatus';
 import { StatusEnum } from 'src/common/enum/entityStatus';
@@ -146,12 +147,26 @@ export class MatchingService {
     }
   }
 
-  async getLatestMatching(currentUserId: number): Promise<Matching> {
-    return await this.matchingRepository.findOne({
-      where: { target: { id: currentUserId } },
+  async getLatestMatching(
+    userId: number,
+  ): Promise<GetOneMatchingResponse | {}> {
+    const matching = await this.matchingRepository.findOne({
+      where: { target: { id: userId } },
       relations: ['target', 'requester'],
       order: { createdAt: 'DESC' },
     });
+
+    if (!matching) {
+      return {};
+    }
+
+    return {
+      id: matching.id,
+      requesterId: matching.requester.id,
+      targetId: matching.target.id,
+      requestStatus: matching.requestStatus,
+      createdAt: dayjs(matching.createdAt).format('YYYY-MM-DDTHH:mm:ssZ'),
+    };
   }
 
   async getMatchings(currentUserId: number): Promise<GetMatchingsResponse> {

src/matching/matching.swagger.ts

@@ -92,31 +92,6 @@ export function GetMatchingSwagger(apiSummary: string) {
   return ApiOperation({ summary: apiSummary });
 }
 
-// 최근 매칭 조회 API Swagger
-export function getLatestMatchingSwagger(apiSummary: string) {
-  return BaseSwaggerDecorator(
-    { summary: apiSummary },
-    [
-      {
-        statusCode: 200,
-        responseOptions: [
-          {
-            model: PatchMatchingResponse,
-            exampleTitle: '성공',
-            exampleDescription: '성공했을 때 값',
-          },
-        ],
-        baseResponseDto: BaseResponse,
-      },
-    ],
-    [
-      ApiBadRequestResponse({ description: 'Bad Request' }),
-      ApiNotFoundResponse({ description: '해당 유저가 존재하지 않습니다.' }),
-      ApiInternalServerErrorResponse({ description: 'Internal Server Error' }),
-    ],
-  );
-}
-
 // 매칭 삭제 API Swagger
 export function DeleteMatchingSwagger(apiSummary: string) {
   return ApiOperation({ summary: apiSummary });

src/matchingEventGateway.ts

@@ -158,4 +158,17 @@ export class MatchingEventsGateway
       client.emit('error', '매칭 상태 변경 처리 중 오류가 발생했습니다.');
     }
   }
+
+  @SubscribeMessage('getLatestMatching')
+  async handleGetLatestMatching(client: Socket, payload: { userId: number }) {
+    const { userId } = payload;
+    try {
+      const latestMatching =
+        await this.matchingService.getLatestMatching(userId);
+
+      client.emit('latestMatching', latestMatching);
+    } catch (error) {
+      client.emit('error', '매칭 조회 중 오류가 발생했습니다.');
+    }
+  }
 }