everything works. Let's deploy.

Author: elijahthis

index.js

@@ -3,13 +3,25 @@ const http = require("http");
 const cors = require("cors");
 const multer = require("multer");
 const path = require("path");
-const { transcodeVideo } = require("./transcode");
+const { transcodeVideo, trimVideo } = require("./transcode");
 
 const port = process.env.PORT || 3211;
 
 // VERY IMPORTANT: WHEN RUNNING IN NODE, USE THESE FLAGS:--experimental-wasm-threads --experimental-wasm-bulk-memory
 
 const app = express();
+
+const fileStorageEngine = multer.diskStorage({
+    destination: (req, file, cb) => {
+        cb(null, "./storage");
+    },
+    filename: (req, file, cb) => {
+        cb(null, Date.now() + "--" + file.originalname);
+    },
+});
+
+const uploads = multer({ storage: fileStorageEngine });
+
 app.use(cors());
 app.use(express.json());
 app.use((_, res, next) => {
@@ -24,19 +36,62 @@ app.get("/", (req, res) => {
     res.send({ message: "Mind your business" });
 });
 
-app.post("/upload", async (req, res) => {
+app.post("/upload", uploads.single("newVideo"), async (req, res) => {
     try {
-        if (req.file) {
+        console.log(req.file);
+        res.send({ filename: req.file.filename, filepath: req.file.path });
+    } catch (e) {
+        console.log(e);
+        throw e;
+    }
+});
+
+app.post("/transcode", async (req, res) => {
+    // res.send({ endpoint: "trim endpoint" });
+    try {
+        if (!req.body.filename) {
             console.log(req);
             throw new Error("no file data");
         }
-        // await transcodeVideo(req.file.originalname, req.file.path);
-        console.log(req.body);
-        await transcodeVideo(req.body.filename, req.body.filepath);
-        res.status(200).send();
-    } catch (e) {}
+
+        console.log(req.body, "line 56");
+        transcodeVideo(
+            req.body.filename,
+            req.body.filepath,
+            req.body.filetype,
+            res
+        );
+    } catch (e) {
+        console.log(e);
+        throw new Error(e);
+    }
+});
+
+app.post("/trim", async (req, res) => {
+    try {
+        if (!req.body.filename) {
+            console.log(req);
+            throw new Error("no file data");
+        }
+
+        console.log(req.body, "line 56");
+        trimVideo(
+            req.body.filename,
+            req.body.filepath,
+            req.body.start,
+            req.body.end,
+            res
+        );
+    } catch (e) {
+        console.log(e);
+        throw new Error(e);
+    }
 });
 
 app.listen(port, () => {
-    console.log(`Example app listening on port ${port}`);
+    console.log(`Veditor app listening on port ${port}`);
+});
+
+process.on("uncaughtException", function (err) {
+    console.log("UNCAUGHT EXCEPTION - keeping process alive:", err); // err.message is "foobar"
 });

test.avi

@@ -3,26 +3,81 @@ const { createFFmpeg, fetchFile } = require("@ffmpeg/ffmpeg");
 
 const ffmpeg = createFFmpeg({ log: true });
 
-const transcodeVideo = async (filename, filepath) => {
-    await ffmpeg.load();
-    ffmpeg.FS(
-        "writeFile",
-        "test.mp4",
-        await fetchFile("http://localhost:3000/assets/video/Real 4K HDR .mp4")
-    );
-    await ffmpeg.run(
-        "-i",
-        "test.mp4",
-        "-t",
-        "2.5",
-        "-ss",
-        "2.5",
-        "-f",
-        "gif",
-        "out.gif"
-    );
-    await fs.promises.writeFile("./out.gif", ffmpeg.FS("readFile", "out.gif"));
-    process.exit(0);
+const transcodeVideo = async (filename, filepath, filetype, res) => {
+    try {
+        if (!ffmpeg.isLoaded()) await ffmpeg.load();
+
+        ffmpeg.FS(
+            "writeFile",
+            `test.${filename.slice(-3)}`,
+            await fetchFile(filepath)
+        );
+
+        if (["wav", "m4a", "mp3"].includes(filetype))
+            await ffmpeg.run(
+                "-i",
+                `test.${filename.slice(-3)}`,
+                "-vn",
+                "-acodec",
+                "copy",
+                `out.${filetype}`
+            );
+        else {
+            await ffmpeg.run(
+                "-i",
+                `test.${filename.slice(-3)}`,
+                `out.${filetype}`
+            );
+        }
+        const newPath = `./transcoded/${Date.now()}-Transcoded----${filename}.${filetype}`;
+        await fs.promises.writeFile(
+            newPath,
+            ffmpeg.FS("readFile", `out.${filetype}`)
+        );
+        await res.download(newPath);
+    } catch (err) {
+        console.log("Error:", err);
+        throw err;
+    }
+};
+
+const trimVideo = async (filename, filepath, start, end, res) => {
+    try {
+        if (!ffmpeg.isLoaded()) await ffmpeg.load();
+
+        ffmpeg.FS(
+            "writeFile",
+            `test.${filename.slice(-3)}`,
+            await fetchFile(filepath)
+        );
+
+        await ffmpeg.run(
+            "-i",
+            `test.${filename.slice(-3)}`,
+            "-ss",
+            `${start}`,
+            "-to",
+            `${end}`,
+            "-c:v",
+            "copy",
+            "-c:a",
+            "copy",
+            `out.${filename.slice(-3)}`
+        );
+
+        const newPath = `./transcoded/${Date.now()}-Trimmed----${filename}.${filename.slice(
+            -3
+        )}`;
+        await fs.promises.writeFile(
+            newPath,
+            ffmpeg.FS("readFile", `out.${filename.slice(-3)}`)
+        );
+        await res.download(newPath);
+    } catch (err) {
+        console.log("Error:", err);
+        throw err;
+    }
 };
 
 module.exports.transcodeVideo = transcodeVideo;
+module.exports.trimVideo = trimVideo;