mirror of
https://github.com/C4illin/ConvertX.git
synced 2025-10-24 00:24:01 +00:00
42 lines
1.1 KiB
TypeScript
42 lines
1.1 KiB
TypeScript
import { unlink } from "node:fs/promises";
|
|
import { Elysia, t } from "elysia";
|
|
import { uploadsDir } from "..";
|
|
import db from "../db/db";
|
|
import { WEBROOT } from "../helpers/env";
|
|
import { userService } from "./user";
|
|
|
|
export const deleteFile = new Elysia().use(userService).post(
|
|
"/delete",
|
|
async ({ body, redirect, jwt, cookie: { auth, jobId } }) => {
|
|
if (!auth?.value) {
|
|
return redirect(`${WEBROOT}/login`, 302);
|
|
}
|
|
|
|
const user = await jwt.verify(auth.value);
|
|
if (!user) {
|
|
return redirect(`${WEBROOT}/login`, 302);
|
|
}
|
|
|
|
if (!jobId?.value) {
|
|
return redirect(`${WEBROOT}/`, 302);
|
|
}
|
|
|
|
const existingJob = await db
|
|
.query("SELECT * FROM jobs WHERE id = ? AND user_id = ?")
|
|
.get(jobId.value, user.id);
|
|
|
|
if (!existingJob) {
|
|
return redirect(`${WEBROOT}/`, 302);
|
|
}
|
|
|
|
const userUploadsDir = `${uploadsDir}${user.id}/${jobId.value}/`;
|
|
|
|
await unlink(`${userUploadsDir}${body.filename}`);
|
|
|
|
return {
|
|
message: "File deleted successfully.",
|
|
};
|
|
},
|
|
{ body: t.Object({ filename: t.String() }) },
|
|
);
|