Cleanup thumbnails

ryanmccartney · Nov 16, 2023 · 63b4ebd · 63b4ebd
1 parent 1008d81
commit 63b4ebd
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 4 deletions.
diff --git a/docs/pages/installation/environment.md b/docs/pages/installation/environment.md
@@ -21,7 +21,7 @@ Docker image environment variables are given below
 | AUTH_PASSWORD | ffmp3gap1      | No       | String  | Auth password for login                                                            |
 | AUTH_KEY      | averysecretkey | No       | String  | Private key for generating JWT tokens. Change this if you're using authentication  |
 | MEDIA_PATH    | ./data/media   | No       | String  | Directory to keep media in. Useful to change if media is stored in a network share |
-| QUEUE_SZIE    | 5              | No       | Integer | Number of FFMpeg processes that can run simultaneously                             |
+| QUEUE_SIZE    | 5              | No       | Integer | Number of FFMpeg processes that can run simultaneously                             |
 | LOG_FOLDER    | logs           | No       | String  | Folder that logs are stored in                                                     |
 | LOG_NAME      | ffmpeg         | No       | String  | Log file names                                                                     |
 | LOG_LEVEL     | info           | No       | String  | Logging level "debug", "error", "info", "http" or "warning"                        |
diff --git a/utils/file-delete.js b/utils/file-delete.js
@@ -1,13 +1,13 @@
 "use strict";
 
-const fs = require("fs");
+const fs = require("fs").promises;
 const path = require("path");
 const logger = require("@utils/logger")(module);
 
 module.exports = async (relativePath) => {
     try {
         const absolutePath = path.resolve(relativePath);
-        if (await fs.unlinkSync(absolutePath)) {
+        if (await fs.unlink(absolutePath)) {
             return true;
         }
         return false;

diff --git a/utils/jobManager.js b/utils/jobManager.js
@@ -1,6 +1,7 @@
 const crypto = require("crypto");
+const fileDelete = require("@utils/file-delete");
 
-let maxQueueSize = process.env.QUEUE_SZIE || 5;
+let maxQueueSize = process.env.QUEUE_SIZE || 5;
 let jobs = {};
 
 const start = (output, name = "FFmpeg Process", type = ["default"]) => {
@@ -36,12 +37,17 @@ const update = (hash, update) => {
 const end = (hash, kill = true) => {
     if (jobs[hash]) {
         const job = jobs[hash];
+
         if (kill) {
             process.kill(jobs[hash].pid, "SIGINT");
         }
+
         job.ended = new Date();
         job.duration = job.ended - job.started;
         delete jobs[hash];
+
+        fileDelete(`data/thumbnail/${job.jobId}.png`);
+
         return job;
     } else {
         return { error: "Job does not exist." };