diff --git a/app/server/cli/commands/reset-password.ts b/app/server/cli/commands/reset-password.ts index aca46e7d..93d200ad 100644 --- a/app/server/cli/commands/reset-password.ts +++ b/app/server/cli/commands/reset-password.ts @@ -21,8 +21,10 @@ const resetPassword = async (username: string, newPassword: string) => { timeCost: 2, }); - await db.update(usersTable).set({ passwordHash: newPasswordHash }).where(eq(usersTable.id, user.id)); - await db.delete(sessionsTable).where(eq(sessionsTable.userId, user.id)); + await db.transaction(async (tx) => { + await tx.update(usersTable).set({ passwordHash: newPasswordHash }).where(eq(usersTable.id, user.id)); + await tx.delete(sessionsTable).where(eq(sessionsTable.userId, user.id)); + }); }; export const resetPasswordCommand = new Command("reset-password")