feat: enhance user management functionality with detailed feedback and improved error handling
This commit is contained in:
@@ -2,6 +2,7 @@ import mysql from "mysql2";
|
||||
import dotenv from "dotenv";
|
||||
dotenv.config();
|
||||
|
||||
// Create a MySQL connection pool using environment variables for configuration
|
||||
const pool = mysql
|
||||
.createPool({
|
||||
host: process.env.DB_HOST,
|
||||
@@ -11,21 +12,26 @@ const pool = mysql
|
||||
})
|
||||
.promise();
|
||||
|
||||
// Function to authenticate a user by username and password
|
||||
export async function loginUser(username, password) {
|
||||
// Query the users table for a matching username and password
|
||||
const [result] = await pool.query(
|
||||
"SELECT * FROM users WHERE username = ? AND password = ?",
|
||||
[username, password]
|
||||
);
|
||||
|
||||
// If a user is found, return success and user data
|
||||
if (result.length > 0) {
|
||||
console.log("User found: ", result[0].username, " ", result[0].id);
|
||||
return { success: true, user: result[0] };
|
||||
} else {
|
||||
// If no user is found, return failure message
|
||||
console.error(`Invalid username or password!; ${result[0]}`);
|
||||
return { success: false, message: "Invalid username or password" };
|
||||
}
|
||||
}
|
||||
|
||||
// Function to create a new user in the database
|
||||
export async function createUser(
|
||||
username,
|
||||
first_name,
|
||||
@@ -34,19 +40,22 @@ export async function createUser(
|
||||
email
|
||||
) {
|
||||
try {
|
||||
// Insert a new user record into the users table
|
||||
const [result] = await pool.query(
|
||||
"INSERT INTO users (username, first_name, last_name, password, email) VALUES (?, ?, ?, ?, ?)",
|
||||
[username, first_name, last_name, password, email]
|
||||
);
|
||||
|
||||
console.log("User created successfully!");
|
||||
return { success: true };
|
||||
return { success: true, message: "User created successfully!" };
|
||||
} catch (error) {
|
||||
console.error("Error creating user: ", error);
|
||||
return { success: false, message: "Error creating user" };
|
||||
// Handle errors during user creation
|
||||
console.log("Error creating user: ", error);
|
||||
return { success: false, message: "Error creating user!" };
|
||||
}
|
||||
}
|
||||
|
||||
// Function to update an existing user's information
|
||||
export async function updateUser(
|
||||
username,
|
||||
first_name,
|
||||
@@ -55,25 +64,36 @@ export async function updateUser(
|
||||
email
|
||||
) {
|
||||
try {
|
||||
// Update user details based on username
|
||||
const [result] = await pool.query(
|
||||
"UPDATE users SET first_name = ?, last_name = ?, password = ?, email = ? WHERE username = ?",
|
||||
[first_name, last_name, password, email, username]
|
||||
);
|
||||
return {
|
||||
success: true,
|
||||
message: "User updated successfully",
|
||||
resultOfquery: result,
|
||||
};
|
||||
} catch (error) {
|
||||
console.error("Error updating user: ", error);
|
||||
return {
|
||||
success: false,
|
||||
message: "Error updating user",
|
||||
resultOfquery: result,
|
||||
};
|
||||
}
|
||||
const resultOfquery = result.affectedRows;
|
||||
|
||||
// If a user was updated, return success
|
||||
if (resultOfquery > 0) {
|
||||
console.log("User updated successfully!");
|
||||
return {
|
||||
success: true,
|
||||
message: "User updated successfully!",
|
||||
resultOfquery: result,
|
||||
};
|
||||
}
|
||||
|
||||
// If no user was updated, return failure
|
||||
if (resultOfquery === 0) {
|
||||
console.log("Error updating user!");
|
||||
return {
|
||||
success: false,
|
||||
message: "Error updating user!",
|
||||
resultOfquery: null,
|
||||
};
|
||||
}
|
||||
} catch (err) {}
|
||||
}
|
||||
|
||||
// Function to delete a user from the database
|
||||
export async function deleteUser(
|
||||
username,
|
||||
first_name,
|
||||
@@ -82,26 +102,29 @@ export async function deleteUser(
|
||||
email
|
||||
) {
|
||||
try {
|
||||
// Delete user based on username and password
|
||||
const [result] = await pool.query(
|
||||
"DELETE FROM users WHERE username = ? AND password = ?",
|
||||
[username, password]
|
||||
);
|
||||
const resultOfquery = result.affectedRows;
|
||||
|
||||
// If a user was deleted, return success
|
||||
if (resultOfquery > 0) {
|
||||
console.log("User deleted successfully!");
|
||||
return {
|
||||
success: true,
|
||||
message: "User deleted successfully",
|
||||
message: "User deleted successfully!",
|
||||
resultOfquery: result,
|
||||
};
|
||||
}
|
||||
|
||||
// If no user was deleted, return failure
|
||||
if (resultOfquery === 0) {
|
||||
console.log("Error deleting user.");
|
||||
console.log("Error deleting user!");
|
||||
return {
|
||||
success: false,
|
||||
message: "Error deleting user",
|
||||
message: "Error deleting user!",
|
||||
resultOfquery: null,
|
||||
};
|
||||
}
|
||||
|
Reference in New Issue
Block a user