[Fix] 썸네일 기본 이미지 설정

[Fix] 썸네일 기본 이미지 설정

Author: seungheon123

apps/media/src/common/clients/record-client.interface.ts

@@ -0,0 +1,3 @@
+export interface IRecordClient {
+  post<T>(path: string, data: any): Promise<T>;
+}

apps/media/src/common/clients/record.client.ts

@@ -0,0 +1,27 @@
+import { Injectable } from '@nestjs/common';
+import { ConfigService } from '@nestjs/config';
+import { ErrorStatus } from '../responses/exceptions/errorStatus';
+import { HttpService } from '@nestjs/axios';
+import { CustomWsException } from '../responses/exceptions/custom-ws.exception';
+import { IRecordClient } from './record-client.interface';
+
+@Injectable()
+export class RecordClient implements IRecordClient {
+  constructor(private readonly httpService: HttpService, private readonly configService: ConfigService) {}
+
+  private readonly baseUrl = this.configService.get<string>('RECORD_SERVER_URL');
+
+  async post<T>(path: string, data: any): Promise<T> {
+    try {
+      const response = await this.httpService.post<T>(`${this.baseUrl}${path}`, data).toPromise();
+      return response.data;
+    } catch (error) {
+      throw this.handleError(error);
+    }
+  }
+
+  // TODO: Error custom 필요
+  private handleError(_error: any): Error {
+    throw new CustomWsException(ErrorStatus.RECORD_SERVER_ERROR);
+  }
+}

apps/media/src/common/responses/exceptions/errorStatus.ts

@@ -10,6 +10,12 @@ export class ErrorStatus {
 
   static readonly API_SERVER_ERROR = new ErrorStatus(500, 'COMMON_5001', 'API 서비스 로직에서 문제가 발생했습니다.');
 
+  static readonly RECORD_SERVER_ERROR = new ErrorStatus(
+    500,
+    'COMMON_5002',
+    'RECORD 서비스 로직에서 문제가 발생했습니다.',
+  );
+
   // User Errors
   static readonly USER_NOT_FOUND = new ErrorStatus(404, 'MEMBER_4000', '사용자를 찾을 수 없습니다.');
 

apps/media/src/sfu/sfu.module.ts

@@ -10,6 +10,7 @@ import { ConsumerService } from './services/consumer.service';
 import { BroadcastModule } from '../broadcast/broadcast.module';
 import { ClientService } from './services/client.service';
 import { RecordService } from './services/record.service';
+import { RecordClient } from 'src/common/clients/record.client';
 
 @Module({
   imports: [BroadcastModule, HttpModule],
@@ -23,6 +24,10 @@ import { RecordService } from './services/record.service';
     ConsumerService,
     RecordService,
     ClientService,
+    {
+      provide: 'RECORD_CLIENT',
+      useClass: RecordClient,
+    },
   ],
 })
 export class SfuModule {}

apps/media/src/sfu/sfu.service.ts

@@ -1,5 +1,5 @@
 import { ConfigService } from '@nestjs/config';
-import { Injectable } from '@nestjs/common';
+import { Inject, Injectable } from '@nestjs/common';
 import * as mediasoup from 'mediasoup';
 import { ConnectTransportDto } from './dto/transport-params.interface';
 import { RoomService } from './services/room.service';
@@ -15,6 +15,7 @@ import { ClientService } from './services/client.service';
 import { RecordService } from './services/record.service';
 import { User } from '../types/user';
 import { SetVideoQualityDto } from './dto/set-video-quality.dto';
+import { IRecordClient } from 'src/common/clients/record-client.interface';
 
 @Injectable()
 export class SfuService {
@@ -27,10 +28,15 @@ export class SfuService {
     private readonly recordService: RecordService,
     private readonly clientService: ClientService,
     private readonly configService: ConfigService,
+    @Inject('RECORD_CLIENT')
+    private readonly recordClient: IRecordClient,
   ) {}
 
   async createRoom(clientId: string, user: User) {
     const room = await this.roomService.createRoom();
+
+    await this.recordClient.post('/thumbnail', { roomId: room.id });
+
     const thumbnail = `${this.configService.get('PUBLIC_RECORD_SERVER_URL')}/statics/thumbnails/${room.id}.jpg`;
     await this.broadcasterService.createBroadcast(
       CreateBroadcastDto.of(room.id, `${user.camperId}님의 방송`, thumbnail, user.id),

apps/record/Dockerfile

@@ -10,6 +10,9 @@ WORKDIR /app
 
 RUN mkdir -p /app/assets/records /app/assets/thumbnails && chmod -R 777 /app/assets
 
+COPY ./apps/record/public/default-thumbnail.jpg /app/apps/record/assets/default-thumbnail.jpg
+RUN chmod 644 /app/apps/record/assets/default-thumbnail.jpg
+
 # Environment variables
 ARG RECORD_PORT
 ARG NCLOUD_ACCESS_KEY

apps/record/public/default-thumbnail.jpg

@@ -88,8 +88,11 @@ const thumbnailArgs = (dirPath: string, roomId: string) => {
     'pipe:0', // SDP를 파이프로 전달
     '-vf',
     'fps=1/10,scale=1280:720', // 10초마다 한 프레임을 캡처하고 해상도 조정
+    '-f',
+    'image2', // 이미지 출력 포맷 명시
     '-update',
-    '1', // 같은 파일에 덮어쓰기 활성화
+    '1',
+    '-y', // 강제 덮어쓰기
     `${dirPath}/thumbnails/${roomId}.jpg`, // 덮어쓸 출력 파일 이름
   ];
   return commandArgs;

apps/record/src/ffmpeg.ts

@@ -12,6 +12,7 @@ const app = express();
 const assetsDirPath = path.join(__dirname, '../assets');
 const thumbnailsDirPath = path.join(__dirname, '../assets/thumbnails');
 const recordsDirPath = path.join(__dirname, '../assets/records');
+const defaultThumbnailPath = path.join(__dirname, '../assets/default-thumbnail.jpg');
 
 app.use(express.json());
 app.use(cors());
@@ -29,6 +30,22 @@ if (!fs.existsSync(recordsDirPath)) {
   fs.mkdirSync(recordsDirPath, { recursive: true });
 }
 
+app.post('/thumbnail', (req, res) => {
+  const { roomId } = req.body;
+  try {
+    if (!fs.existsSync(defaultThumbnailPath)) {
+      console.error('Default thumbnail not found');
+      res.status(404).send({ error: 'Default thumbnail not found' });
+    }
+    const newThumbnailPath = path.join(thumbnailsDirPath, `${roomId}.jpg`);
+    fs.copyFileSync(defaultThumbnailPath, newThumbnailPath);
+    console.log('Default Thumbnail 생성됨:', newThumbnailPath);
+    res.send({ success: true });
+  } catch (error) {
+    res.status(500).send({ success: false, error: 'Failed to create thumbnail' });
+  }
+});
+
 app.post('/send', (req, res) => {
   const { videoPort, roomId, type, audioPort } = req.body;
   createFfmpegProcess(videoPort, assetsDirPath, roomId, type, audioPort);