From ad860f51d3a8cc5e9c627acff69c0d6048b56f13 Mon Sep 17 00:00:00 2001 From: SrGooglo Date: Thu, 24 Apr 2025 07:59:45 +0000 Subject: [PATCH] Drop deprecated endpoints & utils --- .../server/services/files/file.service.js | 12 --------- .../services/files/routes/stream/[$]/get.js | 25 ------------------- .../files/utils/downloadFFMPEG/index.js | 20 --------------- .../services/files/utils/resolveUrl/index.js | 20 --------------- .../files/utils/syncDirToRemote/index.js | 23 ----------------- 5 files changed, 100 deletions(-) delete mode 100644 packages/server/services/files/routes/stream/[$]/get.js delete mode 100644 packages/server/services/files/utils/downloadFFMPEG/index.js delete mode 100755 packages/server/services/files/utils/resolveUrl/index.js delete mode 100755 packages/server/services/files/utils/syncDirToRemote/index.js diff --git a/packages/server/services/files/file.service.js b/packages/server/services/files/file.service.js index 598a155a..a7c80f10 100755 --- a/packages/server/services/files/file.service.js +++ b/packages/server/services/files/file.service.js @@ -11,18 +11,6 @@ import SharedMiddlewares from "@shared-middlewares" import LimitsClass from "@shared-classes/Limits" import TaskQueueManager from "@shared-classes/TaskQueueManager" -// import * as Minio from 'minio' - -// class StorageNG { -// constructor() { - -// } - -// async initialize() { - -// } -// } - class API extends Server { static refName = "files" static useEngine = "hyper-express-ng" diff --git a/packages/server/services/files/routes/stream/[$]/get.js b/packages/server/services/files/routes/stream/[$]/get.js deleted file mode 100644 index 8ecf5ffc..00000000 --- a/packages/server/services/files/routes/stream/[$]/get.js +++ /dev/null @@ -1,25 +0,0 @@ -import mimetypes from "mime-types" - -export default { - useContext: ["storage"], - fn: async (req, res) => { - const streamPath = req.path.replace(req.route.pattern.replace("*", ""), "/") - - this.default.contexts.storage.getObject(process.env.S3_BUCKET, streamPath, (err, dataStream) => { - if (err) { - return res.status(404).end() - } - - const extname = mimetypes.lookup(streamPath) - - // send chunked response - res.status(200) - - // set headers - res.setHeader("Content-Type", extname) - res.setHeader("Accept-Ranges", "bytes") - - return dataStream.pipe(res) - }) - } -} \ No newline at end of file diff --git a/packages/server/services/files/utils/downloadFFMPEG/index.js b/packages/server/services/files/utils/downloadFFMPEG/index.js deleted file mode 100644 index 030a68d1..00000000 --- a/packages/server/services/files/utils/downloadFFMPEG/index.js +++ /dev/null @@ -1,20 +0,0 @@ -import fs from "node:fs" -import os from "node:os" -import axios from "axios" - -export default async (outputDir) => { - const arch = os.arch() - - console.log(`Downloading ffmpeg for ${arch}...`) - const baseURL = `https://johnvansickle.com/ffmpeg/releases/ffmpeg-release-${arch}-static.tar.xz` - - - const response = await axios.get(baseURL, { - responseType: "stream" - }) - - const ffmpegPath = path.join(outputDir, `ffmpeg-${arch}.tar.xz`) - const ffmpegFile = fs.createWriteStream(ffmpegPath) - - response.data.pipe(ffmpegFile) -} \ No newline at end of file diff --git a/packages/server/services/files/utils/resolveUrl/index.js b/packages/server/services/files/utils/resolveUrl/index.js deleted file mode 100755 index a9a33785..00000000 --- a/packages/server/services/files/utils/resolveUrl/index.js +++ /dev/null @@ -1,20 +0,0 @@ -export default (from, to) => { - const resolvedUrl = new URL(to, new URL(from, "resolve://")) - - if (resolvedUrl.protocol === "resolve:") { - let { pathname, search, hash } = resolvedUrl - - if (to.includes("@")) { - const fromUrl = new URL(from) - const toUrl = new URL(to, fromUrl.origin) - - pathname = toUrl.pathname - search = toUrl.search - hash = toUrl.hash - } - - return pathname + search + hash - } - - return resolvedUrl.toString() -} \ No newline at end of file diff --git a/packages/server/services/files/utils/syncDirToRemote/index.js b/packages/server/services/files/utils/syncDirToRemote/index.js deleted file mode 100755 index 7481c2a7..00000000 --- a/packages/server/services/files/utils/syncDirToRemote/index.js +++ /dev/null @@ -1,23 +0,0 @@ -import fs from "fs" -import path from "path" - -async function syncFolder(dir, destPath) { - const files = await fs.promises.readdir(dir) - - for await (const file of files) { - const filePath = path.resolve(dir, file) - const desitinationFilePath = `${destPath}/${file}` - - const stat = fs.statSync(filePath) - - if (stat.isDirectory()) { - await syncFolder(filePath, desitinationFilePath) - } else { - const fileContent = await fs.promises.readFile(filePath) - - await global.storage.putObject(process.env.S3_BUCKET, desitinationFilePath, fileContent) - } - } -} - -export default syncFolder \ No newline at end of file