Merge pull request #308 from tmddus2/refactor/240228-clova-api

Refactor(#307): CLOVA API 호출 실패 시 재시도

mediaServer/src/constants/clova-api-response-type.constant.ts

@@ -0,0 +1,4 @@
+const SUCCEEDED = "SUCCEEDED";
+const RETRIABLE_ERROR = ["ERROR_SERVER_BUSY", "ERROR_AUDIO_CONVERSION", "ERROR_INTERNAL_ERROR", "ERROR_EXTERNAL_ERROR"];
+
+export { SUCCEEDED, RETRIABLE_ERROR };

mediaServer/src/dto/clova-api-request.dto.ts

@@ -0,0 +1,15 @@
+export const ClovaApiRequest =(url: any, code: string) =>{    
+    const headers = new Headers();
+    headers.append('Content-Type', 'application/json');
+    headers.append('X-CLOVASPEECH-API-KEY', process.env.CLOVA_API_KEY as string);
+    return {
+        method: 'POST',
+        headers: headers,
+        body: JSON.stringify({
+            language: process.env.CLOVA_API_LANGUAGE,
+            completion: process.env.CLOVA_API_COMPLETION,
+            url: url,
+            callback: `${process.env.SERVER_API_URL}/lecture/${code}/text`
+        })
+    }
+}

mediaServer/src/dto/clova-api-response.dto.ts

@@ -0,0 +1,11 @@
+export class ClovaApiReponse {
+    result:string;
+    message: string;
+    timestamp: string;
+
+    constructor(result:string, message:string, timestamp:string) {
+        this.result = result;
+        this.message = message;
+        this.timestamp = timestamp;
+    }
+}

mediaServer/src/utils/media-converter.ts

@@ -8,6 +8,9 @@ import path from 'path';
 import { PeerStreamInfo } from '../models/PeerStreamInfo';
 import { FfmpegCommand } from '../models/FfmpegCommand';
 import { uploadFileToObjectStorage } from './ncp-storage';
+import { RETRIABLE_ERROR, SUCCEEDED } from '../constants/clova-api-response-type.constant';
+import { ClovaApiReponse } from '../dto/clova-api-response.dto';
+import { ClovaApiRequest } from '../dto/clova-api-request.dto';
 import { AUDIO_OUTPUT_DIR } from '../constants/media-converter.constant';
 ffmpeg.setFfmpegPath(ffmpegPath.path);
 
@@ -132,21 +135,15 @@ class MediaConverter {
   };
 
   extractSubtitle = async (url: any, code: string) => {
-    const headers = new Headers();
-    headers.append('Content-Type', 'application/json');
-    headers.append('X-CLOVASPEECH-API-KEY', process.env.CLOVA_API_KEY as string);
-
-    const response = await fetch(process.env.CLOVA_API_URL as string, {
-      method: 'POST',
-      headers: headers,
-      body: JSON.stringify({
-        language: process.env.CLOVA_API_LANGUAGE,
-        completion: process.env.CLOVA_API_COMPLETION,
-        url: url,
-        callback: `${process.env.SERVER_API_URL}/lecture/${code}/text`
-      })
-    });
-    console.log(`[${response.status}] 강의 자막 저장`);
+    const response = await fetch(process.env.CLOVA_API_URL as string, ClovaApiRequest(url, code));
+    const result = await response.json() as ClovaApiReponse;
+
+    if (result.result == SUCCEEDED) {
+      console.log(`[${result.result}] 강의 자막 저장`);
+    }
+    if (result.result in RETRIABLE_ERROR) {
+      const response = await fetch(process.env.CLOVA_API_URL as string, ClovaApiRequest(url, code));
+    }
   };
 }