122 lines
3.1 KiB
TypeScript
122 lines
3.1 KiB
TypeScript
import { prisma } from "@/lib/api/db";
|
|
import bcrypt from "bcrypt";
|
|
import removeFolder from "@/lib/api/storage/removeFolder";
|
|
import Stripe from "stripe";
|
|
import { DeleteUserBody } from "@/types/global";
|
|
import removeFile from "@/lib/api/storage/removeFile";
|
|
|
|
export default async function deleteUserById(
|
|
userId: number,
|
|
body: DeleteUserBody
|
|
) {
|
|
// First, we retrieve the user from the database
|
|
const user = await prisma.user.findUnique({
|
|
where: { id: userId },
|
|
});
|
|
|
|
if (!user) {
|
|
return {
|
|
response: "Invalid credentials.",
|
|
status: 404,
|
|
};
|
|
}
|
|
|
|
// Then, we check if the provided password matches the one stored in the database
|
|
const isPasswordValid = bcrypt.compareSync(body.password, user.password);
|
|
|
|
if (!isPasswordValid) {
|
|
return {
|
|
response: "Invalid credentials.",
|
|
status: 401, // Unauthorized
|
|
};
|
|
}
|
|
|
|
// Delete the user and all related data within a transaction
|
|
await prisma.$transaction(async (prisma) => {
|
|
// Delete whitelisted users
|
|
await prisma.whitelistedUser.deleteMany({
|
|
where: { userId },
|
|
});
|
|
|
|
// Delete links
|
|
await prisma.link.deleteMany({
|
|
where: { collection: { ownerId: userId } },
|
|
});
|
|
|
|
// Delete tags
|
|
await prisma.tag.deleteMany({
|
|
where: { ownerId: userId },
|
|
});
|
|
|
|
// Find collections that the user owns
|
|
const collections = await prisma.collection.findMany({
|
|
where: { ownerId: userId },
|
|
});
|
|
|
|
for (const collection of collections) {
|
|
// Delete related users and collections relations
|
|
await prisma.usersAndCollections.deleteMany({
|
|
where: { collectionId: collection.id },
|
|
});
|
|
|
|
// Delete archive folders
|
|
removeFolder({ filePath: `archives/${collection.id}` });
|
|
}
|
|
|
|
// Delete collections after cleaning up related data
|
|
await prisma.collection.deleteMany({
|
|
where: { ownerId: userId },
|
|
});
|
|
|
|
// Delete subscription
|
|
await prisma.subscription.delete({
|
|
where: { userId },
|
|
});
|
|
|
|
// Delete user's avatar
|
|
removeFile({ filePath: `uploads/avatar/${userId}.jpg` });
|
|
|
|
// Finally, delete the user
|
|
await prisma.user.delete({
|
|
where: { id: userId },
|
|
});
|
|
});
|
|
|
|
if (process.env.STRIPE_SECRET_KEY) {
|
|
const stripe = new Stripe(process.env.STRIPE_SECRET_KEY, {
|
|
apiVersion: "2022-11-15",
|
|
});
|
|
|
|
try {
|
|
const listByEmail = await stripe.customers.list({
|
|
email: user.email?.toLowerCase(),
|
|
expand: ["data.subscriptions"],
|
|
});
|
|
|
|
if (listByEmail.data[0].subscriptions?.data[0].id) {
|
|
const deleted = await stripe.subscriptions.cancel(
|
|
listByEmail.data[0].subscriptions?.data[0].id,
|
|
{
|
|
cancellation_details: {
|
|
comment: body.cancellation_details?.comment,
|
|
feedback: body.cancellation_details?.feedback,
|
|
},
|
|
}
|
|
);
|
|
|
|
return {
|
|
response: deleted,
|
|
status: 200,
|
|
};
|
|
}
|
|
} catch (err) {
|
|
console.log(err);
|
|
}
|
|
}
|
|
|
|
return {
|
|
response: "User account and all related data deleted successfully.",
|
|
status: 200,
|
|
};
|
|
}
|