120 lines
4.2 KiB
JavaScript
120 lines
4.2 KiB
JavaScript
import pg from 'pg'
|
|
import bcrypt from "bcrypt";
|
|
import { pool } from '../lib/database.js';
|
|
|
|
|
|
export const getAllUsers = async (req, res) => {
|
|
try {
|
|
const result = await pool.query("SELECT nombre, apellido_pa, apellido_ma, fecha_registro, nombre_carrera, nombre_facultad FROM usuarios JOIN carreras ON usuarios.id_carrera = carreras.id_carrera JOIN facultades ON carreras.id_facultad = facultades.id_facultad;");
|
|
res.json(result.rows);
|
|
} catch (err) {
|
|
res.status(500).json({ error: err.message });
|
|
}
|
|
}
|
|
|
|
export const getSpecificUser = async (req, res) => {
|
|
try {
|
|
const result = await pool.query("SELECT nombre, apellido_pa, apellido_ma, fecha_registro, nombre_carrera, nombre_facultad FROM usuarios JOIN carreras ON usuarios.id_carrera = carreras.id_carrera JOIN facultades ON carreras.id_facultad = facultades.id_facultad WHERE id_usuario = $1;",
|
|
[req.params.userId]
|
|
);
|
|
res.json(result.rows);
|
|
} catch (err) {
|
|
res.status(500).json({ error: err.message });
|
|
}
|
|
}
|
|
|
|
export const validateForUser = async (req, res) => {
|
|
try {
|
|
const { correo_unach, clave } = req.body;
|
|
const query = await pool.query(`
|
|
SELECT usuarios.*, carreras.nombre_carrera, facultades.nombre_facultad
|
|
FROM usuarios
|
|
JOIN carreras ON usuarios.id_carrera = carreras.id_carrera
|
|
JOIN facultades ON carreras.id_facultad = facultades.id_facultad
|
|
WHERE correo_unach = $1
|
|
`, [correo_unach]);
|
|
const user = query.rows[0];
|
|
|
|
if (!user) {
|
|
return res.status(404).json({ error: 'User not found' });
|
|
}
|
|
|
|
const match = await bcrypt.compare(clave, user.clave_hasheada);
|
|
if (!match) {
|
|
return res.status(401).json({ error: 'Invalid credentials' });
|
|
}
|
|
|
|
// Clean sensitive data and return user info
|
|
const userResponse = {
|
|
id_usuario: user.id_usuario,
|
|
nombre: user.nombre,
|
|
apellido_pa: user.apellido_pa,
|
|
apellido_ma: user.apellido_ma,
|
|
correo_unach: user.correo_unach,
|
|
carrera: user.nombre_carrera,
|
|
facultad: user.nombre_facultad
|
|
};
|
|
|
|
res.json(userResponse);
|
|
}
|
|
catch (err) {
|
|
console.error(err);
|
|
res.status(500).json({ error: err.message });
|
|
}
|
|
}
|
|
|
|
export const editUser = async (req, res) => {
|
|
try {
|
|
const { userId } = req.params;
|
|
const { nombre, apellido_pa, apellido_ma, id_carrera } = req.body;
|
|
const query = await pool.query(
|
|
'UPDATE usuarios SET nombre = $1, apellido_pa = $2, apellido_ma = $3, id_carrera = $5 WHERE id_usuario = $4 RETURNING *',
|
|
[nombre, apellido_pa, apellido_ma, userId, id_carrera]
|
|
);
|
|
res.json(query.rows[0]);
|
|
}
|
|
catch (err) {
|
|
console.error(err);
|
|
res.status(500).json({ error: err.message });
|
|
throw err;
|
|
}
|
|
}
|
|
|
|
export const deleteUser = async (req, res) => {
|
|
try {
|
|
const { userId } = req.params;
|
|
const query = await pool.query(
|
|
'DELETE FROM usuarios WHERE id_usuario = $1 RETURNING *',
|
|
[userId]
|
|
);
|
|
res.json({ message: `User ${userId} deleted`, user: query.rows[0] });
|
|
}
|
|
catch (err) {
|
|
console.error(err);
|
|
res.status(500).json({ error: err.message });
|
|
throw err;
|
|
}
|
|
}
|
|
|
|
export const createNewUser = async (req,res) => {
|
|
try {
|
|
const { correo_unach, clave, matricula, nombre, apellido_pa, apellido_ma, id_carrera } = req.body;
|
|
const query = await pool.query(
|
|
'INSERT INTO public.Usuarios (correo_unach, clave_hasheada, matricula, nombre, apellido_ma, apellido_pa, id_carrera) VALUES ($1, $2, $3, $4, $5, $6, $7) RETURNING *',
|
|
[correo_unach, hashPassword(clave), matricula, nombre, apellido_ma, apellido_pa, id_carrera]
|
|
);
|
|
console.log(`Creado el usuario: ${JSON.stringify(query.rows[0])}`);
|
|
res.json(query.rows[0]);
|
|
}
|
|
catch (err) {
|
|
console.error(err);
|
|
res.status(500).json({ error: err.message });
|
|
throw err;
|
|
}
|
|
}
|
|
|
|
function hashPassword(password) {
|
|
const saltRounds = 15;
|
|
const salt = bcrypt.genSaltSync(saltRounds);
|
|
return bcrypt.hashSync(password, salt);
|
|
} |