LibreChat / e2e /setup /cleanupUser.ts
N.Achyuth Reddy
Upload 683 files
9705b6c
import connectDb from '@librechat/backend/lib/db/connectDb';
import {
deleteMessages,
deleteConvos,
User,
Session,
Balance,
Transaction,
} from '@librechat/backend/models';
type TUser = { email: string; password: string };
export default async function cleanupUser(user: TUser) {
const { email } = user;
try {
console.log('πŸ€–: global teardown has been started');
const db = await connectDb();
console.log('πŸ€–: βœ… Connected to Database');
const { _id: user } = await User.findOne({ email }).lean();
console.log('πŸ€–: βœ… Found user in Database');
// Delete all conversations & associated messages
const { deletedCount, messages } = await deleteConvos(user, {});
if (messages.deletedCount > 0 || deletedCount > 0) {
console.log(`πŸ€–: βœ… Deleted ${deletedCount} convos & ${messages.deletedCount} messages`);
}
// Ensure all user messages are deleted
const { deletedCount: deletedMessages } = await deleteMessages({ user });
if (deletedMessages > 0) {
console.log(`πŸ€–: βœ… Deleted ${deletedMessages} remaining message(s)`);
}
await Session.deleteAllUserSessions(user);
await User.deleteMany({ _id: user });
await Balance.deleteMany({ user });
await Transaction.deleteMany({ user });
console.log('πŸ€–: βœ… Deleted user from Database');
await db.connection.close();
} catch (error) {
console.error('Error:', error);
}
}
process.on('uncaughtException', (err) => console.error('Uncaught Exception:', err));