feat: 편집 기능 수정

Author: ChaJunWoo-dev

src/services/trimVideo.js

@@ -1,30 +1,72 @@
 import ffmpeg from "fluent-ffmpeg";
-// import createError from "http-errors";
-
-// import { MESSAGES } from "../config/constants.js";
+import createError from "http-errors";
+import { MESSAGES } from "../config/constants.js";
 import env from "../config/env.js";
 import { bucket } from "../config/gcs.js";
 
 ffmpeg.setFfmpegPath("/usr/bin/ffmpeg");
 
-const trimVideo = async ({ videoId, trimStart, trimEnd }) => {
+const trimAndUpload = async ({ videoId, trimStart, trimEnd, outputPath }) => {
   const originalVideo = `${env.ORIGINAL_PREFIX}/${videoId}`;
 
-  try {
-    const stream = bucket.file(originalVideo).createReadStream();
-    return new Promise((resolve, reject) => {
-      const ffmpegStream = ffmpeg(stream)
-        .setStartTime(trimStart)
-        .duration(trimEnd - trimStart)
-        .format("webm")
-        .on("error", (err) => reject(err));
-
-      const outputStream = ffmpegStream.pipe();
-      resolve(outputStream);
+  return new Promise((resolve, reject) => {
+    const inputFile = bucket.file(originalVideo);
+    const inputStream = inputFile.createReadStream();
+
+    inputStream.on("error", (err) => {
+      console.error("Failed to read input video:", err);
+      reject(createError.InternalServerError("Failed to read video"));
+    });
+
+    inputStream.on("response", (res) => {
+      console.log(
+        "Started reading original video. Status code:",
+        res.statusCode
+      );
     });
-  } catch (err) {
-    throw err;
-  }
+
+    const outputFile = bucket.file(outputPath);
+    const outputStream = outputFile.createWriteStream({
+      metadata: { contentType: "video/webm" },
+    });
+
+    outputStream.on("error", (err) => {
+      console.error("Failed to save video to GCS:", err);
+      reject(createError.InternalServerError(MESSAGES.ERROR.FAILED_SAVE_VIDEO));
+    });
+
+    outputStream.on("finish", async () => {
+      console.log("Upload to GCS finished.");
+
+      try {
+        const [meta] = await outputFile.getMetadata();
+        console.log("Saved video size:", meta.size, "bytes");
+      } catch (err) {
+        console.error("Failed to get uploaded file metadata:", err);
+      }
+
+      resolve();
+    });
+
+    console.log("Starting video trimming with FFmpeg...");
+    ffmpeg(inputStream)
+      .setStartTime(trimStart)
+      .duration(trimEnd - trimStart)
+      .format("webm")
+      .on("start", (commandLine) => {
+        console.log("FFmpeg command:", commandLine);
+      })
+      .on("error", (err) => {
+        console.error("FFmpeg processing error:", err);
+        reject(
+          createError.InternalServerError(MESSAGES.ERROR.FAILED_EDIT_VIDEO)
+        );
+      })
+      .on("end", () => {
+        console.log("FFmpeg trimming finished.");
+      })
+      .pipe(outputStream, { end: true });
+  });
 };
 
-export default trimVideo;
+export default trimAndUpload;