45 lines
1.4 KiB
TypeScript
45 lines
1.4 KiB
TypeScript
import { NextResponse } from "next/server";
|
|
import { db } from "~/server/db";
|
|
import { auth } from "~/server/auth";
|
|
import path from "path";
|
|
import { promises as fs } from "fs";
|
|
import { notifyClients } from "~/utils/notifyClients";
|
|
|
|
export async function DELETE(req: Request) {
|
|
const session = await auth();
|
|
|
|
if (!session?.user) {
|
|
return NextResponse.json({ error: "Unauthorized" }, { status: 401 });
|
|
}
|
|
|
|
try {
|
|
const body = (await req.json()) as { id: string } | null;
|
|
if (!body?.id) {
|
|
return NextResponse.json({ error: "Invalid request body" }, { status: 400 });
|
|
}
|
|
|
|
const resource = await db.file.findUnique({
|
|
where: { id: body.id },
|
|
});
|
|
|
|
if (!resource || resource.uploadedById !== session.user.id) {
|
|
return NextResponse.json({ error: "Resource not found or unauthorized" }, { status: 404 });
|
|
}
|
|
|
|
const filePath = path.join(process.cwd(), "uploads", path.basename(body.id));
|
|
await fs.unlink(filePath).catch((err) => {
|
|
console.error("Error deleting file from filesystem:", err);
|
|
});
|
|
|
|
await db.file.delete({
|
|
where: { id: body.id },
|
|
});
|
|
|
|
notifyClients({ type: "file-removed", fileId: body.id });
|
|
|
|
return NextResponse.json({ message: "Resource deleted successfully" });
|
|
} catch (error) {
|
|
console.error("Error deleting resource:", error);
|
|
return NextResponse.json({ error: "Failed to delete resource" }, { status: 500 });
|
|
}
|
|
} |